栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

学习MQ之前,你要先懂这些~

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

学习MQ之前,你要先懂这些~

MQ基本概念

MQ(Message Queue)消息队列,是基础数据结构中先进先出的一种数据结构。指把要传输的数据(消息)放在队列中,用队列机制来实现消息传递——生产者产生消息并把消息放入队列,然后由消费者去处理。消费者可以到指定队列拉取消息,或者订阅相应的队列,由MQ服务端给其推送消息。

MQ的作用

消息队列中间件是分布式系统中重要的组件,主要解决应用解耦,异步消息,流量削锋等问题,实现高性能,高可用,可伸缩和最终一致性架构。

  • 解耦:一个业务需要多个模块共同实现,或者一条消息有多个系统需要对应处理,只需要主业务完成以后,发送一条MQ,其余模块消费MQ消息,即可实现业务,降低模块之间的耦合。

  • 异步:主业务执行结束后从属业务通过MQ,异步执行,减低业务的响应时间,提高用户体验。

  • 削峰:高并发情况下,业务异步处理,提供高峰期业务处理能力,避免系统瘫痪。

MQ的缺点
  • 系统可用性降低:依赖服务越多,服务越容易挂掉。需要考虑MQ瘫痪的情况

  • 系统复杂性提高:需要考虑消息丢失、消息重复消费、消息传递的顺序性

  • 业务一致性:主业务和从属业务一致性的处理

主要的MQ产品

主要的MQ产品包括:RabbitMQ、ActiveMQ、RocketMQ、Kafka等。

JMS与AMQP
  • JMS基于Java,不能跨语言、跨平台,提供点对点和发布订阅式消息模型,支持多种消息类型(TextMessage、MapMessage、ByteMessage、 StreamMessage、ObjectMessage及Message。

  • AMQP是应用层级别的协议,支持跨语言、跨平台,提供了五种消息模型(direct exchange、fanout exchange、topic exchange、headers exchange、system exchange),后四种与JMS中的发布订阅模式本质上没有太大区别,仅在路由机制上做了更详细的划分),支持消息类型为byte[](复杂的消息会序列化之后发送) 。

    简而言之,JMS定义了Java API层面的标准,在Java体系中,多个client可以通过JMS进行交互,应用无需修改代码,但对跨平台的支持较差;AMQP定义了wire-level层的协议标准;天然具有跨平台、跨语言特性。

消息中间件模式分类
  • 点对点(P2P)
    一条消息只能被一个消费者消费。
  • 发布、订阅
    一条消息可以同时被多个消费者消费;生产者和消费者有时间上的依赖性,生产者在生产的消息的时候,应该至少有一个
    消费者处于在线状态。
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/1032581.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号