异步方法发送消息

Question

我正在将SpringWebSocket 4.2.4与sockjs和stomp一起使用，并试图在异步任务中从服务器向所有订阅者发送消息，但运气不佳

我的班级是：

public class MyClass{
    private timer;
    public MyClass(){
        this.timer = new Timer();
    }

    @Async
    public void myMethod(){
        timer.schedule(new MyReminder(), 1000);
    }

    @Async
    private class MyReminder extends TimerTask{

        @Autowired
        SimpMessagingTemplate messageingTemplate;

        @Override
        public void run(){
            messageingTemplate.convertAndSend("/app/subscribers","message");
        }
    }
}

但是订阅者没有得到消息

有什么帮助吗？我做错了什么：(

*编辑*

我的消息代理：

public void configureMessageBroker(MessageBrokerRegistry config){ 
    config.enableSimpleBroker("/topic","/myApp"); 
    config.setApplicationDestinationPrefixes("/myApp");
}

当我订阅时：

subscribe("myApp/someRoute") 

谢谢

**编辑2：**

谢谢你帮我解决这个问题：）

Answer 1

您可以这样做，但不能超过代理目的地。

请分享您的AbstractWebSocketMessageBrokerConfigure。

通常我们这样做：

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

经纪人不会处理所有这些/app/目的地。您只能在@SubscribeMapping的情况下订阅它们，这是来自客户机计划的请求-应答场景。

就跺脚而言，您的任务完全符合发布-订阅故事-主题。

因此，您的订阅者（客户机）应该订阅代理上的某个主题，然后您可以简单地向它发送消息。