SimpMessageTemplate在spring boot中不发送消息

Question

嗨，我正在尝试发送消息到跺脚endpoint，但我没有得到任何。我使用的是带有跺脚的Spring靴，下面是我的课程

@Controller
public class GreetingController {

  @MessageMapping("/hello")
  @SendTo("/topic/greetings")
  public Greeting greeting(HelloMessage message) throws Exception {
    System.out.println(message.getName());
    Thread.sleep(13000); // simulated delay
    return new Greeting("Hello, " + message.getName() + "!");
  }

}

@Controller                                                
public class Testcont {

  @Autowired
  private SimpMessagingTemplate messageSender;

  @RequestMapping(value="/Users/get",method=RequestMethod.POST)
  @ResponseBody
  public String getUser(@RequestParam(value = "userId") String userId, @RequestParam(value = "password") String password, @RequestParam(value="port") String port, HttpServletRequest request) {
    HelloMessage mess=new HelloMessage();
    mess.setName(userId);
    messageSender.convertAndSend("/app/hello",mess);
    return "Success";

}

以及我对websocket的配置

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

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

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/hello").withSockJS();
    }

}

我在控制台上没有收到任何错误。上面的代码在web浏览器中运行良好。

Answer 1

我在使用WebSocket时也面临同样的问题。对于这篇文章来说已经太晚了，但是对于正在寻找答案的人来说可能会有用。

SimpMessageTemplate-

来自上述WebSocket文档：

“ClientInbound频道” — 用于传递从WebSocket客户端接收的消息。

“clientOutboundChannel” — 用于向WebSocket客户端发送服务器消息。

“brokerChannel” — 用于从服务器端向message broker发送消息的应用程序代码。

>

客户端连接到“http://localhost:8080/portfolio一旦建立了WebSocket连接，STOMP帧就开始在其上流动（在您的例子中：registry.addEndpoint（“/hello”）。使用sockjs（），您使用“hello”，在文档中，它使用“portfolio”。）

客户端发送带有目标标题“/topic/hello”的订阅帧。收到并解码后，消息将发送到“clientInboundChannel”，然后路由到存储客户端订阅的message broker。（这是订阅WebSocket的用户界面，这里没有相关代码。没关系。）

客户端向“/app/hello”发送发送帧。“/app”前缀有助于将其路由到带注释的html" target="_blank">控制器。去掉“/app”前缀后，目标的剩余“/hello”部分将映射到GreetingController中的@MessageMapping方法。（在您的代码中：@MessageMapping（“/hello”）将接收帧。）

从GreetingController返回的值被转换为一条Spring消息，该消息的有效负载基于返回值和默认目的地标题“/topic/hello”（从输入目的地派生，其中“/app”替换为“/topic”）。生成的消息被发送到“brokerChannel”并由消息代理处理。（因此，当您尝试将数据放入服务器的WebSocket中时：messageSender.convertAndSend（“/app/hello”，mess）；应更改为messageSender。convertAndSend（“/topic/hello”，mess），因为它已经在服务器中，我们不需要目的地前缀，但需要代理前缀。）

message broker会找到所有匹配的订阅者，并通过“clientOutboundChannel”向每个订阅者发送一个消息帧，消息从该通道编码为STOMP帧，并通过WebSocket连接发送。

Answer 2

SimpMessagingTemplatebean正好用于代理部分（AbstractMessageBrokerConfiguration）：

@Bean
public SimpMessagingTemplate brokerMessagingTemplate() {
    SimpMessagingTemplate template = new SimpMessagingTemplate(brokerChannel());
    String prefix = getBrokerRegistry().getUserDestinationPrefix();
    if (prefix != null) {
        template.setUserDestinationPrefix(prefix);
    }

由于您没有将消息发送到代理目的地（在您的情况下是/app/），因此此类消息将被AbstractBrokerMessageHandler.checkCustinationPrefix（目的地）忽略。

如果您希望通过相同的@MessageMapping处理该内部消息，则应直接使用clientInboundChannel，它由SimpAnnotationMethodMessageHandler提供：

@Bean
public SimpAnnotationMethodMessageHandler simpAnnotationMethodMessageHandler() {
    SimpAnnotationMethodMessageHandler handler = createAnnotationMethodMessageHandler();
    handler.setDestinationPrefixes(getBrokerRegistry().getApplicationDestinationPrefixes());

我想您可以为clientInboundChannel创建自己的SimpMessageTemplate实例，类似于BrokerMessageTemplatebean。你会没事的。