用java 使用activeMQ

要使用Java使用ActiveMQ，需要进行以下步骤：

下载ActiveMQ并解压缩它。可以从官方网站上下载：http://activemq.apache.org/download.html。
在Java项目中添加ActiveMQ的依赖。可以使用Maven或手动添加JAR文件。
创建一个ActiveMQ连接工厂。这可以通过以下代码完成：

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");

这将创建一个连接到本地主机上的ActiveMQ实例。

创建一个连接并启动它：

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

创建一个会话：

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

创建一个目的地，例如一个队列：

Destination destination = session.createQueue("myQueue");

创建一个生产者并发送消息到队列：

MessageProducer producer = session.createProducer(destination); TextMessage message = session.createTextMessage("Hello, world!"); producer.send(message);

创建一个消费者并接收消息：

MessageConsumer consumer = session.createConsumer(destination); Message message = consumer.receive(); if (message instanceof TextMessage) { TextMessage textMessage = (TextMessage) message; System.out.println("Received message: " + textMessage.getText()); }

关闭连接：

connection.close();

以上是使用Java使用ActiveMQ的基本步骤。当然，还有很多其他的选项和功能，例如使用主题而不是队列，设置持久性，使用事务等