如何使用 java websockets (jsr 356) 将消息从一个端点重定向到另一个端点

Question

我正在做一个个人项目来了解 java websockets。基本上我的 HTML 客户端通过 JSR 356 websockets 向我的服务器发送消息。端点 @ServerEndpoint("/wsServer") 接收来自客户端的所有消息，我希望在另一个 portal/endpoint @ServerEndpoint("/wsDashboard") 中实时查看这些消息作为仪表板。

我很感激任何想法、文档或代码片段，因为我真的不知道，我已经看到像 apache kafka 这样的解决方案，但我不确定这是否是我需要的。

谢谢

Answer 1

在 onmessage 方法上为 /wsDashboard 创建 Java Web 套接字客户端@ServerEndpoint("/wsServer") 端点并将其保存在用户属性中。当您收到消息时，只需将消息转发到 /wsServer 网络套接字。

   @ServerEndpoint("/wsServer")
    public class MyWSServerEndPoint{
 @OnOpen
public void open( Session session) {
    // Open java client websocket connection to /wsDashboard and keep the object in 
        session.getUserProperties().put("wsDashboard ", websocket);
     }
    @OnMessage
     public void onMessage(String  message,Session session){
  //forwarding the message
       session.getUserProperties().get("wsDashboard ").getRemote().send(message);
 }
    @OnClose
    public void onClose(Session session){
     session.getUserProperties().get("wsDashboard ").close();
     }

 }

在这里创建一个客户端端点就是一个很好的例子 http://www.hascode.com/2014/11/creating-different-websocket-chat-clients-in-java/

如何使用 java websockets (jsr 356) 将消息从一个端点重定向到另一个端点

How to redirect messages from one endpoint to another using java websockets (jsr 356)

endpoint

java-websocket

jsr356