黑马程序员技术交流社区
标题: 【郑州校区】Java之品优购课程讲义_day13（3） [打印本页]
作者: 谷粒姐姐 时间: 2018-10-10 10:57
标题: 【郑州校区】Java之品优购课程讲义_day13（3）
1. JMS 入门小 Demo
1.1 点对点模式点对点的模式主要建立在一个队列上面，当连接一个列队的时候，发送端不需要知道接收端是否正在接收，可以直接向 ActiveMQ 发送消息，发送的消息，将会先进入队列中，如果有接收端在监听，则会发向接收端，如果没有接收端接收，则会保存在 activemq 服务器， 直到接收端接收消息，点对点的消息模式可以有多个发送端，多个接收端，但是一条消息， 只会被一个接收端给接收到，哪个接收端先连上 ActiveMQ，则会先接收到，而后来的接收端则接收不到那条消息。
1.1.1 消息生产者
（1）创建工程 jmsDemo ，引入依赖
[AppleScript] 纯文本查看 复制代码
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-client</artifactId>
<version>5.13.4</version>
</dependency>
（2）创建类 QueueProducer main 方法代码如下：
[AppleScript] 纯文本查看 复制代码
//1.创建连接工厂
ConnectionFactory connectionFactory=new ActiveMQConnectionFactory("tcp://192.168.25.135:61616");
//2.获取连接
Connection connection = connectionFactory.createConnection();
//3.启动连接connection.start();
//4.获取 session (参数 1：是否启动事务,参数 2：消息确认模式)
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
//5.创建队列对象
Queue queue = session.createQueue("test-queue");
//6.创建消息生产者
MessageProducer producer = session.createProducer(queue);
//7.创建消息
TextMessage textMessage = session.createTextMessage("欢迎来到神奇的品优购世界");
//8.发送消息producer.send(textMessage);
//9.关闭资源
producer.close(); session.close();
connection.close();
上述代码中第 4 步创建 session 的两个参数：
第 1 个参数 是否使用事务第 2 个参数 消息的确认模式
· AUTO_ACKNOWLEDGE = 1 自动确认
· CLIENT_ACKNOWLEDGE = 2 客户端手动确认
· DUPS_OK_ACKNOWLEDGE = 3 自动批量确认
· SESSION_TRANSACTED = 0 事务提交并确认运行后通过 ActiveMQ 管理界面查询
1.1.1 消息消费者
创建类 QueueConsumer ，main 方法代码如下：
[AppleScript] 纯文本查看 复制代码
//1.创建连接工厂
ConnectionFactory connectionFactory=new ActiveMQConnectionFactory("tcp://192.168.25.135:61616");
//2.获取连接
Connection connection = connectionFactory.createConnection();
//3.启动连接connection.start();
//4.获取 session (参数 1：是否启动事务,参数 2：消息确认模式)
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
//5.创建队列对象
Queue queue = session.createQueue("test-queue");
//6.创建消息消费
MessageConsumer consumer = session.createConsumer(queue);
//7.监听消息
consumer.setMessageListener(new MessageListener() {
public void onMessage(Message message) { TextMessage textMessage=(TextMessage)message; try {
System.out.println("接收到消息："+textMessage.getText());
} catch (JMSException e) {
// TODO Auto-generated catch block e.printStackTrace();
}
}
});
//8.等待键盘输入System.in.read();
//9.关闭资源
consumer.close(); session.close();
connection.close();
执行后看到控制台输出
1.1.1 运行测试
同时开启 2 个以上的消费者，再次运行生产者，观察每个消费者控制台的输出，会发现只有一个消费者会接收到消息。
2.2 发布/订阅模式
2.2.1 消息生产者
创建类 TopicProducer ，main 方法代码如下：
[AppleScript] 纯文本查看 复制代码
//1.创建连接工厂
ConnectionFactory connectionFactory=new ActiveMQConnectionFactory("tcp://192.168.25.135:61616");
//2.获取连接
Connection connection = connectionFactory.createConnection();
//3.启动连接connection.start();
//4.获取 session (参数 1：是否启动事务,参数 2：消息确认模式)
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
//5.创建主题对象
Topic topic = session.createTopic("test-topic");
//6.创建消息生产者
MessageProducer producer = session.createProducer(topic);
//7.创建消息
TextMessage textMessage = session.createTextMessage("欢迎来到神奇的品优购世界");
//8.发送消息producer.send(textMessage);
[AppleScript] 纯文本查看 复制代码
//9.关闭资源
producer.close();
session.close(); connection.close();
运行效果如下：
2.2.1 消息消费者
创建类 TopicConsumer ,main 方法代码如下：
[AppleScript] 纯文本查看 复制代码
//1.创建连接工厂
ConnectionFactory connectionFactory=new ActiveMQConnectionFactory("tcp://192.168.25.135:61616");
//2.获取连接
Connection connection = connectionFactory.createConnection();
//3.启动连接connection.start();
//4.获取 session (参数 1：是否启动事务,参数 2：消息确认模式)
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
//5.创建主题对象
//Queue queue = session.createQueue("test-queue"); Topic topic = session.createTopic("test-topic");
//6.创建消息消费
MessageConsumer consumer = session.createConsumer(topic);
//7.监听消息
consumer.setMessageListener(new MessageListener() {
public void onMessage(Message message) { TextMessage textMessage=(TextMessage)message; try {
System.out.println("接收到消息："+textMessage.getText());
} catch (JMSException e) {
// TODO Auto-generated catch block e.printStackTrace();
}
}
});
//8.等待键盘输入System.in.read();
//9.关闭资源
consumer.close(); session.close(); connection.close();
2.2.1 运行测试
同时开启 2 个以上的消费者，再次运行生产者，观察每个消费者控制台的输出，会发现每个消费者会接收到消息。
| 欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) |
黑马程序员IT技术论坛 X3.2 |
