消息推送系统

import pika

import json

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

data = json.loads(body)

if data['type'] == 'robot':

execute_robot_task(data['command'])

def execute_robot_task(command):

# 模拟机器人任务执行

print(f"Executing robot task: {command}")

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

channel = connection.channel()

channel.queue_declare(queue='robot_queue')

channel.basic_consume(queue='robot_queue', on_message_callback=callback, auto_ack=True)

print("Waiting for messages...")

channel.start_consuming()