java - 如何使用 ExecutorSubscribableChannel

Question

与问题autowire simpmessagingtemplate相关

我遇到了 ExecutorSubscribableChannel 类的问题。我希望服务器向浏览器发送异步消息。如何正确使用 ExecutorSubscribableChannel？

例子：

public class GreetingController {


    @Autowired
    private SimpMessagingTemplate template;

    public void setTemplate(SimpMessagingTemplate template) {
        this.template = template;
    }

    @MessageMapping("/hello")
    @SendTo("/topic/greetings")
    public Greeting greeting(HelloMessage message) throws Exception {
        Thread.sleep(5000); // simulated delay
        this.template.convertAndSend("/topic/greetings", "Hello World");
        return new Greeting("Hello, " + message.getName() + "!");
    }
}

但是我在行中发送的“hello world”文本

this.template.convertAndSend("/topic/greetings", "Hello World");

浏览器没有接收到。其他一切正常。

bean 配置为：

<bean id="executorSC" class="org.springframework.messaging.support.ExecutorSubscribableChannel"/>

<bean id="template" class="org.springframework.messaging.simp.SimpMessagingTemplate">
    <constructor-arg index="0" ref="executorSC"/>
</bean>

提前致谢。

Answer 1

这个问题是由于 Intellij IDEA 中的一个错误而写的。响应是无法自动装配。未找到 SimpMessagingTemplate 类型的 bean

已在 JetBrains 中创建票证来解决此问题。

Answer 2

尝试使用此配置

<websocket:message-broker
    application-destination-prefix="/app">
    <websocket:stomp-endpoint path="/ws">
        <websocket:sockjs />
    </websocket:stomp-endpoint>
    <websocket:simple-broker prefix="/topic/greetings" />
</websocket:message-broker>

安装的

<bean id="executorSC" class="org.springframework.messaging.support.ExecutorSubscribableChannel"/>