1.先下载
官网下载地址：http://activemq.apache.org/activemq-5133-release.html
2.下载的页面
3.下载解压 bin
4.根据自己的电脑的系统们选择 我的电脑是64位 打开启动下面两个文件
出现
5.在网面输入 http://localhost:8161/admin/
用户名 ：admin 密码：admin
6.管理页面
JMS基本步骤
7.编程写生产者
package cn.day1; import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; public class QueueSend { // activemq服务器的url地址，默认通信端口为61616 private static final String URL = "tcp://localhost:61616"; // 队列的名称 private static final String QUEUE_NAME = "queue-test"; public static void main(String[] args) { // 1.创建连接工厂对象（ConnectionFactory） ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(URL); // 2.创建连接对象（Connection） Connection connection = null; try { connection = connectionFactory.createConnection(); // 3.启动连接 connection.start(); // 4.创建session会话，第一参数表示启用事务处理，第二个参数表示启动哪种应答模式，这里启用的是自动应答 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); // 5.创建目的地（destination） Destination destination = session.createQueue(QUEUE_NAME); // 6.创建生产者 MessageProducer producer = session.createProducer(destination); // 循环发送消息 for (int i = 0; i < 10; i++) { // 7.创建消息，这里创建的是简单的文本消息体 TextMessage textMessage = session.createTextMessage("test" + i); // 8.使用消息生产者往目的地发送消息 producer.send(destination, textMessage); System.out.println("消息发送成功：" + textMessage.getText()); } // 9.关闭连接 connection.close(); } catch (JMSException e) { e.printStackTrace(); } } }运行结果：
消息发送成功：test0 消息发送成功：test1 消息发送成功：test2 消息发送成功：test3 消息发送成功：test4 消息发送成功：test5 消息发送成功：test6 消息发送成功：test7 消息发送成功：test8 消息发送成功：test9查看管理页面
8编写消费者
package cn.day1; import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; public class QueueReceive { // activemq服务器的url地址，默认通信端口为61616 private static final String URL = "tcp://localhost:61616"; // 队列的名称 private static final String QUEUE_NAME = "queue-test"; public static void main(String[] args){ // 1.创建连接工厂对象（ConnectionFactory） ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(URL); // 2.创建连接对象（Connection） Connection connection = null; try{ connection = connectionFactory.createConnection(); // 3.启动连接 connection.start(); // 4.创建session会话，第一参数表示启用事务处理，第二个参数表示启动哪种应答模式，这里启用的是自动应答 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); // 5.创建目的地（destination） Destination destination = session.createQueue(QUEUE_NAME); // 6.创建消费者 MessageConsumer messageConsumer = session.createConsumer(destination); // 7.创建一个监听器 messageConsumer.setMessageListener((Message message) ->{ TextMessage textMessage = (TextMessage) message; try { System.out.println("接收消息: " + textMessage.getText()); } catch (JMSException e) { e.printStackTrace(); } }); }catch (Exception e){ e.getStackTrace(); } } }
运行结果：
接收消息: test0 接收消息: test1 接收消息: test2 接收消息: test3 接收消息: test4 接收消息: test5 接收消息: test6 接收消息: test7 接收消息: test8 接收消息: test9
打开页面
