使用Java WebSocket进行实时通信案例分享-蒲公英云

使用Java WebSocket进行实时通信案例分享

原创ゝ一世哀愁。 2024-10-09 19:03 195阅读 0赞

Java WebSocket是一种在客户端和服务器之间进行全双工、低延迟数据交换的技术。以下是一个简单的WebSocket通信案例，使用Spring Boot框架：

创建WebSocket配置类（websocket-config.xml）：

<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:websocket="http://www.springframework.org/schema/websocket"
       xsi:schemaLocation="http://www.springframework.org/schema/beans 
        http://www.springframework.org/schema/beans/spring-beans-4.3.xsd 
        http://www.springframework.org/schema/websocket 
        http://www.springframework.org/schema/websocket/spring-websocket-4.3.xsd">
    <!-- 配置WebSocket端点 -->
    <websocket:serverEndpoint id="chatServer" path="/chat"/>
</beans>

创建WebSocket客户端（ChatClient.java）：

import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;
public class ChatClient {
    private WebSocketSession session;
    public void connect(String uri) {
        // 使用Spring Boot的WebSocket配置类创建连接
        session = WebSocketTemplate.getWebSocket_session(uri);
        if (session != null) {
            session.getAsyncRemote().sendText("Hello from client!");
        } else {
            System.out.println("Failed to connect to server.");
        }
    }
    public void sendMessage(String message) {
        if (session != null) {
            TextMessage textMsg = new TextMessage(message);
            session.getAsyncRemote().send(textMsg);
        } else {
            System.out.println("Session not found, cannot send message.");
        }
    }
    public WebSocketSession getSession() {
        return session;
    }
    public void disconnect() {
        if (session != null) {
            session.close();
            System.out.println("Disconnected from server successfully.");
        } else {
            System.out.println("Session not found, cannot disconnect.");
        }
    }
}

创建WebSocket服务端（ChatServer.java）：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.server.SessionHandler;
import org.springframework.web.socket.server.TextWebSocketSession;
@Configuration
public class ChatServer {
    @Bean
    public SessionHandler sessionHandler() {
        return new TextWebSocketSession();
    }
}