Spring Boot 如何知道 MessageMapping 指定了 Jms Queue 还是 Websocket 主题？

Question

我有一个控制器 bean，其方法如下：

@MessageMapping("${my.topic}")
public void receiveCommand(Message content) {
    log.info("Received command: " + content);
}

我还将SimpMessagingTemplate 和JmsMessagingTemplate 注入到这个控制器中。我相信我的 receiveCommand 方法的问题在于 Spring 期望这是 JMS 消息而不是 WebSocket 消息。但是这似乎无法确定，我如何确保此方法对应于 WebSocket 主题而不是 JMS 队列？

我的应用程序使用@EnableJms 和@EnableWebSocket 进行了注释，并且可以很好地通过STOMP 接收JMS 消息和发送WebSocket 消息，但似乎无法接收WebSocket 消息。

我的Controller上的消息导入如下。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.messaging.Message;
import org.springframework.messaging.handler.annotation.MessageMapping;
import org.springframework.messaging.simp.SimpMessagingTemplate;
import org.springframework.stereotype.Component;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Controller;

我还有另一种使用有效 JmsListener 的方法，所以我想知道这是否被 Spring 在类路径上以某种方式拾取并将 MessageMapping 覆盖为 JMS 队列名称。

@JmsListener(destination = "${my.destination}")
public void receiveMessage(String content) {
   System.out.println("Jms message: " + content); 
}

在运行如下所示的单元测试时，我没有看到任何堆栈跟踪或错误。

@Autowired
private SimpMessagingTemplate websocket;

@Value("${my.topic}")
private String topic;

@Test
public void shouldReceiveCommandMessages() throws IOException {
    URL url = Resources.getResource("command.json");
    String json = Resources.toString(url, Charsets.UTF_8);
    this.websocket.convertAndSend(topic, json);
}

它在一个更大的SpringBootTest 中，用于测试 Jms 发送和接收。

Answer 1

SIMP 模板用于向连接的客户端发送数据；要将数据发送到控制器，您应该使用STOMP Client。

4.4.6。发送消息

如果您想从应用程序的任何部分向连接的客户端发送消息怎么办？任何应用程序组件都可以向“brokerChannel”发送消息。最简单的方法是注入一个 SimpMessagingTemplate，并使用它来发送消息。通常它应该很容易按类型注入，例如：

4.4.15。 STOMP 客户端

Spring 提供了一个 STOMP over WebSocket 客户端和一个 STOMP over TCP 客户端。

@Controller
class Listener {

    @MessageMapping("/string")
    public void handle(String in) {
        System.out.println("STOMP Received: " + in);
    }

    @JmsListener(destination = "so50614472")
    public void listen(String in) {
        System.out.println("JMS Received: " + in);
    }

}

和

STOMP Received: foo
JMS Received: bar