Java服务端可以通过以下两种方式与Android客户端进行通信：
使用WebSocket协议：
Java服务端代码：
importjavax.websocket.*;
importjavax.websocket.server.ServerEndpoint;
importjava.io.IOException;
importjava.util.concurrent.CopyOnWriteArraySet;
importjava.util.concurrent.atomic.AtomicInteger;
@ServerEndpoint("/websocket")
publicclassBackendController{
privatestaticCopyOnWriteArraySet clients =newCopyOnWriteArraySet<>();
privatestaticAtomicIntegercounter =newAtomicInteger(0);
@OnOpen
publicvoidonOpen(Session session) {
clients.add(session);
}?
@OnClose
publicvoidonClose(Session session) {}
// 此处仅展示了与发送消息相关的代码，因此只给出了注释。
// 完整的WebSocket代码实现应该包括处理接收消息、处理错误等操作。其他相关的注释如下：?
// OnMessage? ?
publicvoidonMessage(Stringmessage) {}
// OnError? ? ?
publicvoidonError(Session session, Throwable thr) {}
// OnSessionConnect? ?
publicvoidonSessionConnect(StringsessionId) {}
// OnSessionDisconnect? ?
publicvoidonSessionDisconnect(StringsessionId) {}
// OnMessageSent
publicvoidonMessageSent(int count) {}
// OnMessageReceived? ?
publicvoidonMessageReceived(Stringmessage) {}
@OnMessage
publicvoidonMessage(Stringmessage,Sessionsession) throwsIOException{
// 在此处处理接收到的消息?
System.out.println("Received message from client: "+ message);
}?
}
在Android设备端，可以使用相应的WebSocket库（如WebSocket-Android等）来连接后端WebSocket服务器并进行通信。
以下是一个Android客户端使用WebSocket协议进行通信的示例代码：
importandroid.os.Handler;
importandroid.os.Looper;
importandroid.util.SparseArray;
importorg.json.JSONException;
importorg.json.JSONObject;
importjava.net.URI;
importjava.net.URISyntaxException;
importjava.util.*;
importjavax.websocket.*;
importjavax.websocket.server.ServerEndpoint;
importjava.io.IOException;
importjava.util.concurrent.CopyOnWriteArraySet;
importjava.util.concurrent.atomic.AtomicInteger;
importandroid.os.Handler;
importandroid.os.Looper;
importandroid.util.*;
ToWebSocket@ServerEndpoint("/websocket")
publicclassBackendController{
privatestaticCopyOnWriteArraySet clients =newCopyOnWriteArraySet<>();
privatestaticAtomicIntegercounter=newAtomicInteger(0);
@OnOpenpublic
voidonOpen(Session session){
clients.add(session);
}
@OnClosepublic
voidonClose(Session session){}
@OnMessagepublic
voidonMessage(String message, Session session)throwsIOException {
// 在此处处理接收到的消息
Systemeoutprintln(""+ message);
}
@OnMessagepublic
voidonMessage(String message, Session session)throwsIOException {}
}
使用Server-Sent Events（SSE）：
SSE是一种基于HTTP协议的实时通信技术，它允许服务器向客户端推送数据，而不需要客户端发出请求。SSE使用单个HTTP连接，持续保持连接状态，并通过服务器发送的事件流来更新客户端的数据。
在Java服务端使用SSE（Server-Sent Events）和安卓客户端进行通信，需要以下步骤：
首先，你需要创建一个Java服务端来处理SSE连接和验证客户端登录。可以使用Java的Servlet或Spring框架来实现服务端逻辑。在服务端，你需要配置SSE连接和事件处理机制。以下是一个简单的Java Servlet示例：
@WebServlet("/sse")
publicclassSSEServletextendsHttpServlet{
protectedvoid doGet(HttpServletRequestrequest,HttpServletResponseresponse)throwsServletException,IOException{
response.setContentType("text/event-stream");
response.setCharacterEncoding("UTF-8");
PrintWriterout = response.getWriter();
out.write("data: Hello, SSE!\n\n");
out.flush();?
}?
}
上述代码创建了一个名为sse的Webservlet，用于处理SSE连接。它设置响应类型为text/event-stream，并返回一条数据消息。
在安卓客户端，你需要使用JavaScript来与Java服务端建立SSE连接，并通过事件流接收和解析服务端发送的数据。以下是一个简单的安卓客户端示例：
privatevoidstartSSE() {
try{
URLurl =newURL("http://localhost:8080/sse");
HttpURLConnectionconnection = (HttpURLConnection) url.openConnection();
connection.setRequestMethod("GET");
connection.setDoOutput(true);
connection.connect();
if(connection.getContentType().equals("text/event-stream")) {
BufferedReaderreader =newBufferedReader(newInputStreamReader(connection.getInputStream()));
Stringline;
while((line = reader.readLine()) !=null) {
handleSSEEvent(line);
}?
}else{
// 处理连接失败或不支持SSE的情况?
}?
}catch(IOExceptione) {
e.printStackTrace();
}finally{
// 关闭连接等清理操作?
}?
}?
privatevoidhandleSSEEvent(Stringevent) {
// 处理服务端发送的数据消息?
}
原文转载自：java服务端与安卓进行通信的方式-Java-Android-昆明微程软体