java - convertAndSend 与 Send To 注释

Question

我有以下代码:

@Controller
@EnableScheduling
public class QuoteController {

    @Scheduled(fixedDelay=5000)
    @SendTo(value="/topic/quote")
    public String sendPrice() {
        return "message from scheduler";
    }
}

它不会将消息发送到 channel 。但是下面的代码有效:

@Controller
@EnableScheduling
public class QuoteController {
    @Autowired
    public SimpMessageSendingOperations messagingTemplate;

    @Scheduled(fixedDelay=5000)
    public String sendPrice() {
        messagingTemplate.convertAndSend("/topic/quote", "message from scheduler");
    }
}

Answer 1

我们应该只在 websocket 调用的函数中使用 @SendTo 注释，它是指使用 @MessageMapping 注释的函数。

如果您想以其他方式将消息发送到队列，您应该使用messagingTemplate.convertAndSend。

@SendTo 示例:

@MessageMapping("/hello") // from websocket
@SendTo("/topic/bla")
public String foo1(String message) {
    return message;
}

.convertAndSend 示例:

@Autowired
private SimpMessagingTemplate template;

@GetMapping("/{msg}") //from GET request
public void foo2(@PathVariable String msg) {
    template.convertAndSend("/topic/bla", msg);
}