2022年4月27最简单基础的python3之rabbitmq分布式配置

recv端：192.168.172.128

send端：192.168.172.128

rabbitmq：192.168.172.129

代码开始...

consumer端：

#!/usr/bin/env python
# _*_ coding:utf-8 _*_
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(host='192.168.174.129',port=5672,
                                                               credentials=pika.PlainCredentials('test', 'test'))
                                     )  # 这只是建立了一个最基本的socket
channel = connection.channel()  # 声明一个管道
channel.queue_declare(queue='hello')  # 声明queue


def callback(ch, method, properties, body):
    print('-->:', ch, method, properties)
    print("[队列]接收到了：\033[0;32m%r\033[0m" % body)

# 消费消息;# 如果收到消息，就调用这个函数‘callback’,来处理消息；
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)  # 只是声明...
print('\033[0;31m开始接收队列消息...\033[0m' )
channel.start_consuming()  # 这句代码才是正式开始接收消息；
# 注意：这句代码一执行，它就会永远你执行，它不止收一条；
# 如果没有消息，它就会阻塞在这里；

producer端：

#!/usr/bin/env python
# _*_ coding:utf-8 _*_
import pika
connection = pika.BlockingConnection(  # 先去建立socket实例
    pika.ConnectionParameters(host='192.168.174.129', port=5672,
                              credentials=pika.PlainCredentials('test', 'test'))
    )  # 这只是建立了一个最基本的socket
channel = connection.channel()  # 声明一个管道
channel.queue_declare(queue='hello')  # 声明queue
channel.basic_publish(
    exchange='',
    routing_key='hello',  # routing_key表示queue名字
    body=b'hello word')  # body消息内容
print("[队列]发送了'hello word'的内容...")
connection.close()  # 关闭队列，无需关闭管道

最简单的rabbitmq已经完成...

标签：...,27,pika,rabbitmq,queue,192.168,2022,hello,channel
来源： https://www.cnblogs.com/noobXF/p/16200433.html