注:此读书笔记,摘录自《大型分布式网站结构设计与实践》书籍,部分扩展内容来自于互联网。如有侵权,请联系本人删除。
涉及到ActiveMQ &JMS&RabbitMQ&RocketMQ&Kafka
JMS的组件
0.连接工厂
1.连接
2.会话
3.目的地
4.消息
5.生产者
6.消费者
JMS的可靠性机制
- 1.确认 只有再被确认之后才认为已经被成功消费了,消息的成功消费包括三个阶段:
客户接收消息、客户处理消息和消息被确认。
Session.AUTO_ACKNOWlEDGE 会话自动确认
Session.CLIENT_ACKNOWLEGE 客户通过消息的acknowledge方法确认消息
Session.DUPS_ACKNOWLEDGE 重复消息会将消息头的JMSRedelivered字段置为true, - 2.持久性
PERSISTENT
NON_PERSISTENT - 3.优先级
消息的优先级分为10个级别 从0到9(最高) - 4.消息过期
可以设置消息在一段时间后过期,默认是永不过期 - 5.临时目的地
- 6.持久订阅