1.什么是消息中间件
MQ全称为Message Queue , 消息队列是应用程序和应用程序之间的通信方法 。
为什么使用MQ?2.应用场景 2.1 任务异步处理
在项目中 , 可将一些无需即时返回且耗时的操作提取出来 , 进行异步处理 , 而这种异步处理的方式大大的节省了服务器的请求响应时间 , 从而提高了系统的吞吐量
将不需要同步处理的并且耗时长的操作由消息队列通知消息接收方进行异步处理 。提高了应用程序的响应时间 。2.2 应用程序解耦合
MQ相当于一个中介 , 通过它让生产者与消费者交互 , 将应用程序进行解耦合 。2.3 削峰填谷 如某个系统会往数据库写数据 , 但是数据库只能支撑每秒1000左右的并发写入 , 并发量再高就容易宕机 。
在系统低峰期的时候并发也就100多个 , 但在高峰期时候 , 并发量会突然激增到5000以上 , 这个时候数据库肯定会卡死 。
这时候 , 可以使用MQ , 消息会被MQ保存起来 , 然后系统就可以按照自己的消费能力来消费 , 比如每秒1000个数据 , 慢慢写入数据库 , 就不会卡死数据库了 。
但使用了MQ之后 , 限制消费消息的速度为1000 , 但是这样一来 , 高峰期产生的数据势必会被积压在MQ中 , 高峰就被“削”掉了 。
但是因为消息积压 , 在高峰期过后的一段时间内 , 消费消息的速度还是会维持在1000QPS , 直到消费完积压的消息,这就叫做**“填谷”**
3. AMQP 和 JMS
【java开发中常见中间件 java中间件技术有哪些】MQ是消息通信的模型;实现MQ的大致有两种主流方式:AMQP、JMS 。3.1 AMQP AMQP 是一种协议 , 更准确地说是一种 binary wire-level protocol(链接协议) 。与 JMS 的本质差别 : AMQP不从API层进行限定 , 而是直接定义网络交换的数据格式 。
3.2 JMS JMS 即Java消息服务(JavaMessage Service)应用程序接口 , 是一个Java平台中关于面向消息中间件(MOM)的API , 用于在两个应用程序之间 , 或分布式系统中发送消息 , 进行异步通信 。
3.3 AMQP 与 JMS 区别JMS 是定义了统一的接口 , 来对消息操作进行统一; AMQP是通过规定协议来统一数据交互的格式JMS 限定了必须使用Java语言; AMQP只是协议 , 不规定实现方式 , 因此是跨语言的 。JMS 规定了两种消息模式; AMQP的消息模式更加丰富4.多种消息中间件 常见的消息队列有如下:
ActiveMQ:基于 JMSZeroMQ:基于 C 语言开发RabbitMQ:基于 AMQP 协议 , erlang 语言开发 , 稳定性好RocketMQ:基于 JMS , 阿里巴巴产品Kafka:类似MQ的产品;分布式消息系统 , 高吞吐量
推荐阅读
- 中国邮政网络培训学院考试模拟题跟答案。。家里网线都断了 想学都学不了 考试了也不会 有会的跟我说说吧。
- 200兆是多少mbps
- 如何更改qq昵称 更改qq昵称的方法
- 白宫风云 求the west wing 全集的BT种子,最好要中英双语的,下载速度快的,谢谢
- 平移现象有哪些写20个 平移现象有哪些
- 中国历史有上夏朝存在的学者观点 夏朝是否真实存在
- 奥斯维辛集中营有幸存者吗 奥斯维辛集中营有多恐怖
- 楷书最早起源形成于什么时期 中国的楷书什么时候出现的
- 英雄联盟设置fps有什么用 英雄联盟中FPS是什么意思
- 篮球怎么确定轴心脚