注意:请参阅问题底部的更新了解我最终得出的结论。

我需要通过发送请求消息的 Web 套接字对请求发送多个响应，第一个响应很快，其他响应在验证数据后(大约 10 到 60 秒后，来自多个并行线程)。

我无法获得稍后的响应以停止通过所有打开的 Web 套接字进行广播。如何让它们仅发送到初始 Web 套接字？或者我应该使用Spring STOMP之外的东西(因为，​​老实说，我想要的只是将消息路由到各种功能，我不需要或想要广播到其他网络套接字的能力，所以我怀疑我可以写消息经销商本人，即使它正在重新发明轮子)。

我没有使用 Spring 身份验证(正在改进为遗留代码)。

在初始返回消息上，我可以使用@SendToUser，即使我们没有用户，Spring 也只会将返回值发送到发送消息的 websocket。 (见 this question)。

不过，由于响应速度较慢，我想我需要使用 SimpMessagingTemplate.convertAndSendToUser(user, destination, message)，但我不能，因为我必须传入用户，我不知道是什么使用 @SendToUser 的用户。我尝试按照步骤 in this question ，但在未通过身份验证时无法正常工作(在这种情况下，principal.getName() 返回 null)。

我已经为原型(prototype)大大简化了这一点，所以不用担心同步线程或其他任何事情。我只是希望网络套接​​字能够正常工作。

这是我的 Controller :

@Controller
public class TestSocketController
{
  private SimpMessagingTemplate template;

  @Autowired
  public TestSocketController(SimpMessagingTemplate template)
  {
    this.template = template;
  }

  // This doesn't work because I need to pass something for the first parameter.
  // If I just use convertAndSend, it broacasts the response to all browsers
  void setResults(String ret)
  {
    template.convertAndSendToUser("", "/user/topic/testwsresponse", ret);
  }

  // this only sends "Testing Return" to the browser tab hooked to this websocket
  @MessageMapping(value="/testws")
  @SendToUser("/topic/testwsresponse")
  public String handleTestWS(String msg) throws InterruptedException
  {
    (new Thread(new Later(this))).start();
    return "Testing Return";
  }

  public class Later implements Runnable
  {
    TestSocketController Controller;
    public Later(TestSocketController controller)
    {
        Controller = controller;
    }

    public void run()
    {
        try
        {
            java.lang.Thread.sleep(2000);

            Controller.setResults("Testing Later Return");
        }
        catch (Exception e)
        {
        }
    }
  }
}

为了记录，这里是浏览器端:

var client = null;
function sendMessage()
{
    client.send('/app/testws', {}, 'Test');
}

// hooked to a button
function test()
{
    if (client != null)
    {
        sendMessage();
        return;
    }

    var socket = new SockJS('/application-name/sendws/');
    client = Stomp.over(socket);
    client.connect({}, function(frame)
    {
        client.subscribe('/user/topic/testwsresponse', function(message)
        {
            alert(message);
        });

        sendMessage();
    });
});

这是配置:

@Configuration
@EnableWebSocketMessageBroker
public class TestSocketConfig extends AbstractWebSocketMessageBrokerConfigurer
{
    @Override
    public void configureMessageBroker(MessageBrokerRegistry config)
    {
        config.setApplicationDestinationPrefixes("/app");
        config.enableSimpleBroker("/queue", "/topic");
        config.setUserDestinationPrefix("/user");
    }

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

更新:由于信息通过原始套接字以外的其他 websocket 发送的可能性涉及安全问题，我最终向我的小组建议我们不要使用 Spring 4.0 的 STOMP over Web Sockets 实现。我理解 Spring 团队为什么按照他们的方式做，它比我们需要的更强大，但是我们项目的安全限制足够严重，实际需求也足够简单，所以我们决定走不同的方式.这不会使以下答案无效，因此请根据您的项目需求做出自己的决定。至少我们希望大家都了解了这项技术的局限性，无论好坏。

最佳答案

为什么不为每个客户使用单独的主题？

1. 客户端生成 session id。

   var sessionId = Math.random().toString(36).substring(7);

2. 客户端订阅/topic/testwsresponse/{sessionId}，然后向“/app/testws/{sessionId}”发送消息。

3. 在您的 Controller 中，您使用@MessageMapping(value="/testws/{sessionId}") 并删除@SendToUser。您可以使用 @DestinationVariable 在您的方法中访问 sessionId。
4. Controller 向/topic/testwsresponse/{sessionId} 发送更多响应。

本质上，当您使用用户目的地时，Spring 在内部会做类似的事情。由于您不使用 Spring 身份验证，因此您不能依赖此机制，但您可以轻松实现自己的，如上所述。

var client = null;
var sessionId = Math.random().toString(36).substring(7);
function sendMessage()
{
    client.send('/app/testws/' + sessionId, {}, 'Test');
}

// hooked to a button
function test()
{
    if (client != null)
    {
        sendMessage();
        return;
    }

    var socket = new SockJS('/application-name/sendws/');
    client = Stomp.over(socket);
    client.connect({}, function(frame)
    {
        client.subscribe('/topic/testwsresponse/' + sessionId, function(message)
        {
            alert(message);
        });

        // Need to wait until subscription is complete
        setTimeout(sendMessage, 1000);
    });
}); 

Controller :

@Controller
public class TestSocketController
{
    private SimpMessagingTemplate template;

    @Autowired
    public TestSocketController(SimpMessagingTemplate template)
    {
        this.template = template;
    }

    void setResults(String ret, String sessionId)
    {
        template.convertAndSend("/topic/testwsresponse/" + sessionId, ret);
    }

    @MessageMapping(value="/testws/{sessionId}")
    public void handleTestWS(@DestinationVariable String sessionId, @Payload String msg) throws InterruptedException
    {
        (new Thread(new Later(this, sessionId))).start();
        setResults("Testing Return", sessionId);
    }

    public class Later implements Runnable
    {
        TestSocketController Controller;
        String sessionId;
        public Later(TestSocketController controller, String sessionId)
        {
            Controller = controller;
            this.sessionId = sessionId;
        }

        public void run()
        {
            try
            {
                java.lang.Thread.sleep(2000);

                Controller.setResults("Testing Later Return", sessionId);
            }
            catch (Exception e)
            {
            }
        }
    }
}

刚刚测试过，按预期工作。

关于java - 在没有 Spring 身份验证的情况下通过 web-socket 多次回复，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/30038249/