Spring メッセージの送信をどのように実現するか

Springのメッセージングは、ウェブソケットを介して実現することができます。ウェブソケットは、シングルTCP接続で全二重通信を実行するプロトコルで、リアルタイムメッセージングを実現します。

まず、Spring BootプロジェクトにWebSocketの依存関係を追加する必要があります。これは、pom.xmlファイルに以下の依存関係を追加することで実現できます。

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-websocket</artifactId>
</dependency>

WebSocketに関する情報を設定するためのWebSocket設定クラスを作成してください。この設定クラスでは、WebSocketの処理を担当するWebSocketハンドラを定義できます。例としては、クライアントの接続やメッセージの送受信、クライアントとの接続解除などの操作を処理します。以下は、基本的なWebSocket設定クラスの例です。

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {
    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(new MyWebSocketHandler(), "/websocket")
                .setAllowedOrigins("*");
    }
}

WebSocket ハンドラーを作成して、WebSocket のコネクションの操作に対応する。このハンドラーで WebSocketHandler インターフェイスを実装し、クライアントの接続やメッセージの送信と切断に対応するようにメソッドをオーバーライドする。以下はシンプルな WebSocket ハンドラーの例。

public class MyWebSocketHandler extends TextWebSocketHandler {
    private List<WebSocketSession> sessions = new CopyOnWriteArrayList<>(); // 保存所有连接的会话

    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        sessions.add(session); // 添加新连接的会话
    }

    @Override
    protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
        for (WebSocketSession s : sessions) {
            s.sendMessage(message); // 向所有连接的会话发送消息
        }
    }

    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
        sessions.remove(session); // 移除断开连接的会话
    }
}

最後にWebSocketテンプレートを使用してコントローラ内からメッセージを送信することができます。以下にコントローラクラスの簡単な例を示します：

@RestController
public class MessageController {
    @Autowired
    private WebSocketTemplate webSocketTemplate;

    @GetMapping("/send")
    public String sendMessage(@RequestParam String message) {
        webSocketTemplate.convertAndSend("/websocket", message); // 发送消息给客户端
        return "Message sent: " + message;
    }
}

Springを使ったメッセージプッシュの基本的な手順です。WebSocketで実現するメッセージプッシュは、リアルタイムの双方向通信を実現し、リアルタイムメッセージのプッシュやインスタントメッセージなどのシーンに適しています。