spring websocket将消息从队列发送到用户convertAndSendToUser不工作

Question

在我的场景中，我希望用户订阅一个固定的websocketendpoint，并且在订阅时不需要提及队列名或主题。我想处理控制器内部的逻辑，以便从各自的队列中获取消息并将消息发送回每个用户。我想达到的目标是：-

我的客户端代码首先连接到websocketendpoint/websocket：-

client.connectToServer( aWebsocketHandler, URI.create( "wss://host.com/websocket" ) );

然后通过websocket发送STOMP connect and subscribe帧

STOMP connect frame :-
accept-version : 1.1
heart-beat : 100000,0

STOMP subscribe frame  :-

destination : /app/fixed 
id : 123
ack : auto
receipt  : 123456

正在工作的服务器端代码控制器是：-

@SubscribeMapping ( "fixed" )
    public void handle( Principal principal ) {
        System.out.println( "principal.getName();" + principal.getName() );
        String queueName = Helper.getClientToQueueMap().get( principal.getName() );
        // in loop just for testing
        while(true){

            Object o = rabbitTemplate.receiveAndConvert(queueName);
            if ( o != null ) {
                System.out.println( "Returning mesg**" + o.toString() );
                simpMessagingTemplate.convertAndSend( "/app/fixed", o.toString() );
            }
            try {
                Thread.sleep(3000);
            } catch ( InterruptedException e ) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            } 
            }
       }
       }

我的web配置有以下内容：-

@Override
    protected void configureStompEndpoints( StompEndpointRegistry registry ) {
        registry.addEndpoint( "/websocket" ).setAllowedOrigins( "*" );

    }

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

现在我想修改这段代码，以便将消息从队列发送给它各自的特定用户。即使每个用户都将订阅相同的endpoint/app/fixed，他们之间也不应该共享任何消息。通过几篇文章，我发现客户端可以订阅/user/queue/fixed，并且在控制器中使用convertAndSendToUser发送给特定的用户

simpMessagingTemplate.convertAndSendToUser( principal.getName(), "/queue/fixed", o.toString() );

但这不管用。因为我订阅的是/user/queue/fixed，所以这个带有@subscribeMapping（“fixed”）的控制器句柄方法永远不会被调用。有人能帮我做错了什么吗？

Answer 1

这对我来说很有效

@subscribeMapping（“/user/queue/fixed”）在控制器上

并且做

simpMessagingTemplate.convertAndSendToUser( principal.getName(), "/queue/fixed", o.toString() );

客户端订阅/用户/队列/固定