activemq 传输json

ActiveMQ 是一个流行的消息代理，支持多种通信协议，包括传输 JSON 格式的数据。若要使用 ActiveMQ 传输 JSON 数据，可以利用它提供的 REST 接口或 JMS（Java Message Service）通信协议。以下是使用 JMS 传输 JSON 数据的示例代码：

// 创建连接
ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
Connection connection = factory.createConnection();
connection.start();

// 创建会话
Session session = connection.createSession(false,Session.AUTO_ACKNowLEDGE);

// 创建目的地
Destination destination = session.createQueue("json_queue");

// 创建消息生产者
MessageProducer producer = session.createProducer(destination);

// 创建 JSON 消息
JSONObject json = new JSONObject();
json.put("name","jim");
json.put("age",25);
TextMessage message = session.createTextMessage(json.toString());

// 发送消息
producer.send(message);

// 关闭连接
producer.close();
session.close();
connection.close();

上述代码创建了一个 JSON 对象，然后将其转换为文本消息，最后使用 JMS 发送到指定的队列中。在接收端，可以使用类似的方式将文本消息转换为 JSON 对象，并对其进行处理。