本文会从基础概念开始，扩展到实战再扩展回概念，由浅入深去了解rabbitMQ

rabbitMQ入门
RabbitMQ 是部署最广泛的开源消息代理。
是一个由erlang开发的基于AMQP（Advanced Message Queue ）协议的开源实现。
用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面都非常的优秀。是当前最主流的消息中间件之一。

AMQP
AMQP，是应用层协议的一个开放标准，为面向消息的中间件设计。消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在，同样，消息使用者也不用知道发送者的存在。AMQP的主要特征是面向消息、队列、路由（包括点对点和发布/订阅）、可靠性、安全。

RabbitMQ常用的场景
异步：批量数据异步处理 例：批量上传文件，日志埋点，订单全流程状态监控
削峰：高负载任务负载均衡 例：电商秒杀 统一系统中 自己发送给自己
解耦：串行任务并行化 例 抓单系统–》订单系统
广播：基于发布/订阅模式实现一对多通信。 例： 多用户发送邮件

rabbitMQ的安装
在linux系统中rabbitMQ官网给出了各版本的安装方式。
http://www.rabbitmq.com/install-rpm.html

由于使用了erlang语言开发，所以需要erlang的包。
erlang和RabbitMQ的兼容性，
参考: https://www.rabbitmq.com/which-erlang.html#compatibility-matrix

下载 rabbitmq-server 、erlang.rpm。

下载后可以通过rpm -ql rabbitmq-server 查看rpm的文件。

配置文件路径默认为/etc/rabbitmq/rabbitmq
注：环境变量文件，可以不配置

rabbitmq.con?g配置文件,3.7支持新旧两种配置文件格式

rabbitmq-env.conf配置
常用的参数

RABBITMQ_NODE_IP_ADDRESS= //IP地址，空串bind所有地址，指定地址bind指定网络接口
RABBITMQ_NODE_PORT= //TCP端口号，默认是5672 RABBITMQ_NODENAME=
//节点名称。默认是rabbit RABBITMQ_CONFIG_FILE= //配置文件路径 ，即rabbitmq.config文件路径
RABBITMQ_MNESIA_BASE= //mnesia所在路径 RABBITMQ_LOG_BASE=
//日志所在路径 RABBITMQ_PLUGINS_DIR= //插件所在路径

rabbitmq.config配置
如果是用rpm包安装，可从默认docs目录复制配置文件样例：
cp /usr/share/doc/rabbitmq-server-3.6.5/rabbitmq.config.example

/etc/rabbitmq.config tcp_listerners
#设置rabbimq的监听端口，默认为[5672]。
disk_free_limit
#磁盘低水位线，若磁盘容量低于指定值则停止接收数据，默认值为{mem_relative,
1.0},即与内存相关联1：1，也可定制为多少byte.
vm_memory_high_watermark
#设置内存低水位线，若低于该水位线，则开启流控机制，默认值是0.4，即内存总量的40%。
hipe_compile
#将部分rabbimq代码用High Performance Erlang compiler编译，可提升性能，该参数是实验性，若出现erlang vm segfaults，应关掉。
force_fine_statistics
#该参数属于rabbimq_management，若为true则进行精细化的统计，但会影响性能。 frame_max #包大小，若包小则低延迟，若包则高吞吐，默认是131072=128K。 heartbeat #客户端与服务端心跳间隔，设置为0则关闭心跳，默认是600秒。

rabbitMQ插件

启用 rabbitmq-server -detached 关闭 rabbitmqctl stop

-v 显示所有插件的详情（详细）
-m 仅仅只显示插件的名称 (简约)
-E 仅仅只显示显式启用的插件
-e 仅仅只显示显式、隐式启用的插件 表示用于过滤插件名称表达式

# 显示所有的插件，每一行一个 
rabbitmq-plugins list

# 显示所有的插件，并且显示插件的版本号和描述信息 
rabbitmq-plugins list -v

# 显示所有名称含有 "management" 的插件 
rabbitmq-plugins list -v management

# 显示所有显示或者隐式启动的插件 
rabbitmq-plugins list -e rabbit

# 启用指定插件
rabbitmq-plugins enable

# 禁用指定插件
rabbitmq-plugins disable

# 禁用所有插件
rabbitmq-plugins set

# 启用management插件和它所依赖的插件，禁用其他所有插件
rabbitmq-plugins set rabbitmq_management

