春天引导+的Spring Web插槽+ RabbitMQ的STOMP网站

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了春天引导+的Spring Web插槽+ RabbitMQ的STOMP网站相关的知识,希望对你有一定的参考价值。

我的工作我的应用程序添加实时通知

我已经做了POC与 - 春季启动 - 春天的WebSocket - SockJS - RabbitMQ的STOMP插件

我读到RabbitMQ Web STOMP 和想要做的是POC。但它说,由于对SockJS网页套接字仿效版本3.7支持已被删除。

是否有春天的WebSocket + RabbitMQ的STOMP网站有或没有任何SockJS例子。

请帮忙。

参考链接:

http://www.rabbitmq.com/stomp.html

http://www.rabbitmq.com/web-stomp.html

https://spring.io/guides/gs/messaging-stomp-websocket/

答案

@ n.sharvarish ...首先创建了这样一个的RabbitMQ的WebSocket配置类...

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer 
    private static final Logger log = LoggerFactory.getLogger(WebSocketConfig.class);
    @Value("$spring.rabbitmq.username")
    private String userName;
    @Value("$spring.rabbitmq.password")
    private String password;
    @Value("$spring.rabbitmq.host")
    private String host;
    @Value("$spring.rabbitmq.port")
    private int port;
    @Value("$endpoint")
    private String endpoint;
    @Value("$destination.prefix")
    private String destinationPrefix;
    @Value("$stomp.broker.relay")
    private String stompBrokerRelay;
    @Override
    public void configureMessageBroker(final MessageBrokerRegistry config) 
        config.enableStompBrokerRelay(stompBrokerRelay).setRelayHost(host).setRelayPort(port).setSystemLogin(userName).setSystemPasscode(password);
        config.setApplicationDestinationPrefixes(destinationPrefix);
    
    @Override
    public void registerStompEndpoints(final StompEndpointRegistry registry) 
        registry.addEndpoint(endpoint).setAllowedOrigins("*").withSockJS();
    


然后......您要使用..这样使用上述配置类..

@Autowired
SimpMessagingTemplate template

template.convertAndSend(destinationurl, object);

并配置上面的用户名和密码,并全部由application.properties

以上是关于春天引导+的Spring Web插槽+ RabbitMQ的STOMP网站的主要内容,如果未能解决你的问题,请参考以下文章

使用受 Spring 安全性保护的资源创建简单 Web 应用程序

春天引导摇篮脚本 - 获取mainClassName

杀死服务器会话春天

SFA官方翻译:使用Spring 5引导Web应用程序

spring的发音春天该怎么发音

Spring引导Web套接字,无需向特定用户发送消息