rabbitMQ消息队列1

rabbitmq 消息队列
	解耦

	异步
		优点：解决排队问题
		缺点： 不能保证任务被及时的执行
		应用场景：去哪儿，
	同步
		优点：保证任务被及时的执行
		缺点：排队问题

	大并发
		Web nginx  10000-20000
		    apache 1000-2000
		pv= page visit = 上yi =10server web cluster集群

		uv = user visit

		qps =

队列的作用
	1. 存储消息、数据
	2. 保证消息顺序
	3. 保证数据的交付

为什么用rabbitmq instead of python queue
是因为python queue 不能跨进程

#acknowledgment 消息不丢失
#no-ack ＝ False，如果消费者遇到情况(its channel is closed, connection is closed, or TCP connection is lost)挂掉了，
#那么，RabbitMQ会重新将该任务添加到队列中
#2、durable   消息不丢失 不能在已声明的队列中添加 而是需要重新定义
#3、消息获取顺序
#默认消息队列里的数据是按照顺序被消费者拿走，例如：消费者1 去队列中获取 奇数 序列的任务，消费者1去队列中获取 偶数 序列的任务。
#channel.basic_qos(prefetch_count=1) 表示谁来谁取，不再按照奇偶数排列
#4、发布订阅
#发布订阅和简单的消息队列区别在于，发布订阅会将消息发送给所有的订阅者，而消息队列中的数据被消费一次便消失。所以，
#RabbitMQ实现发布和订阅时，会为每一个订阅者创建一个队列，而发布者发布消息时，会将消息放置在所有相关队列中。
#exchange type = fanout
#5、关键字发送
# exchange type = direct
#之前事例，发送消息时明确指定某个队列并向其中发送消息，RabbitMQ还支持根据关键字发送，
#即：队列绑定关键字，发送者将数据根据关键字发送到消息exchange，exchange根据 关键字 判定应该将数据发送至指定队列。
#6、模糊匹配
#exchange type = topic
#在topic类型下，可以让队列绑定几个模糊的关键字，之后发送者将数据发送到exchange，exchange将传入”路由值“和 ”关键字“进行匹配，匹配成功，则将数据发送到指定队列。
## 表示可以匹配 0 个 或 多个 单词
#*  表示只能匹配 一个 单词

#当Consumer关闭连接时，这个queue要被deleted。可以加个exclusive的参数
#channel.queue_declare(exclusive=True)
生产者
	1. 端口，ip,认证信息
	2. 创建一个队列
	3. 往队列里发消息
消费者
	1. 端口，ip,认证信息
	2. 从指定队列里取消息

确保消息被消费完毕
	1. 生产者端发消息时，加参数
		  properties=pika.BasicProperties(
		  delivery_mode=2,  # make message persistent
	  ),

	2. 消费者端，消息处理完毕时，发送确认包
		 ch.basic_ack(delivery_tag=method.delivery_tag)

	channel.basic_consume(callback, #取到消息后，调用callback 函数
                      queue='task1',)
                      #no_ack=True) #消息处理后，不向rabbit-server确认消息已消费完毕

durable = True , 保证队列持久化

1）最大 Delivery Tag
#传递标记是一个64位长的值，因此其最大值为9223372036854775807。
#由于Delivery Tag唯一标识每个通道的每次投递，所以，发送者或客户端在实践中不太可能超过此值。


消息的公平分发
	消费者端
		channel.basic_qos(prefetch_count=1)

 消息订阅发布

 exchange type
	fanout = 广播
	direct = 组播
	topic  = 规则播
	header =
直连交换机（direct）,
主题交换机（topic）,
（头交换机）headers
 扇型交换机（fanout）
rpc