1、new_task.py import pika import sys connection = pika.BlockingConnection( pika.ConnectionParameters(host='10.20.1.250')) channel = connection.channel() channel.queue_declare(queue='task_queue', durable=True) message = ' '.join(sys.argv[1:]) or "Hello World!" …