写一个java消息队列发送

消息的示例程序。

好的，以下是一个简单的 Java 消息队列发送消息的示例程序：

import javax.jms.*;
import org.apache.activemq.ActiveMQConnectionFactory;

public class MessageQueueSender {
    private static final String BROKER_URL = "tcp://localhost:61616"; // ActiveMQ broker 地址
    private static final String QUEUE_NAME = "test_queue"; // 消息队列名称

    public static void main(String[] args) {
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(BROKER_URL);

        try {
            Connection connection = connectionFactory.createConnection();
            connection.start();

            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

            Queue queue = session.createQueue(QUEUE_NAME);

            MessageProducer producer = session.createProducer(queue);

            // 创建一条文本消息
            TextMessage message = session.createTextMessage("Hello, World!");

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

            System.out.println("Sent message: " + message.getText());

            connection.close();
        } catch (JMSException e) {
            System.err.println("JMSException: " + e.getMessage());
        }
    }
}

这个程序使用了 ActiveMQ 作为消息队列中间件，可以将消息发送到指定的队列中。

首先，定义了 ActiveMQ broker 的地址 `BROKER_URL` 和消息队列名称 `QUEUE_NAME`。然后创建一个 `ActiveMQConnectionFactory` 来创建 `Connection`。

接下来，创建一个 `Session` 对象，并在创建 `Queue` 和 `MessageProducer` 对象。在这个例子中，创建了一条文本消息并用 `producer.send()` 方法发送出去。

最后，关闭连接。

希望这个示例程序对您有所帮助！