Publish/subscribe:发布订阅模式
发布订阅模式:
一、每一个消费者监听本身的队列。
二、生产者将消息发给broker,由交换机将消息转发到绑定此交换机的每一个队列,每一个绑定交换机的队列都将接收
到消息
中间多了个交换机
一个消息生产者先发送给交换机,由交换机把消息发送给各个队列。每一个队列都有不一样的消费者在监听
实现了发布一个消息 多个消费者均可以接收到这个消息了
若是把下面的队列干掉。那么红色圈出的部分和工做模式是相同的。工做对垒虽然没有交换机也会有一个默认的交换机。
因此说发布于订阅能够实现工做队列的功能。可是它比工做队列更强大,它就能够实现多个消费者同时来接受同一条消息
测试
案例:
用户通知,当用户充值成功或转帐完成系统通知用户,通知方式有短信、邮件多种方法 。
两个消息队列分别表明了email和sms就是短信
定义一个新的生产者
把原来的代码逻辑复制到新的类里面
有一个交换机和两个队列
在声明队列的时候,声明两个队列
3d
Ctrl+T 找到实现类
这就是方法的参数
替换机有不少的常量类型
几种类型
blog
里面有不少的重载方法
绑定短信队列。
队列
每次发5条消息
第一个参数是交换机。第二个参数路由key仍是设置为空,
路由