Spring客户端到客户端通信

Question

我有一个要求，我的Websocket会话应该能够相互通信，我正在创建一个请求响应模型，其中我的客户机A将在一个队列上发送一个请求，其中我有多个订阅代理(Ag1和Ag2)。我希望我的请求会在这两个订阅者之间循环运行。不幸的是，这一事件被广播给两个代理人，而不是一对一的交流。

我的Spring

@Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/websocket").withSockJS();
    }

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.setApplicationDestinationPrefixes("/app");
        config.enableSimpleBroker("/queue", "/topic");
    }

客户端JS代码

requestResponse = new RequestResponse({
    outgoingChannel : "/queue/clients",
    incomingChannel : "/topic/broadcast/clients",
    callbackFn : widget3eventHandler
},session);

代理订户代码

requestResponse = new RequestResponse({
    outgoingChannel : "/topic/broadcast/clients",
    incomingChannel : "/queue/clients",
    callbackFn : widget3eventHandler,
    processAll : true
},session);

这是SIMP经纪人的错误还是我做错了什么。

Answer 1

如果您想知道如何实现客户端到客户端的通信，可以检查此示例聊天应用程序。