amqp 写入json格式消息

AMQP（Advanced Message Queuing Protocol）是一种高级消息队列协议，它提供了可靠的消息传输机制和灵活的消息路由方式。在AMQP中，消息由生产者发送到队列中，并由消费者从队列中取出进行处理。

AMQP支持多种数据格式，其中包括json格式。json格式是一种轻量级的数据交换协议，非常适合在AMQP中传输数据。

import pika
import json

# 连接rabbitmq服务器
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 定义队列和消息
queue_name = 'test_queue'
message = {'name': '张三','age': 28}

# 将消息转换为json格式并发送到队列中
channel.basic_publish(exchange='',routing_key=queue_name,body=json.dumps(message))

connection.close()

代码中，我们使用Python编写了一个简单的生产者程序。首先，通过pika模块连接到RabbitMQ服务器，然后定义一个队列和一个包含数据的消息。接着，将消息使用json.dumps方法转换为json格式，并使用basic_publish方法将其发送到队列中。

通过这种方式，我们可以在AMQP中快速而简单地传输json格式的消息，实现了高效的消息传输和处理。