MQ消息队列中间件用于分析IM即时通讯系统

MQ消息队列在IM即时通讯的用途

• 1）用户聊天消息的离线存储环节 ：由于IM消息传输具有高强度的特点，在不当干预数据库的情况下可能导致系统崩溃；因此建议将离线消息在完成入库前步骤存入的消息队列中进行暂存，并由独立部署的数据接收端进行定时化地归档至数据库；
• ２)用户的行为数据收集环节：由于用户的聊天记录与指令性操作等信息既可以满足大规模数据分析的需求；又必须按照国家相关法律法规的要求长期存储；因此这类数据同样适用的消息队列存储方案；后续仍可采用独立部署的数据接收端进行归档至数据库的操作；

在用户操作日志收集环节中使用log时需要考虑其潜在的问题：尽管具有一定的局限性但其在关键业务场景中仍然发挥着不可替代的作用同时其规模往往较大存储起来存在较大的挑战性此时恰逢LinkedIn公司的开源项目Kafka应运而生并发挥着重要作用

典型的消息队列原理图

MQ消息队列的典型应用场景

在众多中型及大型分布式系统中,MQ消息队列得到了广泛应用,其主要应用场景涉及异步处理机制的应用、应用解耦技术的支持以及具备流量削峰特性的特点,同时覆盖了实时通信功能这一