这一节了解一下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 userMap = new HashMap();
public DCWebSocketServer(int port) {
super(new InetSocketAddress(port));
}
public void sendMessageToUser(String message) {
message = message;
if (userMap == null || userMap.isEmpty()) return;
Set ketSet = userMap.keySet();
for (String key : ketSet) {
WebSocket clientSocket = userMap.get(key);
if (clientSocket != null) {
clientSocket.send(message);
}
}
}
@Override
public void onOpen(WebSocket conn, ClientHandshake handshake) {
String userHost = conn.getRemoteSocketAddress().getHostString();
if(!userMap.containsKey(userHost)) {
userMap.put(userHost,conn);
}
String res = getClientInfo(conn);
}
@Override
protected boolean onConnect(SelectionKey key) {
return super.onConnect(key);
}
@Override
public void onClose(WebSocket conn, int code, String reason, boolean remote) {
String userHost = conn.getRemoteSocketAddress().getHostString();
if (userMap.containsKey(userHost)) {
userMap.remove(userHost);
}
}
@Override
public void onMessage(WebSocket conn, String message) {
if(message != null && message.contains("ScanCode")) {
// sendMessageToUser(message);
}
}
@Override
public void onError(WebSocket conn, Exception ex) {
}
@Override
public 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 userMap = new HashMap();
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);
}
@Override
public void onOpen(ServerHandshake handshakedata) {
}
@Override
public void onMessage(String message) {
}
@Override
public void onClose(int code, String reason, boolean remote) {
}
@Override
public void onError(Exception ex) {
}
}
启动服务端:
serverSocketManager = ServerSocketManager.getInstance()
serverSocketManag服务器托管网er!!.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")
}
服务器托管,北京服务器托管,服务器租用 http://www.fwqtg.net
相关推荐: JDBC SQL Server Source Connector: 一览与实践
高春辉、王春生、朱峰:关于开源创业的15件小事 在快速发展的数据驱动业务环境中,确保数据在各个系统间高效、准确地同步至关重要。为了进一步的数据处理和分析,经常需要将这些数据同步到其他数据处理系统。Apache SeaTunnel 提供了一个强大而灵活的数据集成…