import pika

# Use the username and password to create a login credential object.
credentials = pika.PlainCredentials('rolename', 'eyJr***')
# Create a connection.
connection = pika.BlockingConnection(pika.ConnectionParameters(
    host='111.222.333.44', port=5672, virtual_host='Vhostname', credentials=credentials))
# Establish a channel.
channel = connection.channel()
# Declare an exchange.
channel.exchange_declare(exchange='ExchangeName', exchange_type="ExchangeType")

routingKeys = ['aaa.bbb.ccc', 'aaa.bbb.ddd', 'aaa.ccc.zzz', "xxx.yyy.zzz"]

for routingKey in routingKeys:
    # Send a message to the specified exchange.
    # When messages are sent without specifying an exchange, it is required to specify a message queue. The routing_key parameter represents the Routing Key when the specified exchange is used; it represents the name of the message queue when no exchange is specified.
    channel.basic_publish(exchange='direct_exchange',
                          routing_key=routingKey,
                          body=(routingKey + 'This is a new direct message.').encode(),
                          properties=pika.BasicProperties(
                              delivery_mode=2,  # Set message persistence.
                          ))
    print('send success msg to rabbitmq')
connection.close()

import os
import pika
import sys


def main():
    # Use the username and password to create a login credential object.
    credentials = pika.PlainCredentials('rolename', 'eyJr***')
    # Create a connection.
    connection = pika.BlockingConnection(pika.ConnectionParameters(
        host='111.222.333.44', port=5672, virtual_host='Vhostname', credentials=credentials))
    # Establish a channel.
    channel = connection.channel()
    # Declare a message queue.
    channel.queue_declare(queue='route_queue1', exclusive=True, durable=True)
    # Bind a message queue to an exchange and specify a Routing Key.
    routing_keys = ['aaa.bbb.ccc', 'aaa.bbb.ddd']
    for routingKey in routing_keys:
        channel.queue_bind(exchange='direct_exchange', queue="route_queue1", routing_key=routingKey)
    # Set to receive only one unacknowledged message.
    channel.basic_qos(prefetch_count=1)

    # Message consumption logic.
    def callback(ch, method, properties, body):
        print(" [Consumer1(Direct 'aaa.bbb.ccc'/'aaa.bbb.ddd')] Received (%r)" % body)
        # Manually reply with acknowledgment.
        ch.basic_ack(delivery_tag=method.delivery_tag)

    # Create a consumer to consume messages in the message queue.
    channel.basic_consume(queue='route_queue1',
                          on_message_callback=callback,
                          auto_ack=False)  # Set to non-automatic acknowledgment.

    print(" [Consumer1(Direct 'aaa.bbb.ccc'/'aaa.bbb.ddd')] Waiting for messages. To exit press CTRL+C")
    channel.start_consuming()


if __name__ == '__main__':
    try:
        main()
    except KeyboardInterrupt:
        print('Interrupted')
        try:
            sys.exit(0)
        except SystemExit:
            os._exit(0)