Javaを使っリアルタイムデータ配信機能はどのように実装されますか？

2年 ago
芽依, 雨夜
1 minute

WebSocket技術を使用してJavaリアルタイムデータプッシュ機能を実現できます。WebSocketは、シングルTCP接続上で全二重通信を行うプロトコルで、リアルタイムデータのプッシュを実現できます。

こちらが、Javaを使用してWebSocketのリアルタイムデータ送信をで行なう簡単な手順です。

  1. WebSocketに関連する依存関係をインポートする：
<dependency>
    <groupId>javax.websocket</groupId>
    <artifactId>javax.websocket-api</artifactId>
    <version>1.1</version>
</dependency>
<dependency>
    <groupId>org.glassfish.tyrus</groupId>
    <artifactId>tyrus-server</artifactId>
    <version>1.13</version>
</dependency>
  1. JAX-RSエンドポイント
@ServerEndpoint("/websocket")
public class MyWebSocketEndpoint {

    @OnOpen
    public void onOpen(Session session) {
        // 当WebSocket连接建立时调用
    }

    @OnMessage
    public void onMessage(String message, Session session) {
        // 当接收到客户端发送的消息时调用
    }

    @OnClose
    public void onClose(Session session) {
        // 当WebSocket连接关闭时调用
    }

    @OnError
    public void onError(Throwable error, Session session) {
        // 当发生错误时调用
    }

    // 自定义方法，用于实时推送数据给客户端
    public void pushData(String data) {
        // 将数据发送给客户端
    }
}
  1. アプリのコンフィギュレーションクラスで WebSocket エンドポイントを登録します。
@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {

    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(new MyWebSocketEndpoint(), "/websocket").setAllowedOrigins("*");
    }
}
  1. pushData()メソッド
@Autowired
private MyWebSocketEndpoint webSocketEndpoint;

public void sendDataToClient(String data) {
    webSocketEndpoint.pushData(data);
}

WebSocketを使用して、Javaでリアルタイムにデータを送信する機能を実装できる。クライアントがWebSocketエンドポイントに接続すると onOpen() メソッドが呼び出され、クライアントがメッセージを送信すると onMessage() メソッドが呼び出され、WebSocketが閉じられると onClose() メソッドが呼び出され、エラーが発生すると onError() メソッドが呼び出される。一方で、独自の pushData() メソッドを使用して、WebSocketエンドポイントインスタンスからリアルタイムデータをクライアントに送信できる。

bannerAds