WebSocket 双向通信,RabbitMQ发消息到浏览器
首先RabbitMQ安装STOMP 插件
我们进入rabbitmq容器，执行下面的命令开启stomp插件
rabbitmq-plugins enable rabbitmq_web_stomp rabbitmq_web_stomp_examples将当前的容器提交为新的镜像
docker commit 3989ec68bf3c rabbitmq:stomp
停止当前的容器
docker stop 3989ec68bf3c
根据新的镜像创建同期
docker run -di --name=changgou_rabbitmq -p 5671:5617 -p 5672:5672 -p 4369:4369 -p 15671:15671 -p 15672:15672 -p 25672:25672 -p 15670:15670 -p 15674:15674 rabbitmq:stomp
注意这里插件端口是15674
然后写前端js
1.下载stomp.min.js（RabbitMQ官网有提供）
2.js代码
<html> <head> <title>RabbitMQ Web STOMP Examples : Echo Servertitle> <meta charset="UTF-8"> <script src="js/stomp.min.js">script> head> <script> var client = Stomp.client('ws://localhost:15674/ws'); var on_connect = function(x) { //paynotify是交换机，/exchange是固定写法 id = client.subscribe("/exchange/paynotify", function(d) { alert(d.body); }); }; var on_error = function() { console.log('error'); }; //账号 密码 接到消息执行的方法 异常执行方法 路由 client.connect('guest', 'guest', on_connect, on_error, '/'); script> body> html>
服务端发消息
@Autowired private StringRedisTemplate redisTemplate; public void run(){ //发一个123的消息 rabbitTemplate.convertAndSend(paynotify,"","123"); }
这样浏览器就可以接受服务端的消息了
扩展
destination 在 RabbitMQ Web STOM 中进行了相关的定义，根据使用场景的不同，主要有以下 4 种：
- 1./exchange/
对于 SUBCRIBE frame，destination 一般为/exchange/
对于 SEND frame，destination 一般为/exchange/
- 2./queue/
对于 SUBCRIBE frame，destination 会定义的共享 queue，并且实现对该队列的消息订阅。
对于 SEND frame，destination 只会在第一次发送消息的时候会定义的共享 queue。该消息会被发送到默认的 exchange 中，routingKey 即为 。 - 3./amq/queue/
这种情况下无论是 SUBCRIBE frame 还是 SEND frame 都不会产生 queue。但如果该 queue 不存在，SUBCRIBE frame 会报错。
对于 SUBCRIBE frame，destination 会实现对队列的消息订阅。
对于 SEND frame，消息会通过默认的 exhcange 直接被发送到队列中。 - 4./topic/
对于 SUBCRIBE frame，destination 创建出自动删除的、非持久的 queue 并根据 routingkey 为绑定到 amq.topic exchange 上，同时实现对该 queue 的订阅。
对于 SEND frame，消息会被发送到 amq.topic exchange 中，routingKey 为。