如何用Python向RabbitMQ生产发送0到100区间随机连续值消息

所需调整的内容 #

• 若需要控制连续发送的间隔，可导入time模块，用sleep方法调整发送频率
• 替换固定的消息体内容，使用random.uniform(0, 100)生成0到100之间的连续随机数值，转换为字符串类型后作为body参数传入basic_publish方法
• 新增循环逻辑实现连续生产消息，可根据实际需求调整循环终止条件、发送间隔

修改后的完整代码 #

import pika
import random
import time  # 新增导入，用于控制发送间隔

connection = pika.BlockingConnection(
    pika.ConnectionParameters(host='localhost')
)

channel = connection.channel()

channel.queue_declare(queue="hello")

# 连续发送逻辑，此处示例为无限循环发送，可按需修改循环条件
while True:
    # 生成0-100的随机连续值，若需要整数可替换为random.randint(0,100)
    random_value = random.uniform(0, 100)
    # 转换为字符串格式作为消息体
    message = f"random value: {random_value:.2f}"
    channel.basic_publish(exchange='', routing_key='hello', body=message)
    print(f" [x] Sent '{message}'")
    # 间隔1秒发送，可按需调整间隔时长
    time.sleep(1)

connection.close()

学习建议 #

• 入门阶段可以先从RabbitMQ官方的基础示例练起，覆盖生产消费、工作队列、发布订阅、路由、主题模式等核心场景，每个示例都动手跑一遍就能快速掌握基础用法
• 掌握基础后可以深入学习消息持久化、发布确认、死信队列、延迟队列等高阶特性，结合实际业务场景练习使用

内容的提问来源于stack exchange，提问作者Hande Yildirim