2022年4月27最简单基础的python3之rabbitmq分布式配置
2022/4/27 22:12:56
本文主要是介绍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已经完成...
这篇关于2022年4月27最简单基础的python3之rabbitmq分布式配置的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-05-08有遇到过吗?同样的规则 Excel 中 比Python 结果大
- 2024-03-30开始python成长之路
- 2024-03-29python optparse
- 2024-03-29python map 函数
- 2024-03-20invalid format specifier python
- 2024-03-18pool.map python
- 2024-03-18threads in python
- 2024-03-14python Ai 应用开发基础训练,字符串,字典,文件
- 2024-03-13id3 algorithm python
- 2024-03-13sum array elements python