使用Java WebSocket进行双向通信的问题及示例-蒲公英云

使用Java WebSocket进行双向通信的问题及示例

原创电玩女神 2024-09-25 19:57 143阅读 0赞

WebSocket是一种在单个TCP连接上进行全双工通信的协议。以下是使用Java WebSocket进行双向通信的问题，以及一个简单的示例。

问题：

如何创建WebSocket服务器？
如何编写客户端发送消息的代码？
如何处理服务器接收的消息？

示例：

创建WebSocket服务器（使用Java和Spring Boot框架）：

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.web.socket.server.WebSocketServer;
@SpringBootApplication
public class WebSocketServerApplication {
    public static void main(String[] args) {
        SpringApplication.run(WebSocketServerApplication.class, args);
        // 这里启动WebSocket服务器
    }
}

编写客户端发送消息的代码（使用Java和WebSocket API）：

import java.net.URI;
import java.util.concurrent.Executors;
import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.WebSocketContainer;
public class WebSocketClient {
    private static final URI SERVER_URI = URI.create("ws://localhost:8080/"); // 服务器URL
    public static void sendMessage(String message) {
        WebSocketContainer container = new WebSocketContainer();
        Session session = container.connectToServer(Session.class, SERVER_URI)); // 连接到服务器
        try {
            session.getBasicRemote().sendText(message); // 发送消息
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                session.close(); // 关闭连接
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}