01.消息代理
你要买菜，是不是直接去地里跟农民伯伯砍价？
你要吃肉，是不是直接去养鸡户家里，让他现场杀鸡？
肯定不是，这种直接与生产者交易的成本太大了！大到不可承受。因此有了中间商的存在。中间商将生产者与消费者的所有环节都透明化，使最终的交易流程极其简单。
于是，我们才得以直接在菜市场，甚至在网上商城直接选购琳琅满目的商品，只需要支付价钱，就能将商品拿回家。我们不需要知道一颗青菜背后的主人是谁，住在哪里，性格如何; 菜农也不需要考虑自己的菜最终会到哪个人的餐桌。
将这个场景映射到软件领域：一个系统中有多个服务，如，1.发表说说 2.消息推送 3.记录日志
用户程心是个大v，发了一条说说：“出于对人类世界及三体世界的爱，我决定参加执剑人的选举！”
发表动态后，她的五十亿粉丝都会收到消息，同时日志模块会记录她这个行为。
如果让发表说说这个服务直接同步阻塞地调用消息推送和记录日志这两个服务。那很可能程心每次发表说说都会卡住，要等到另外两个服务完成才能响应。
此时，就需要用到消息代理，程心在发表说说后只需要做一件事，将这个消息发送到消息代理中心。而其他功能模块会从消息代理中心获取消息，再进行后续的逻辑处理。这样就将系统进行了解耦，后续即使再增加其他的服务，如发送邮件给云天明，都不需要再改动发表说说的代码，其他服务只需要对接消息代理即可。
RabbitMQ 就是一个成熟，优秀，应用广泛的消息代理服务。
02.安装RabbitMQ
RabbitMQ的安装方式详情见官网描述
以mac为例：
brew install rabbitmq
加入环境变量
vim ~/.zshrc
# export PATH="/usr/local/sbin:$PATH"
服务启动
brew services start rabbitmq
浏览器访问 http://localhost:15672/
账号密码都是guest
RabbitMQ页面
03.生产者-消费者模式
RabbitMQ对于绝大多数编程语言都提供了良好的支持，详情页面
本教程以python为例，首先安装pika库
pip install pika
接下来要实现一个简单的生产者-消息者的消息功能：
-
生产者将消息推送到RabbitMQ
-
消息者从RabbitMQ获取消息
生产--消费
新建 send.py 作为生产者
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost')) # 建立连接
channel = connection.channel() # 创建信道
channel.queue_declare(queue='hello') # 声明队列
channel.basic_publish(exchange='', # 默认的交换机
routing_key='hello', # 路由键
body='Hello World!') # 消息体
print(" [x] Sent 'Hello World!'")
connection.close() # 关闭连接
在RabbitMQ中，消息是不能直接发送到队列中的，这个过程需要通过交换机（exchange）来进行。但是为了不让细节拖累我们的进度，这里我们只需要知道如何使用由空字符串表示的默认交换机即可。默认交换机比较特别，它允许我们指定消息究竟需要投递到哪个具体的队列中，队列名字需要在routing_key参数中指定
新建 receive.py 作为消费者
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello') # 生产者与消费者都声明队列，避免队列不存在
def callback(ch, method, properties, body):
print(" [x] Received %r" % body)
channel.basic_consume(callback, # 消费者获取消息后的回调函数
queue='hello', # 指定要消费的队列名称
no_ack=True)
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming() # 开始消费，程序会一直处于等待响应中
为什么消费者和生产者都要声明队列?
因为生产者与消费者有可能是在不同机器运行的，我们不知道哪个会先运行，倘若先运行的程序没有声明队列，两者就不能进行通信。因此最安全的方式就是两者都进行声明队列，如果队列已经存在，RabbitMQ会自动忽略
执行结果：
消息投递
生产者与消费者的启动顺序可以自由安排
04.队列操作
☁ rabbitMq [master] ⚡ rabbitmqctl list_queues # 显示所有队列
Timeout: 60.0 seconds ...
Listing queues for vhost / ...
task_queue 0
hello-queue 0
hello 0
topic_single_queue 0
☁ rabbitMq [master] ⚡ rabbitmqadmin delete queue name=task_queue # 删除某个队列
queue deleted
参考文献: https://www.rabbitmq.com/tutorials/tutorial-one-python.html
网友评论