使用Java WebSocket进行实时通信-蒲公英云

使用Java WebSocket进行实时通信

WebSocket是一种在单个TCP连接上进行全双工通信的协议。以下是一个简单的Java WebSocket示例，使用了Spring Websocket：

创建WebSocket服务器端：

import org.springframework.web.socket.TextWebSocketMessage;
import org.springframework.web.socket.WebSocketSession;
public class WebSocketServer {
    @Override
    public void onOpen(WebSocketSession session) {
        System.out.println("Connection opened: " + session.getId());
        // 发送欢迎信息
        session.getRemoteAddress().getHostAddress();
        sendWelcomeMessage(session);
    }
    private void sendWelcomeMessage(WebSocketSession session) {
        TextWebSocketMessage message = new TextWebSocketMessage("Welcome to the WebSocket Server!");
        session.sendMessage(message);
    }
}

创建WebSocket客户端：

import org.springframework.web.socket.TextWebSocketMessage;
import org.springframework.web.socket.WebSocketSession;
public class WebSocketClient {
    public static void main(String[] args) {
        // 连接WebSocket服务器
        WebSocketSession session = new SimpleTextWebSocketClient();
        session.getWebSocketHandler().onOpen(session);
        // 发送消息
        sendMessage(session, "Hello from the client!"));
    }
    private static void sendMessage(WebSocketSession session, String message) {
        TextWebSocketMessage textMessage = new TextWebSocketMessage(message);
        session.sendMessage(textMessage);
    }
}