这一节了解一下WebSocket的用法，WebSocket是一种基于TCP的全双工通信协议，通过它可以在客户端和服务器之间建立一个持久的连接，实现实时的双向数据传输。它的主要功能特点是允许服务器主动向客户端推送信息，同时也允许客户端主动向服务器发送信息。用法如下:
app下的gradle:
implementation "org.java-websocket:Java-WebSocket:1.5.3"服务端:
import android.util.Log;
import com.foxek.usb_custom_hid_demo.UsbPlay;import org.java_websocket.WebSocket;
import org.java_websocket.handshake.ClientHandshake;
import org.java_websocket.server.WebSocketServer;import java.net.InetSocketAddress;
import java.nio.channels.SelectionKey;
import java.util.HashMap;
import java.util.Map;
import java.util.Set;public class DCWebSocketServer extends WebSocketServer {public static String TAG = "DCWebSocketServer";private Map<String, WebSocket> userMap = new HashMap<String, WebSocket>();public DCWebSocketServer(int port) {super(new InetSocketAddress(port));}public void sendMessageToUser(String message) {message = message;if (userMap == null || userMap.isEmpty()) return;Set<String> ketSet = userMap.keySet();for (String key : ketSet) {WebSocket clientSocket = userMap.get(key);if (clientSocket != null) {clientSocket.send(message);}}}@Overridepublic void onOpen(WebSocket conn, ClientHandshake handshake) {String userHost = conn.getRemoteSocketAddress().getHostString();if(!userMap.containsKey(userHost)) {userMap.put(userHost,conn);}String res = getClientInfo(conn);}@Overrideprotected boolean onConnect(SelectionKey key) {return super.onConnect(key);}@Overridepublic void onClose(WebSocket conn, int code, String reason, boolean remote) {String userHost = conn.getRemoteSocketAddress().getHostString();if (userMap.containsKey(userHost)) {userMap.remove(userHost);}}@Overridepublic void onMessage(WebSocket conn, String message) {if(message != null && message.contains("ScanCode")) {
// sendMessageToUser(message);}}@Overridepublic void onError(WebSocket conn, Exception ex) {}@Overridepublic void onStart() {}private String getClientInfo(WebSocket conn) {return conn.getRemoteSocketAddress().getHostString()+":"+ conn.getRemoteSocketAddress().getPort();}
}
import android.util.Log;
import org.java_websocket.WebSocket;
import java.util.HashMap;
import java.util.Map;public class ServerSocketManager {public static String TAG = "ServerSocketManager";private final int SOCKET_PORT = 8888;private DCWebSocketServer dcWebSocketServer;private Map<WebSocket, String> userMap = new HashMap<WebSocket, String>();public ServerSocketManager() {this.dcWebSocketServer = new DCWebSocketServer(SOCKET_PORT);}private static class ServerSocketManagerHolder {private static final ServerSocketManager INSTANCE = new ServerSocketManager();}public static ServerSocketManager getInstance() {return ServerSocketManagerHolder.INSTANCE;}public void sendMessageToAll(String message) {dcWebSocketServer.sendMessageToUser(message);}public boolean start() {try {dcWebSocketServer.start();dcWebSocketServer.setReuseAddr(true);return true;} catch (Exception e) {e.printStackTrace();return false;}}public boolean stop() {try {dcWebSocketServer.stop();return true;} catch (Exception e) {e.printStackTrace();}return false;}}客户端:
import android.util.Log;import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;import java.net.URI;public class DCSocketManagerClient extends WebSocketClient {public static String TAG = "DCSocketManagerClien";private static volatile DCSocketManagerClient client = null;public static DCSocketManagerClient getInstance(URI uri) {if (client == null) {synchronized (DCSocketManagerClient.class) {if (client == null) {client = new DCSocketManagerClient(uri);}}}return client;}public DCSocketManagerClient(URI serverUri) {super(serverUri);}@Overridepublic void onOpen(ServerHandshake handshakedata) {}@Overridepublic void onMessage(String message) {}@Overridepublic void onClose(int code, String reason, boolean remote) {}@Overridepublic void onError(Exception ex) {}
}启动服务端:
serverSocketManager = ServerSocketManager.getInstance()serverSocketManager!!.start()
启动客户端:
val uri = URI.create("ws://127.0.0.1:8888")
clientSocketManager = DCSocketManagerClient.getInstance(uri)try {clientSocketManager?.connectBlocking()} catch (e: Exception) {e.printStackTrace()}客户端发送消息:
if (clientSocketManager != null) {clientSocketManager!!.send("Java Coffee")}服务端发送消息:
if (serverSocketManager != null) {serverSocketManager!!.sendMessageToAll("Drink Coffee From ServerMsg")}
)
