作者：田园里的蟋蟀出处：http://www.cnblogs.com/xishuai/一般情况下，我们会使用rabbitmq_management插件，通过WebUI的方式来监控和操作RabbitMQ（端口15672），但有时候命令的方式会更加方便一些，RabbitMQ提供了CLI管理工具rabbitmqadmin，其...

一、前提erlang安装版本一致RabbitMQ安装版本一致下面的例子以192.168.73.134与192.168.73.135为服务器搭建Rabbitmq集群.二、RabbitMQ集群RabbitMQ是用erlang开发的，集群非常方便，因为erlang天生就是一门分布式语言，但其本身并不支持负载均衡。Rabbit...

安装erlang【执行】sudoapt-getinstallerlang-nox验证【执行】erl安装rabbitmq【可选】sudoapt-getupdate【可选】sudoapt-getupgrade【执行】sudoapt-getinstallrabbitmq-server补充对前面部分的一些补充：https://...

转载：https://blog.51cto.com/14156658/2461907Ansible官方文档：http://www.ansible.com.cn/index.htmlAnsible是今年来越来越火的一款开源运维自动化工具，通过Ansible可以实现运维自动化，提高运维工程师的工作效率，减少人为失误。Ans...

Postman是一个可扩展的API开发和测试协同平台工具，可以快速集成到CI/CD管道中。旨在简化测试和开发中的API工作流。Postman工具有Chrome扩展和独立客户端，推荐安装独立客户端。Postman有个workspace的概念，workspace分personal和team类型。Personalworksp...

转载：关于MQ的几件小事（五）如何保证消息按顺序执行作者：一条路上的咸鱼1.为什么要保证顺序消息队列中的若干消息如果是对同一个数据进行操作，这些操作具有前后的关系，必须要按前后的顺序执行，否则就会造成数据异常。举例：比如通过mysqlbinlog进行两个数据库的数据同步，由于对数据库的数据操作是具有顺序性的，如果操作顺...

 1.mq原则数据不能多，也不能少，不能多是说消息不能重复消费；不能少，就是说不能丢失数据。如果mq传递的是非常核心的消息，支撑核心的业务，那么这种场景是一定不能丢失数据的。2.丢失数据场景丢数据一般分为三种，一种是mq把消息丢了，一种就是消费时将消息丢了。下面从rabbitmq和kafka分别说一下，丢失数...

   RabbitMQ的消费者有两种模式实现RabbitMQ的消费者有两种模式，推模式（Push）和拉模式（Pull）。推模式：消息中间件主动将消息推送给消费者拉模式：消费者主动从消息中间件拉取消息推模式将消息提前推送给消费者，消费者必须设置一个缓冲区缓存这些消息。好处很明显，消费者总是有...

   send端#!/usr/bin/envpythonimportpikacredentials=pika.PlainCredentials("用户名","密码")connection=pika.BlockingConnection(pika.ConnectionParameters('...

 ConnectionFactory（连接管理器）：应用程序与Rabbit之间建立连接的管理器，程序代码中使用。Channel（信道）：消息推送使用的通道。Exchange（交换器）：用于接受、分配消息。Queue（队列）：用于存储生产者的消息。RoutingKey（路由键）：用于把生成者的数据分配到交换器上...

作者：Hawstein出处：http://hawstein.com/posts/google-java-style.html声明：本文采用以下协议进行授权：自由转载-非商用-非衍生-保持署名|CreativeCommonsBY-NC-ND3.0，转载请注明作者及出处。前言源文件基础源文件结构格式命名约定编程实践Java...

持久化：将交换机或队列数据保存到磁盘，服务器宕机或重启之后依然存在。非持久化：将交换机或队列的数据保存到内存中，服务器宕机或重启之后数据将不存在。在RabbitMQ中也提供了持久化和非持久化方式。实现方式为将durable设置为false即可。在配置文件中配置交换机或队列时配置durable="false"即可，配置方...

在SpringAMQP项目中Spring也提供了对RabbitMQ的支持，这里在之前学习SpringBoot的时候也整合过，但是今天这里使用的Spring的xml配置来整个rabbit.SpringAMQP项目地址：https://spring.io/projects/spring-amqp；下面来看看使用方式。pom...

　　 　　上图表示一个消费者消费消息之后，不讲消息直接存储到队列，而是使用两个消费者各自声明一个队列，将各自的对应的队列与交换机绑定。这样每个消费者都读取的是自身所对应的队列的所有消息，大达到了一个生产者生产消息，所有消费者都能消费的目的。　　将交换机类型设置为fanout即可实现Publish/Subscr...

　　　　这里表示一个生产者生产了消息发送到队列中，但是确有两个消费者在消费同一个队列中的消息。　　Producer如下：packagecom.wangx.rabbitmq.worker;importcom.rabbitmq.client.Channel;importcom.rabbitmq.client.Connect...