客服一:
客服二:
客服三:

消息队列

提供规范的通信方式,并能够让应用系统之间相互进行数据通信和共享。
经过严酷的线上环境打磨与内购会、大促等高峰场景的严苛考验,可支撑十万级设备连接与数万消息并发,
是一个真正具备低延迟、高并发、高可用、高可靠的数据通信中间件。

产品概述
产品优势
  • 发布订阅
  • 消息顺序
  • 消息查询
  • 消息存储(目前默认存48小时)
  • 定时(延时)消息
  • SendOneWay(只发不管成功与否)
  • 事务消息
  • 消费提供集群模式和广播模式
  • 消息回溯
  • 消息优先级(客户端通过topic或tag控制)
应用场景
异步解耦 流量削峰 日志监控 物联网类应用

基于发布订阅模型,分布式应用异步解耦,可以增加应用的水平扩展性,增加前端应用快速客户反应能力。

大促等流量洪流突然来袭时,MQ可以缓冲突发流量,避免整个系统崩溃。

做为重要日志的监控通信管道,将应用日志监控对系统性能影响降到最低

物联网设备通过接入网关连接云端,DMS消息队列可以提供高速的数据传输通道,连接后端的数据分析系统

常见问题
消息堆积问题解决办法

目前Broker只保存2天的消息,2天还未被消费的数据将会自动从队尾删除。发生消息堆积时,如果消费速度一直追不上发送速度,可以选择丢弃不重要的消息。其中消息堆积超过磁盘90%则消息会自动从消息队列中删除。

消息size最大支持128K

虽然消息size最大支持128k,但是随着消息size的增大,消息队列集群TPS将会严重下降,因此建议消息size越小越好。

消费速度慢的处理方式

可以通过启动多个消费者线程或者多台机器,通过提高消费并行度加快消费速度。

消费打印日志

如果消息量较少,建议在消费入口方法打印消息,方便后续排查问题。如果能打印每条消息消费耗时,那在排查消费慢等线上问题时,就会更方便。

客户端支持

当前版本仅支持java客户端调用,它支持JDK1.7及JDK1.7以上版本。

如果您的运行环境是JDK1.6或低于JDK1.6版本,请升级到JDK1.7及JDK1.7以上版本,以便于您快速对接消息队列产品。