SpringBoot整合中间件RabbitMQ（二）
exchange.direct
打开：http://localhost:15672/#/exchanges
1.新增Exchanges：
| Name | Type | Features | Message rate in | Message rate out | +/- |
|---|---|---|---|---|---|
| (AMQP default) | direct | D | |||
| amq.direct | direct | D | |||
| amq.fanout | fanout | D | |||
| amq.headers | headers | D | |||
| amq.match | headers | D | |||
| amq.rabbitmq.trace | topic | D I | |||
| amq.topic | topic | D | |||
| exchange.direct | direct | D | |||
| exchanges.fanout | fanout | D | |||
| exchanges.topic | topic | D |
Durability：durable 持久化的
2.新增Queues：
| Overview | Messages | Message rates | +/- | |||||
|---|---|---|---|---|---|---|---|---|
| Name | Features | State | Ready | Unacked | Total | incoming | deliver / get | ack |
| unionpaysmart | D | idle | 0 | 0 | 0 | |||
| unionpaysmart.news | D | idle | 0 | 0 | 0 | |||
| invi | D | idle | 0 | 0 | 0 | |||
| invi.emps | D | idle | 0 | 0 | 0 | |||
| invi.idea | D | idle | 0 | 0 | 0 | |||
| invi.news | D | idle | 0 | 0 | 0 |
3.将exchange和Queues绑定。
Exchange: exchange.direct
| To | Routing key | Arguments | |
|---|---|---|---|
| unionpaysmart | unionpaysmart | ||
| unionpaysmart.news | unionpaysmart.news | ||
| invi | invi | ||
| invi.emps | invi.emps | ||
| invi.idea | invi.idea | ||
| invi.news | invi.news |
Exchange: exchanges.fanout
| To | Routing key | Arguments | |
|---|---|---|---|
| unionpaysmart | unionpaysmart | ||
| unionpaysmart.news | unionpaysmart.news | ||
| invi | invi | ||
| invi.emps | invi.emps | ||
| invi.idea | invi.idea | ||
| invi.news | invi.news |
Exchange: exchanges.topic
| To | Routing key | Arguments | |
|---|---|---|---|
| unionpaysmart.news | *.news | ||
| invi | invi.# | ||
| invi.emps | invi.# | ||
| invi.idea | invi.# | ||
| invi.news | *.news | ||
| invi.news | invi.# |
”#“ 匹配 0 或者多个单词
”*“ 匹配 1个单词
4.发送/接收消息
exchange.direct 点对点
-
Publish message（发布消息）：
Routing key:invi
Payload：direct.exchange.msg.helloword
direct 完全匹配路由键的 所以只有 invi 能收到消息。
-
刷新，查看队列结果：
Overview Messages Message rates +/- Name Features State Ready Unacked Total incoming deliver / get ack unionpaysmart D idle 0 0 0 unionpaysmart.news D idle 0 0 0 invi D idle 1 0 1 0.00/s invi.emps D idle 0 0 0 invi.idea D idle 0 0 0 invi.news D idle 0 0 0 -
查看队列消息：
The server reported 0 messages remaining.
Exchange exchange.direct Routing Key invi Redelivered ○ Properties delivery_mode:1headers: Payload29 bytesEncoding: string direct.exchange.msg.helloword
exchanges.fanout 点对所有
-
Publish message（发布消息）：
Routing key:invi.news
Payload：fanout.exchanges.msg.hahahahahaha
-
刷新，查看队列结果：
Overview Messages Message rates +/- Name Features State Ready Unacked Total incoming deliver / get ack unionpaysmart D idle 1 0 1 0.00/s unionpaysmart.news D idle 1 0 1 0.00/s invi D idle 2 0 2 0.00/s 0.00/s 0.00/s invi.emps D idle 1 0 1 0.00/s invi.idea D idle 1 0 1 0.00/s invi.news D idle 1 0 1 0.00/s 所有的队列收到消息+1。
-
查看队列消息：
The server reported 0 messages remaining.
Exchange exchanges.fanout Routing Key invi.news Redelivered ○ Properties delivery_mode:1headers: Payload33 bytesEncoding: string fanout.exchanges.msg.hahahahahaha
Exchange: exchanges.topic 按照指定格式匹配
-
示例1.Publish message（发布消息）：
Routing key:invi.news
Payload：topic.exchanges.msg.哈哈哈哈哈哈
符合：
invi.#又符合：
*.news除了：unionpaysmart 应该都能收到消息。
-
查看队列消息：
Overview Messages Message rates +/- Name Features State Ready Unacked Total incoming deliver / get ack unionpaysmart D idle 1 0 1 0.00/s unionpaysmart.news D idle 2 0 2 0.00/s invi D idle 3 0 3 0.00/s 0.00/s 0.00/s invi.emps D idle 2 0 2 0.00/s invi.idea D idle 2 0 2 0.00/s 0.00/s 0.00/s invi.news D idle 2 0 2 0.00/s 发现 invi 开头 news后缀的队列都加了1.
-
示例2.Publish message（发布消息）：
Routing key: hello.news
Payload：topic.exchanges.msg.嘿嘿嘿嘿
只符合：
*.news只有 news后缀的能收到消息
-
查看队列消息：
Overview Messages Message rates +/- Name Features State Ready Unacked Total incoming deliver / get ack unionpaysmart D idle 1 0 1 0.00/s 0.00/s 0.00/s unionpaysmart.news D idle 3 0 3 0.00/s invi D idle 3 0 3 0.00/s 0.00/s 0.00/s invi.emps D idle 2 0 2 0.00/s invi.idea D idle 2 0 2 0.00/s 0.00/s 0.00/s invi.news D idle 3 0 3 0.00/s 0.00/s 0.00/s 只有 news后缀的队列+1.
查看并删除消息：
Queues
Get messages
Ack Mode：Ack messages requeues false
