| 1234567891011121314 |
- #生产者
- import pika
- user_info = pika.PlainCredentials('user', 'Un2yzriWm7veSDoh')
- connection = pika.BlockingConnection(pika.ConnectionParameters('rabbitmq.rabbitmq.svc.cluster.local', 5672, '/', user_info))
- channel = connection.channel()
- # 创建一个指定名称的交换机，并指定类型为fanout，用于将接收到的消息广播到所有queue中
- channel.exchange_declare(exchange='交换机', exchange_type='fanout')
- # 将消息发送给指定的交换机，在fanout类型中，routing_key=''表示不用发送到指定queue中，
- # 而是将发送到绑定到此交换机的所有queue
- channel.basic_publish(exchange='交换机', routing_key='', body='这是一条测试消息')
|
