消息中间件入门

本文涉及的产品
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
简介: 消息中间件入门

1、什么是消息中间件



利用高效可靠的消息传递机制进行平台无关的数据交流;

并基于数据通信来进行分布式系统的集成;

通过提供消息传递和消息排队模型,它可以在分布式环境下扩展进程间的通信;


2、消息中间件的应用场景



跨系统数据传递、高并发流量削峰、数据异步处理…等等


3、常用的消息中间件



ActiveMQ、RabbitMQ、Kafka、RocketMQ


4、消息中间件设计思想



协议、持久化机制、消息分发策略、高可用、高可靠


5、协议是什么



协议是计算机之间通信时共同遵从的一组约定,都遵守相同的约定,计算机之间才能相互交流。协议是计算机之间通信时共同遵从的一组约定,都遵守相同的约定,计算机之间才能相互交流。


协议三要素:


语法:即数据与控制信息的结构或格式;

语义:即需要发出何种控制信息,完成何种动作以及做出何种响应;

时序(同步):即事件实现顺序的详细说明


消息中间件常用的协议:OpenWire、AMQP、MQTT、Kafka、OpenMessage


MQTT协议(RabbiMQ、ActiveMQ):


MQTT (Message Queuing Telemetry Transport)消息队列遥测传输是IBM开发的一个即时通讯协议,物联网系统架构中的重要组成部分。


特性:轻量、结构简单、传输快、没有事务支持、没有持久化相关设计


应用场景:适用于计算能力有限、低带宽、网络不稳定的场景。


Open Message协议(RocketMQ)


OpenMessaging是近一两年由阿里发起,与雅虎、滴滴出行、Streamlio等公司共同参与创立的分布式消息中间件、流处理领域的应用开发标准。是国内首个在全球范围内发起的分布式消息领域国际准。


特性:结构简单、解析快、有事务设计、有持久化设计


Kafka协议(kafka)


Kafka协议是基于TCP的二进制协议。消息内部是通过长度来分隔,由一些基本数据类型组成。


特性:结构简单、解析快、无事务设计、有持久化设计


6、常用持久化方式



image.png


7、常用的消息中间件分发策略



image.png


8、高可用机制



高可用性是指产品在规定的条件和规定的时刻或时间区间内处于可执行规定功能状态的能力。

当业务量大时,一台消息中间件服务器可能无法满足需求,所以需要消息中间件能够集群部署,来达到高可用的目的。


Master-Slave主从共享数据的部署方式


image.png


Master-Slave主从同步部署方式


image.png


Broker-Cluster多主集群同步部署方式


image.png


Broker-Cluster多主集群转发部署方式


image.png



Master-Slave与Broker-Cluster结合


image.png


9、高可靠是什么



高可靠性是指系统可以无故障地持续运行。比如一个系统从来不崩溃、报错,或者崩溃、报错的几率较低,那就是高可靠。

在高并发业务场景下,如果不能保证系统的高可靠,那造成的损失将会非常严重。


保证消息中间件的高可靠性,可以从以下几方面考虑


消息传输可靠:通过协议来保证系统间数据解析的正确性。

消息存储可靠:通过持久化来保证消息的存储可靠性。



目录
相关文章
|
24天前
|
消息中间件 网络协议 Dubbo
消息中间件面试题
消息中间件面试题
25 2
|
5月前
|
消息中间件 NoSQL 中间件
消息中间件系列教程(01) -知识回顾
消息中间件系列教程(01) -知识回顾
50 0
|
5月前
|
消息中间件 Kafka
温故知新-消息中间件篇
温故知新-消息中间件篇
27 0
|
6月前
|
消息中间件 存储 Java
消息中间件第一讲:RocketMQ从入门到精通
消息中间件第一讲:RocketMQ从入门到精通
147 0
|
9月前
|
消息中间件 容器
项目实战16——消息队列的意义
项目实战16——消息队列的意义
62 0
|
消息中间件 存储 Cloud Native
技术盘点:消息中间件的过去、现在和未来
目前以“事件驱动”构建的数字化商业生态才刚起步,未来 EventBridge 将围绕事件这一抽象层次实现更强大的能力,比如事件的全链路可观测、事件分析计算、低代码开发等特性,帮助企业全面落地云时代的“事件驱动”架构。
217 1
技术盘点:消息中间件的过去、现在和未来
|
消息中间件 存储 运维
消息队列与消息中间件概述:消息中间件核心概念与技术选型
消息队列是一个存放消息的容器,消息队列是分布式系统中重要的组件,使用消息队列主要是为了通过异步处理提高系统性能、削峰、降低系统耦合性。
327 1
|
消息中间件 SQL 网络协议
消息中间件MQ知识点
mq消息队列块满了:如果消息积压在 mq 里,你很长时间都没有处理掉,此时导致 mq 都快写满了,咋办?这个还有别的办法吗?没有,谁让你第一个方案执行的太慢了,你临时写程序,接入数据来消费,消费一个丢弃一个,都不要了,快速消费掉所有的消息。然后走第二个方案,到了晚上再补数据吧。
消息中间件MQ知识点
|
消息中间件 搜索推荐 Java
【深入浅出之透析RocketMQ原理及实战指南】精讲RocketMQ是什么 | 带你真正认识RocketMQ
【深入浅出之透析RocketMQ原理及实战指南】精讲RocketMQ是什么 | 带你真正认识RocketMQ
201 0
【深入浅出之透析RocketMQ原理及实战指南】精讲RocketMQ是什么 | 带你真正认识RocketMQ
|
消息中间件 Kafka RocketMQ
消息中间件(RocketMQ)笔记
分布式消息中间件,主要是实现分布式系统中解耦、异步消息、流量销锋、日志处理等场景。生产中用的最多的消息队列有Activemq,rabbitmq,kafka,rocketmq等。 以 Jms 规范和 rocketmq 为主来分享。版本基于 3.2.6 。 主要分享:JMS规范、Rocketmq的介绍、部署方式、特性的一些使用。
消息中间件(RocketMQ)笔记