和關鍵字相似

生產者：

# coding:utf8
# __author:  Administrator
# date:      2018/3/15 0015
# /usr/bin/env python
import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(
    host=‘localhost‘
))

channel = connection.channel()

channel.exchange_declare(exchange=‘topic_logs‘,
                         type
 
=‘topic‘)

key = ‘ha.ga.ef‘
message=‘Hello World‘
channel.basic_publish(exchange=‘topic_logs‘,
                      routing_key=key,
                      body=message)

print("Sent message")
connection.close()

消費者：

# coding:utf8
# __author:  Administrator
# date:      2018/3/15 0015
# /usr/bin/env python
import pika
import sys

connection 
 
= pika.BlockingConnection(pika.ConnectionParameters(
    host=‘localhost‘
))

channel = connection.channel()

channel.exchange_declare(exchange=‘topic_logs‘,
                         type=‘topic‘)

result = channel.queue_declare(exclusive=True)
queue_name = result.method.queue

bind_key = ‘ha‘

channel.queue_bind(exchange
 
=‘topic_logs‘,
                   queue=queue_name,
                   routing_key=bind_key)

print(‘Wait for logs‘)

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

channel.basic_consume(callback,
                      queue=queue_name,
                      no_ack=True)

channel.start_consuming()

python---RabbitMQ（4）exchange中模糊匹配topic