应c++写一个关于rabbitmq的生产者和消费者完整的代码

以下是一个关于RabbitMQ的生产者和消费者完整代码：

# 导入库
import pika

# 创建连接
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 创建队列
channel.queue_declare(queue='hello')

# 定义消费者回调函数
def callback(ch, method, properties, body):
print(" [x] Received %r" % body)

# 告诉RabbitMQ使用callback来接收信息
channel.basic_consume(queue='hello',
auto_ack=True,
on_message_callback=callback)

# 开始接收信息，并进入阻塞状态，队列里有信息才会调用callback进行处理
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

# 创建生产者
channel.basic_publish(exchange='',
routing_key='hello',
body='Hello World!')

# 关闭连接
connection.close()