Rabbitmq

py 消息队列:
    线程 queue（同一进程下线程之间进行交互）
    进程 Queue（父子进程进行交互 或者 同属于同一进程下的多个子进程进行交互）

Broker：简单来说就是消息队列服务器实体。
Exchange：消息交换机，它指定消息按什么规则，路由到哪个队列。
Queue：消息队列载体，每个消息都会被投入到一个或多个队列。
Binding：绑定，它的作用就是把exchange和queue按照路由规则绑定起来。
Routing Key：路由关键字，exchange根据这个关键字进行消息投递。
vhost：虚拟主机，一个broker里可以开设多个vhost，用作不同用户的权限分离。
producer：消息生产者，就是投递消息的程序。
consumer：消息消费者，就是接受消息的程序。
channel：消息通道，在客户端的每个连接里，可建立多个channel，每个channel代表一个会话任务

‘‘‘生产者的意思，也可以称为发送者，实例中表现为send.py‘‘‘

import pika
import random

# 新建连接，rabbitmq安装在本地则hostname为‘localhost‘
hostname=‘localhost‘
parameters = pika.ConnectionParameters(hostname)  # 参数
connection = pika.BlockingConnection(parameters)  # 连接

# 创建通道
channel = connection.channel()
# 声明一个队列，生产者和消费者都要声明一个相同的队列，用来防止万一某一方挂了，另一方能正常运行
channel.queue_declare(queue=‘aaa‘)


number = random.randint(1,1000)
body = f‘hello world {number}‘
# 交换机；队列名，写声明将消息发往那个队列；消息内容
# routing_key在使用匿名交换机的时候才需要制定，表示发送到那个队列
channel.basic_publish(exchange=‘‘,
                      routing_key=‘aaa‘,
                      body=body)

print(f‘sent,{body}‘)
connection.close()

‘‘‘消费者的意思，也可以称为接收者，实例中表现为receive.py‘‘‘

import pika # pika异步

# 新建连接，rabbitmq安装在本地则hostname为‘localhost‘
hostname = ‘localhost‘
parameters = pika.ConnectionParameters(hostname)  # 参数: 传递用户名和密码的对象(https://blog.csdn.net/comprel/article/details/94662916)
connection = pika.BlockingConnection(parameters)  # 连接

# 创建通道
channel = connection.channel()
channel.queue_declare(queue=‘aaa‘)

def callback(ch, method, properties, body):
    print(4,body)

# 告诉rabbitmq使用callback来接收信息
channel.basic_consume(‘aaa‘,callback,False)
# 开始接收信息，并进入阻塞状态，队列里有信息才会调用callback进行处理,按ctrl+c退出
print (‘ [*] Waiting for messages. To exit press CTRL+C‘)
channel.start_consuming()