ss -tanl | grep 5672
LISTEN0128          *:25672                    *:*
LISTEN0128          *:15672                    *:*
LISTEN0128         :::5672                    :::*

#send.py生产者代码
import pika
import time
#配置连接参数
params = pika.ConnectionParameters('192.168.142.135')

#配置连接参数
#params = pika.ConnectionParameters('192.168.0.1')
credential = pika.PlainCredentials('zhanghao','password')

params =pika.ConnectionParameters(
	'192.168.0.1',5672,# broker, port
	'test',# virtual host
	credential# user password
	)


#建立连接
connection = pika.BlockingConnection(params)
with connection:
	#建立通道
	channel = connection.channel()
	
	#创建一个队列，queue命名为hello。如果queue不存在，消息将被dropped
	channel.queue_declare(queue='hello')
	
	#也可以连接发送message，只需要加个for循环for i in range(2),body中增加{}.format(i), 循环最好再增加一个time.sleep(0.5)
	channel.basic_publish(
		exchange='',#使用缺省exchange
		routing_key='hello',# routing_key必须指定，这里要求和目标queue一致
		body='Hello World'#消息
	    )
	print("Sent Message OK")

# recieve.py消费者代码
import pika
#获取对端连接的信息
params = pika.URLParameters('amqp://server_zhanghao:server_password@server_ip:5672/server_rabbitmq_vhost')
#建立连接
connection = pika.BlockingConnection(params)

def callback(channel,method,properties,body):
	print('Get a message = {}'.format(body))

#使用 with 可以自动关闭channel，防止遗漏导致的资源浪费
with connection:
	channel = connection.channel()
	channel.basic_consume(
		'hello',     #队列名
		callback,    #消费回调函数
		True         #不回应
    ) 
	print('Waiting for messages. To exit press CTRL+C')
	channel.start_consuming()

#生成一个交换机
channel.exchange_declare(
exchange='logs',#新交换机
exchange_type='fanout'#广播
)

#消费者端
result = channel.queue_declare(queue='')#生成一个随机名称的queue
result = channel.queue_declare(queue='',exclusive=True)#生成一个随机名称的queue，并在断开连接时删除queue

#生成queue
q1 = channel.queue_declare(queue='',exclusive=True)
q2 = channel.queue_declare(queue='',exclusive=True)
q1name = q1.method.queue  #可以通过result.method.queue查看随机名称
q2name = q2.method.queue
print(q1name,q2name)

#绑定
channel.queue_bind(exchange='logs',queue=q1name)
channel.queue_bind(exchange='logs',queue=q2name)

# send.py生产者代码
import time
import pika

parameters = pika.URLParameters('amqp://wayne:wayne@192.168.142.135:5672/test')
connection = pika.BlockingConnection(parameters)
channel = connection.channel()
with connection:
	channel.exchange_declare(exchange='logs',#新交换机
			exchange_type='fanout')#扇出，广播
	
	for i inrange(40):
		channel.basic_publish(exchange='logs',	#使用指定的exchange
				routing_key='',					#广播模式，不用指定routing_key
				body='data-{:02}'.format(i))	#消息
		time.sleep(0.01)
	print("send OK")

# recieve.py消费者代码
import pika

params = pika.URLParameters('amqp://zhanghao:password@server_rabbitmq_ip:5672/server_rabbitmq_vhost')
connection = pika.BlockingConnection(params)
channel = connection.channel()
channel.exchange_declare(exchange='logs',exchange_type='fanout')

#生成队列，名称随机，exclusive=True断开删除该队列
q1 = channel.queue_declare(queue='',exclusive=True)
q2 = channel.queue_declare(queue='',exclusive=True)
name1 = q1.method.queue#查看队列名
name2 = q2.method.queue
print(name1,name2)

#绑定到交换机
channel.queue_bind(exchange='logs',queue=name1)
channel.queue_bind(exchange='logs',queue=name2)

def callback(channel,method,properties,body):
	print('{}\n{}'.format(channel,method))	
	print('Get a message = {}'.format(body))
	
with connection:
	channel.basic_consume(
	name1,		#队列名
	callback,	#消费回调函数
	True		#不回应
    )
	channel.basic_consume(name2,callback,True)
	
	print('Waiting for messages. To exit press CTRL+C')
	channel.start_consuming()
#先启动消费者可以看到已经创建了exchange