activemq 传json格式

ActiveMQ是一种流行的消息队列软件，它可以跨系统和语言进行消息传递。尤其在分布式系统中，ActiveMQ扮演着重要的角色。而传递数据格式的选择则是一方面。

JSON是一种轻量级的数据交换格式，易于阅读和编写，也易于机器解析和生成。JSON格式的数据常用于Web应用程序中，特别适合用于数据交换。而对于ActiveMQ来说，JSON格式的消息可以通过JMS提供的TextMessage类型来进行传递。

    // 创建JSON对象
    JSONObject json = new JSONObject();
    json.put("name","John");
    json.put("age",30);
    json.put("city","New York");

    // 发送JSON消息
    TextMessage message = session.createTextMessage();
    message.setText(json.toString());
    producer.send(message);

在上面的代码中，首先我们用Java语言创建了一个JSONObject对象，并在其中放置了一些数据。这些数据包括name、age和city。接着，我们通过调用JSONObject对象的toString方法将其转换为一个字符串，并将该字符串设置为一个TextMessage对象的消息内容。最后，我们通过MessageProducer实例将消息发送到ActiveMQ队列中。

在接收JSON消息时，我们只需要将TextMessage类型的消息的内容取出并解析即可：

    // 接收JSON消息
    Message message = consumer.receive();
    if (message instanceof TextMessage) {
        TextMessage textMessage = (TextMessage) message;
        String jsonStr = textMessage.getText();
        JSONObject json = new JSONObject(jsonStr);
        String name = json.getString("name");
        int age = json.getInt("age");
        String city = json.getString("city");

        // 处理收到的数据
        System.out.println(name + "," + age + "," + city);
    }

如上所示，在接收JSON消息时，我们首先通过判断消息类型，判断是否为TextMessage类型的消息。如果是，则将消息内容转换为一个字符串，并将其解析为一个JSONObject对象。然后我们可以通过getString和getInt方法取出其中的数据，并进行处理。

总的来说，将JSON格式的消息发送到ActiveMQ队列中，可以让我们的应用程序更加灵活、可扩展，也更易于维护。