生产消息

以下加粗内容需要替换为实例自有信息，请根据实际情况替换。

• SSL认证方式

  import pikaimport ssl# 连接信息conf = {    'host': 'ip',    'port': 5671,    'queue_name': 'queue-test',    'username': 'root',    'password': 'password'}context = ssl.SSLContext(ssl.PROTOCOL_TLSv1_2)credentials = pika.PlainCredentials(conf['username'], conf['password'])parameters = pika.ConnectionParameters(conf['host'],                                       conf['port'],                                       '/',                                       credentials,                                       ssl_options=pika.SSLOptions(context))connection = pika.BlockingConnection(parameters)channel = connection.channel()channel.queue_declare(conf['queue_name'])data = bytes('Hello World!', encoding='utf-8')channel.basic_publish(exchange='',                      routing_key=conf['queue_name'],                      body=data)print(" [x] Sent 'Hello World!'")connection.close()

• 非SSL认证方式

  import pika# 连接信息conf = {    'host': 'ip',    'port': 5672,    'queue_name': 'queue-test',    'username': 'root',    'password': 'password'}credentials = pika.PlainCredentials(conf['username'], conf['password'])parameters = pika.ConnectionParameters(conf['host'],                                       conf['port'],                                       '/',                                       credentials)connection = pika.BlockingConnection(parameters)channel = connection.channel()channel.queue_declare(conf['queue_name'])data = bytes("Hello World!", encoding="utf-8")channel.basic_publish(exchange='',                      routing_key=conf['queue_name'],                      body=data)print(" [x] Sent 'Hello World!'")connection.close()