我们知道rabbitMq是Erlang语言写的。那么，我们想要安装mq的话，就需要安装Erlang环境。不同版本的mq对应的erlang不同。那么怎么知道mq与erlang的版本关系呢？我们在下载页面的右侧，可以看到有个Erlang Versions的。如下图：
要实现镜像模式，需要先搭建一个普通集群模式，在这个模式的基础上再配置镜像模式可以实现高可用。
使用vm虚拟机安装两台centos7虚拟机，IP分别为192.168.30.139和140 注意防火墙问题，实验环境可选择关闭防火墙
Message Quete 消息队列，是指消息传输中存储消息的容器。多用于分布式系统。
RabbitMQ是一个广泛使用的消息服务器，采用Erlang语言编写，是一种开源的实现 AMQP（高级消息队列协议）的消息中间件；
由于最近一个项目并发请求压力比较大，所以考虑改进架构，引入消息中间件集群作为一个缓冲消息队列，具体需求： 1）将大量的WebService请求报文发送到mq集群之中，并保持消息先后顺序 2）保证每个消息的可靠性 3）维护MQ服务器的可扩展性 综合考虑，决定使用Apache的activemq，activemq是Apache出品，最流行的，能力强劲的开源消息总线。本项目使用的是activemq5.11，activemq5.11要求jdk6+，本次使用jdk7，并引入activemq服务器。 准备三台服务器： a
手动恢复有两种方式，一是恢复指定bookie节点的数据；二是恢复指定ledger的数据。
昨晚生产系统机房切换，又度过了一个不眠之夜。趁着这段无聊时间，分享一下前一段时间 RocketMQ 踩坑经历
安装name为rabbitmq的这里是直接安装最新的，如果需要安装其他版本在rabbitmq后面跟上版本号即可 docker pull rabbitmq
考虑到 Python 性能及效率性，Python Web 端一直不温不火，JAVA 和 Golang 的微服务生态一直很繁荣，也被广泛用于企业级应用开发当中，本篇文章将介绍一款 Python 微服务框架：「 Nameko 」，Nameko 是一款小巧、简洁的、异步通信方式的微服务架构，它采用 RabbitMQ 消息队列作为消息中间件，基于发布者、订阅者模式，其中，消费者与生产者基于 RPC 进行通讯。
在 Milvus 的云原生架构中，消息队列（Log Broker）可谓任重道远，它不仅要具备流式数据持久性、支持 TT 同步、事件通知等能力，还要确保工作节点从系统崩溃中恢复时增量数据的完整性。
考虑到 Python 性能及效率性，Python Web 端一直不温不火，JAVA 和 Golang 的微服务生态一直很繁荣，也被广泛用于企业级应用开发当中
注意，这里三台服务器都连接上互联网，另外RabbitMQ集群节点必须在同一网段里，如果是跨广域网，效果会变差。
RocketMQ在发送消息的时候，提示：MQClientException: No route info of this topic xxx
一、RabbitMQ简单介绍 在日常工作环境中，你是否遇到过两个（多个）系统间需要通过定时任务来同步某些数据？你是否在为异构系统的不同进程间相互调用、通讯的问题而苦恼、挣扎？如果是，那么恭喜你，消息服务让你可以很轻松地解决这些问题。消息服务擅长于解决多系统、异构系统间的数据交换（消息通知/通讯）问题，你也可以把它用于系统间服务的相互调用，即适用于云计算集群的远程调用(RPC)。毫无疑问，RabbitMQ就是当前最主流的消息中间件之一。 AMQP（Advanced Message Queuing Protoc
RabbitMQ是一个在 AMQP(高级消息队列协议)基础上完成的，可复用的企业消息系统，是当前最主流的消息中间件之一。 由erlang开发的AMQP（Advanced Message Queue 高级消息队列协议 ）的开源实现，由于erlang 语言的高并发特性，性能较好，本质是个队列，FIFO 先入先出，里面存放的内容是message,下面介绍通过在ubuntu+cpolar+rabbitMQ环境下，实现mq服务端远程访问。
在API接口同步请求过程中，不适合处理耗时过长、或者一直轮询的工作。此时，可以结合MQ异步队列任务进行后台处理。
MQ全称为Message Queue, 消息队列（MQ）是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息（针对应用程序的数据）来通信，而无需专用连接来链接它们。消息传递指的是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此来通信，直接调用通常是用于诸如远程过程调用的技术。排队指的是应用程序通过 队列来通信。队列的使用除去了接收和发送应用程序同时执行的要求。其中较为成熟的MQ产品有IBM WEBSPHERE MQ等等。
是对ActiveMQ进行高可用的一种有效的解决方案， 高可用的原 理：使用ZooKeeper（集群）注册所有的ActiveMQ Broker。只有其中的一个Broker可以对外提供服务（ 也就是Master节点） ，其 他的Broker处于待机状态，被视为Slave。如果Master因故障而不能提供服务， 则利用ZooKeeper的内部选举机制会从Slave中选举出一个Broker充当Master节 点，继续对外提供服务。 官网文档如下: http://activemq.apache.org/replicated-leveldb-store.html 二：部署方案， ActiveMQ集群环境准备： （ 1） 首先我们下载apache-activemq-5.11.1- bin.tar.gz，到我们的一台主节点上去，然后我们在（ 192.168.1.111一个节点 上实现集群即可） （ 2） Zookeeper方案
本文主要介绍如何在Ubuntu系统环境下，安装RabbitMQ与cpolar内网穿透工具实现无公网IP随时随地远程访问本地部署的MQ服务端。
RabbitMQ是一个在 AMQP(高级消息队列协议)基础上完成的，可复用的企业消息系统，是当前最主流的消息中间件之一。由erlang开发的AMQP（Advanced Message Queue 高级消息队列协议 ）的开源实现，由于erlang 语言的高并发特性，性能较好，本质是个队列，FIFO 先入先出，里面存放的内容是message,下面介绍通过在ubuntu+cpolar+rabbitMQ环境下，实现mq服务端远程访问。
一、RocketMQ基础知识介绍 Apache RocketMQ是阿里开源的一款高性能、高吞吐量、队列模型的消息中间件的分布式消息中间件。RocketMQ具有以下特点： 上图是一个典型的消息中间件收发
Message Queue, 就是消息队列，MQ 经常会作为多系统当中的网络消息传输。是一种应用程序对应用程序的通信方式。也是WEB服务器的一种重要的第三方软件。
MQTT官方网站：【入口】 EMQ官方文档：【入口】 EMQ开源代码：【GitHub】
由于安全团队要求，需要给rabbitmq加上SSL，java代码使用ssl秘钥进行连接。
先说下这个词的概念，维基百科给的解释：年轻人出于对国内压抑的工作文化的失望，与其跟随社会期望坚持奋斗，不如选择“躺平”的处事态度。
前提：三个节点都主机映射，关防火墙网络，配好yum（后边出错，主机名和映射要对应）
RabbiMQ是用Erang开发的，集群非常方便，因为Erlang天生就是一门分布式语言，但其本身并不支持负载均衡。
在主流的MQ消息队列中，主要具体是Kafka和RabbitMQ，RabbitMQ消息队列是基于AMQP的协议来实现，AMQP的协议主要是面向消息，队列，路由以及发布/订阅的模式，同时AMQP在可靠性和安全性方面是非常具备优势的。AMQP的协议主要应用于企业级的领域，对数据一致性，稳定性，可靠性要求很高的场景，这也是侧面说明了RabbitMQ消息队列中间件也是具备这方面的特性，不过比起Kafka消息的高性能，和高吞吐量而言是比较逊色的。RabbitMQ具体就是开源的消息队列服务器，主要是基于AMQP的协议来实现，使用Erlang语言编写(该语言主要应用于路由器开发编程领域)。
1、RabbitMQ的安装，rabbitmq为erlang语言开发，所以先安装erlang语言开发包，现在电脑一般都是64位的，所以下载64位的都行了。红色框可以选择版本，箭头选择64位的进行下载。下载和打开网页很慢，官网：http://www.erlang.org/downloads/20.0
1）以ActiveMQ 5.15.2 Release为例：在下载页面的Change Log处
https://www.cnblogs.com/poloyy/category/1693896.html
由于前几天感冒了，断更了几天，希望大家多穿点儿，出门戴好口罩，别感冒。上班的第一天，同事因为RabbitMQ中间件启动异常就找到了我，让我帮忙给看一下，因为这台机器是开发环境，整个小组开发调试都用这个消息中间件接收消息，平时都正常的，突然就起不来，令人匪夷所思，下面我就针对该异常的排查过程和具体问题做一个记录。
客户关系关系服务器需要部署Docker环境，将Mysql与Canal部署到Docker容器中
本文的宗旨在于通过简单干净实践的方式教会读者，使用 Docker 配置 RocketMQ 并在基于 DDD 分层结构的 SpringBoot 工程中使用 RocketMQ 技术。因为大部分 MQ 的发送都是基于特定业务场景的，所以本章节也是基于 《MyBatis 使用教程和插件开发》 章节的扩展。
假设一个场景：编写一个博客系统，需要引入elasticsearch搜索引擎实现对文章内容的检索。则需要解决MySQL与elasticsearch数据同步的问题。
对消息队列进行技术选型时，需要通过以下指标衡量你所选择的消息队列，是否可以满足你的需求：
消息队列是存储数据的一个中间件，可以理解为一个容器。生产者生产消息投递 到队列中，消费者可以拉取消息进行消费，如果消费者目前没有消费的打算，则消息队列会保留消息，直到消费者有消费的打算。
消息队列这种技术主要用在分布式设计当中，其实可以说是一种设计模式。是相对同步系统而言的。同步系统是什么呢？ 同步，是当所有的操作都完毕，才会返回结果，比如用户支付，如果是同步的话就是当用户所发起的支付操作，然后只有等支付的这个业务成功然后才给用户返回结果说支付成功，但是分布式的异步就不一样了， 异步的话它并不是等一套操作全部完成才会返回结果。用户发起支付操作，那么这个操作会立马返回给用户您已经支付成功，然后后面具体的支付扣款以及转账数据等等的操作是自己独立完成的。用户发起支付后，我们只要把这个支付的消息告诉后面的操作，说用户支付了，后面的操作逻辑我就不管了，我现在立马给用户返回信息，让用户及时得到反馈。这就是异步。
有时候我们的项目中会用到即时通讯功能，比如电商系统中的客服聊天功能，还有在支付过程中，当用户支付成功后，第三方支付服务会回调我们的回调接口，此时我们需要通知前端支付成功。而 RabbitMQ 可以很方便的实现即时通讯功能，如果你的业务只是少量地方使用即时通信，需要一个简易的消息系统，你可以直接考虑 MQ 的实现， MQ 有很高的吞吐率，具有持久化，还可以横向扩展，总之还不错，用就完了，奥利给！
rabbitmq的.erlang.cookie如果发生变化，都应该重启那个rabbitmq
今天我们来学习如何避免单点的MQ故障而导致的不可用问题，这个就要靠MQ的集群去实现了。
消息（Message）是指在应用间传送的数据。消息可以非常简单，比如只包含文本字符串，也可以更复杂，可能包含嵌入对象。
操作系统版本：SUSE Linux Enterprise Server 10 SP4 32bit
两种方式各有优劣，打电话可以立即得到响应，但是你却不能跟多个人同时通话。发送邮件可以同时与多个人收发邮件，但是往往响应会有延迟。
在注册流程中，数据写DB是主流程，但注册后给用户发优惠券或欢迎短信是分支流程，时效性也不强。
RocketMQ主要有四大组成部分：NameServer、Broker、Producer、Consumer。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
