一、MQ（Message Queue） 即 消息队列，一般用于应用系统解耦、消息异步分发，能够提高系统吞吐量。MQ的产品有很多，有开源的，也有闭源，比如ZeroMQ、RabbitMQ、 ActiveMQ、Kafka/Jafka、Kestrel、Beanstalkd、HornetQ、Apache Qpid、Sparrow、Starling、Amazon SQ...
1.准备K8S环境 2.下载基础镜像，需要安装两种插件：autocluster、rabbitmq_management 方法一： 下载已有插件镜像 [root@localhost ~]#docker pull registry.cn-hangzhou.aliyuncs.com/wise2c/kubernetes-rabbitmq-autocluster 下...
1.下载erlang官网地址 http://www.erlang.org/download 挑选合适的版本 然后 wget 比如目前18.3运行命令 wget http://erlang.org/download/otp_src_18.3.tar.gz 2.使用yum安装下必须的配件： yum install gcc glibc-devel make n...
项目需要搭建rabbitmq的高可用集群，最近在学习搭建过程，在这里记录下可以跟大家一起互相交流（这里只是记录了学习之后自己的搭建过程，许多原理的东西没有细说）。 搭建环境 CentOS7 64位 RabbitMQ 3.6.2 Keepalived 1.2.21 主机：192.168.0.1 192.168.0.2 192.16...
https://spring.io/projects/spring-cloud-stream#overviewhttps://cloud.spring.io/spring-cloud-static/spring-cloud-stream/3.0.1.RELEASE/reference/html/ 一、消息驱动概述 官网定义Spring Cloud St...
Celery: Celery是基于Python开发的分布式任务队列。它支持使用任务队列的方式在分布的机器／进程／线程上执行任务调度。 1、 celery工作流程： 消息中间件（message broker）：Celery本身不提供消息服务，但是可以方便的和第三方提供的消息中间件集成。包括，RabbitMQ, Redis, MongoDB ，SQLAl...
消息队列是非常基础的关键服务，为保证公司队列服务的高可用及负载均衡，现通过如下方式实现: RabbitMQ Cluster + Queue HA + Haproxy + Keepalived3台rabbitMQ服务器构建broker集群，允许2台服务器故障而服务不受影响，在此基础上，通过queue mirror实现队列的高可用，在本例中镜像到所有服务器，即...
何为小版本呢？就是在小数点第二位的版本号，比如3.7.7到3.7.18就是小版本升级。因为这个有操作，所以写个博客记录一下，以后可能用到。 第一个节点： 1、在节点1下载对应版本的安装包。 2、在节点1执行关闭节点， rabbitmqctl stop_app。 3、在节点1执行升级，rpm -Uvh ***.rpm。如果成功的话，就执行7。如果在停止服务的...
官方文档： Clustering Guide Highly Available (Mirrored) Queues (翻译) 一、默认模式 默认情况下，RabbitMQ集群中队列的内容仅位于单个节点上(即声明该队列的节点，也就是主节点)。创建队列时，只会在某一个节点上创建队列，其它节点上并不含有队列，而只是含有创建节点的元数据(包括队列信息，绑定关系等...
1 RABBITMQ简介及安装 RabbitMQ是一个开源的AMQP实现，服务器端用Erlang语言编写，支持多种客户端，如：Python、Ruby、.NET、Java、JMS、C、PHP、ActionScript、XMPP、STOMP等，支持AJAX。用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。 AMQP，即Advanc...