Java 開発: WebSocket を使用してリアルタイム通信を行う方法

Java 開発: WebSocket を使用してリアルタイム通信を行う方法

WebSocket は、Web アプリケーションでの双方向通信のためのプロトコルです。これにより、サーバーはクライアントにメッセージをアクティブに送信して、リアルタイム通信機能を実現できます。 Java 開発では、いくつかのオープン ソース ライブラリを使用して WebSocket 通信を実装できます。

この記事では、Java で javax.websocket ライブラリを使用して WebSocket 通信を実装する方法を紹介し、具体的なコード例を示します。

ステップ 1: 依存ライブラリを導入する
まず、javax.websocket ライブラリと javax.json ライブラリの依存関係をプロジェクトに導入する必要があります。 Maven を使用して依存関係を管理するには、次のコードを pom.xml ファイルに追加します。

<dependencies>
  <dependency>
    <groupId>javax.websocket</groupId>
    <artifactId>javax.websocket-api</artifactId>
    <version>1.1</version>
  </dependency>
  <dependency>
    <groupId>org.glassfish.tyrus</groupId>
    <artifactId>tyrus-container-grizzly-client</artifactId>
    <version>1.13</version>
  </dependency>
  <dependency>
    <groupId>javax.json</groupId>
    <artifactId>javax.json-api</artifactId>
    <version>1.1</version>
  </dependency>
  <dependency>
    <groupId>org.glassfish</groupId>
    <artifactId>javax.json</artifactId>
    <version>1.1</version>
  </dependency>
</dependencies>

ステップ 2: WebSocket サーバーとクライアントを作成する
次に、WebSocket サーバーと WebSocket クライアントを作成する必要があります。 。

サーバー側のコード例:

import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;

@ServerEndpoint("/websocket")
public class WebSocketServer {

    @OnOpen
    public void onOpen(Session session) {
        // 当有客户端连接时触发
        System.out.println("WebSocket连接已建立");
    }

    @OnMessage
    public String onMessage(String message, Session session) {
        // 当收到客户端消息时触发，并向客户端发送消息
        System.out.println("收到客户端消息：" + message);
        return "服务器返回消息：" + message;
    }

    @OnClose
    public void onClose(Session session, CloseReason closeReason) {
        // 当客户端断开连接时触发
        System.out.println("WebSocket连接已关闭");
    }

    @OnError
    public void onError(Throwable error) {
        // 当发生错误时触发
        System.out.println("WebSocket错误：" + error.getMessage());
    }
}

クライアント側のコード例:

import javax.websocket.*;
import java.net.URI;

@ClientEndpoint
public class WebSocketClient {

    private Session session;
    private CountDownLatch latch;

    public WebSocketClient() {
        latch = new CountDownLatch(1);
    }

    @OnOpen
    public void onOpen(Session session) {
        // 当连接建立时触发
        System.out.println("WebSocket连接已建立");
        this.session = session;
        latch.countDown();
    }

    public void sendMessage(String message) {
        // 向服务器发送消息
        session.getAsyncRemote().sendText(message);
    }

    @OnMessage
    public void onMessage(String message) {
        // 当收到服务器消息时触发
        System.out.println("收到服务器消息：" + message);
    }

    @OnClose
    public void onClose(Session session, CloseReason closeReason) {
        // 当服务器断开连接时触发
        System.out.println("WebSocket连接已关闭");
    }
    
    @OnError
    public void onError(Throwable error) {
        // 当发生错误时触发
        System.out.println("WebSocket错误：" + error.getMessage());
    }
    
    public void close() throws InterruptedException {
        // 关闭WebSocket连接
        session.close();
        latch.await();
    }
}

ステップ 3: サーバーとクライアントを起動する
最後に、メインクラスのサーバーとクライアント。

public class Main {
    public static void main(String[] args) {
        WebSocketServer server = new WebSocketServer();
        ServerContainer serverContainer = ContainerProvider.getWebSocketContainer();
        try {
            serverContainer.connectToServer(server, new URI("ws://localhost:8080/websocket"));
            WebSocketClient client = new WebSocketClient();
            session.getBasicRemote().sendText("客户端发送消息");
            client.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

上記はJavaとjavax.websocketライブラリを利用してWebSocket通信を実装するサンプルコードです。 WebSocket を介して、サーバーとクライアントの間でメッセージを迅速に転送し、リアルタイム通信を実現できます。 WebSocket を使用すると、リアルタイムでクライアントにデータをプッシュできます。これは、リアルタイム チャットやリアルタイム データ表示などのアプリケーション シナリオで非常に役立ちます。

以上がJava 開発: WebSocket を使用してリアルタイム通信を行う方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。