...
|
...
|
@@ -3,8 +3,7 @@ |
|
|
### yoho MQ
|
|
|
|
|
|
### 相关类图
|
|
|
![](pic/yoho_mq_class.png)
|
|
|
|
|
|
![](PIC/yoho_mq_class.png)
|
|
|
消息发送通过YhProducerTemplate发送,其有几个重载的函数,最终只有两类,延时消息和普通消息。生产者Producer调用以下两个接口就可以完成消息的传送。
|
|
|
|
|
|
- 普通消息发送接口:
|
...
|
...
|
@@ -52,8 +51,7 @@ public interface YhMessageConsumer { |
|
|
8. 启动listenerContainer
|
|
|
|
|
|
下图是大致初始化相关图:
|
|
|
|
|
|
![](pic/yoho_mq_simple.png)
|
|
|
![](PIC/yoho_mq_simple.png)
|
|
|
|
|
|
|
|
|
### 延时消息队列
|
...
|
...
|
@@ -94,9 +92,7 @@ TTl队列内的消息在到达ttl时间时就过期成为一个deadMsg。利用D |
|
|
9. 启动listenerContainer
|
|
|
|
|
|
下图是大致初始化相关图:
|
|
|
|
|
|
![](pic/yoho_mq_delay.png)
|
|
|
|
|
|
![](PIC/yoho_mq_delay.png)
|
|
|
|
|
|
|
|
|
|
...
|
...
|
|