activemq 发送json

ActiveMQ是Apache开发的一款消息中间件，可以实现可靠的消息传输和异步通讯。在实际应用中，我们常使用ActiveMQ来发送和接收消息，而JSON是一种轻量级的数据交换格式，也广泛应用于Web应用中。下面我们将介绍如何使用ActiveMQ来发送JSON格式的消息。

// 引入ActiveMQ的相关包
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;

// 连接ActiveMQ
String brokerURL = "tcp://localhost:61616";
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerURL);
Connection connection = connectionFactory.createConnection();
connection.start();

// 创建会话和队列
Session session = connection.createSession(false,Session.AUTO_ACKNowLEDGE);
Destination destination = session.createQueue("queueName");

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

// 构建JSON格式的消息
JSONObject json = new JSONObject();
json.put("name","John");
json.put("age",30);
String messageString = json.toString();

// 创建消息并发送
TextMessage message = session.createTextMessage(messageString);
producer.send(message);

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

使用ActiveMQ发送JSON格式的消息，实际上就是将JSON字符串作为消息发送到ActiveMQ的队列中。在接收端，可以通过解析JSON字符串来获取消息内容。

总之，ActiveMQ是一个强大的消息中间件，支持多种消息格式的传输，对于需要异步通讯的场景非常适用。同时，JSON也是一种非常实用的数据交换格式，在Web应用中也得到了广泛的应用。