作者：一个怪瓜的自白 | 来源：互联网 | 2023-08-20 18:39
一、消息队列概述
消息队列中间件是分布式系统的重要组建&＃xff0c;主要解决&＃xff1a;应用耦合&＃xff0c;异步消息&＃xff0c;流量削峰、消息通讯等问题。
目前在生产环境&＃xff0c;使用较多的消息队列有&＃xff1a;ActiveMQ、RabbitMQ、ZeroMQ、kafka、MetaMQ、RocketMQ
二、消息队列应用场景
1.异步处理
如&＃xff0c;用户注册后&＃xff0c;串行发送注册邮件和短信&＃xff0c;会浪费时间。但是使用消息队列&＃xff0c;注册信息写入数据库——写入消息队列——异步读取——发送注册邮件&＃xff08;注册短信&＃xff09;&＃xff0c;可提高系统吞吐量。
2.应用解耦
场景&＃xff1a;用户下单后&＃xff0c;订单系统需要通知库存系统&＃xff0c;传统方法是调用库存系统的接口&＃xff0c;但假如库存系统无法访问&＃xff0c;则订单失败&＃xff0c;订单系统与库存系统耦合。
解决方案&＃xff1a;
3.流量削峰
应用场景&＃xff1a;秒杀活动&＃xff0c;一般会因为流量过大而导致应用挂掉。应用消息队列&＃xff0c;可控制活动人数&＃xff0c;缓解短时间内高流量
解决方案&＃xff1a;服务器接受用户请求后&＃xff0c;首先写入消息队列&＃xff0c;如果消息队列长度超过最大数量&＃xff0c;则直接抛弃用户请求或跳转到错误页面。
4.日志处理
如kafka的应用&＃xff0c;解决大量日志传输的问题。
日志采集客户端&＃xff1a;负责日志数据采集&＃xff0c;定时写入kafka队列。
kafka队列&＃xff1a;负责日志数据的接受、存储和转发
注&＃xff1a;Elasticsearch&＃xff1a;实时日志分析服务的核心技术&＃xff0c;一个schemaless&＃xff0c;实时数据存储服务&＃xff0c;通过Index组织数据&＃xff0c;兼具强大的搜索和统计功能。kibana是基于Elasticsearch的数据可视化组件。
三、JMS消息服务
有两种消息模型&＃xff0c;P2P和 publish/subscribe
1.点对点
每个消息 只有一个消费者&＃xff0c;发送者发送消息后&＃xff0c;不会管是否接收成功
2.发布/订阅模式
三个角色&＃xff1a;主题、发布者、订阅者。多个发布者发送消息到多个订阅者。
3.消息消费&＃xff1a;
同步&＃xff1a;订阅者通过receive方法接收消息&＃xff0c;接收到消息前将一直阻塞
异步&＃xff1a;可注册一个消息监听器&＃xff0c;小气到达之后&＃xff0c;自动调用监听器的onMessage方法
京公网安备 11010802041100号