MQ客户端使用手册.docx

Notes
DEMO程序(Java)
Version (当前支持版本)
大大简化配置,连接工厂类、消费***容器,发送模板都共享,不用为每个消息类型单独配置
升级了SAF版本和Zookeeper客户端版本,解决了重连Zookeeper异常及其可能造成的内存溢出
提供了发送者和消费者的接口
消费者容器增加了一些API,增加和删除消费者,暂停和恢复消费,检查是否暂停消费等等
消费方,如果配置了异常处理器,则会自动创建过滤器,提供过滤数据和暂停功能,需要zookeeper支持
消费者默认延迟5秒启动
并发数,默认1-5,根据消息数量自动调整消费会话线程
每个消息类型,单独的连接,避免互相影响
异步关闭连接,解决某些场景,关闭时间过长,会阻塞进程一段时间
解决管理端暂停消费,应用重启后继续消费的问题
管理端移除消息类型的消费者,应用自动停止该消息类型的消费,需要zookeeper支持
增加TextMessageListener类,建议文本消息***都从该类继承
升级说明:大量重构调整了相关API和配置文件,请按照Demo重新配置和测试
Version
增加暂停消费消息功能
增加在日志中记录发送或消费缓慢的功能
修复客户端无法正常关闭的bug
修复集群切换连接无法完全断开的问题
Version
增加批量消费接口
增加发送异常重试功能
增加消息***功能
增加消费线程智能调整功能
Version
修复zookeeper重启造成Leader选举问题,
Version
增加消息批量发送接口
大幅度优化消息发送和接收速度
Version
修复zookeeper重启造成Leader选举问题,
Version
修复一个重试服务相关bug
Version
修复saf版本获取错误的问题
Version
增加mq命名空间配置功能,简化客户端配置
Version
修改API调用Close程序不能正常退出情况
ClusterMessageListenerContainer增加sessionTransacted和sessionAcknowledgeMode读取方法
Version
ClusterMessageListenerContainer增加MessageListenerAdapter兼容
Version
消费者增加重试服务
Version
修改concurrency配置
Version
集群客户端发布,支持动态扩容,Failover,LoadBalance

短信信息
邮件type
说明
解决方案
MQ积压
backlog
消费方未能及时消费完发送来的消息,积压在MQ服务端
检测消费者连接是否断开,消费速度是否存在问题
MQ连接
connection
客户端与MQ服务端连接断开
是否正在上线,如果未在上线检测消费者进程是否存活,网络是否存在问题
MQ重试
retry
发送消息失败或是消费方消费出现错误数据
检查消息内容或消费逻辑是否存在问题,解决后消息会自动重试成功,如无法解决3天后消息会过期
MQ死信
dlq
消费方消费出现错误数据,重试服务未开启或是调用失败
检查消息内容或消费逻辑是否存在问题,解决后需手动在管理端进行move操作,移动回正常队列


规范
说明
监听模式
保证消息的及时性
消息持久化
避免消息丢失
VirtualTopic替换Topic
支持同一个消费者集群负载均衡
发布订阅关系
需要提前申请,通过管理控制台在系统中维护好
messageId
字符串,业务消息的唯一ID,存放在JMS消息Properties中自定义属性中,便于归档查询
systemId
字符串,业务系统编码,和管理控制台中维护的值一致,存放在JMS消息Properties中自定义属性中,便于归档查询
compressType
字符串,自定义压缩算法,存放在JMS消息Properties中自定义属性中,1为zip压缩
Queue命名规范
系统代码_消息类型代码
VirtualTopic生产者命名规范

VirtualTopic消费者命名规范

消息重发
MQ为了保证消息的可靠,可能造成消息重发,消费者必须