Java ActiveMQ队列模式案例
2023-09-14 09:03:40 时间
创建Eclipse项目并运行
创建java project:ActiveMQ-5.14,新建lib文件夹
打开apache-activemq-5.14.0-bin\apache-activemq-5.14.0\lib目录
拷贝如下6个jar包:
activemq-broker-5.14.0.jar
activemq-client-5.14.0.jar
activemq-all-5.14.0.jar
geronimo-j2ee-management_1.1_spec-1.0.1.jar
geronimo-jms_1.1_spec-1.1.1.jar
slf4j-api-1.7.13.jar
这6个jar文件到lib文件夹中,并Build Path->Add to Build Path
结构如图:
Sender.java
1 package test;
2
3 import javax.jms.Connection;
4 import javax.jms.ConnectionFactory;
5 import javax.jms.DeliveryMode;
6 import javax.jms.Destination;
7 import javax.jms.MessageProducer;
8 import javax.jms.Session;
9 import javax.jms.TextMessage;
10 import org.apache.activemq.ActiveMQConnection;
11 import org.apache.activemq.ActiveMQConnectionFactory;
12
13 public class Sender {
14 private static final int SEND_NUMBER = 5;
15
16 public static void main(String[] args) {
17
18 ConnectionFactory connectionFactory; // ConnectionFactory--连接工厂,JMS用它创建连接
19 // Provider 的连接
20 Connection connection = null; // Connection :JMS 客户端到JMS
21 Session session; // Session: 一个发送或接收消息的线程
22 Destination destination; // Destination :消息的目的地;消息发送给谁.
23 MessageProducer producer; // MessageProducer:消息发送者
24 // 构造ConnectionFactory实例对象,此处采用ActiveMq的实现jar
25 connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,
26 ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");
27 try { // 构造从工厂得到连接对象
28 connection = connectionFactory.createConnection();
29 // 启动
30 connection.start();
31 // 获取操作连接
32 session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
33 // 获取session注意参数值xingbo.xu-queue是一个服务器的queue,须在在ActiveMq的console配置
34 destination = session.createQueue("FirstQueue");
35 // 得到消息生成者【发送者】
36 producer = session.createProducer(destination);
37 // 设置不持久化,此处学习,实际根据项目决定
38 producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
39 // 构造消息,此处写死,项目就是参数,或者方法获取
40 sendMessage(session, producer);
41 session.commit();
42 } catch (Exception e) {
43 e.printStackTrace();
44 } finally {
45 try {
46 if (null != connection)
47 connection.close();
48 } catch (Throwable ignore) {
49 }
50 }
51 }
52
53 public static void sendMessage(Session session, MessageProducer producer) throws Exception {
54 for (int i = 1; i <= SEND_NUMBER; i++) {
55 TextMessage message = session.createTextMessage("ActiveMq 发送的消息" + i);
56 // 发送消息到目的地方
57
58 System.out.println("发送消息:" + "ActiveMq 发送的消息" + i);
59 producer.send(message);
60 }
61 }
62 }
Receiver.java
package test;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
public class Receiver {
public static void main(String[] args) {
// ConnectionFactory :连接工厂,JMS 用它创建连接
ConnectionFactory connectionFactory;
// Connection :JMS 客户端到JMS Provider 的连接
Connection connection = null;
// Session: 一个发送或接收消息的线程
Session session;
// Destination :消息的目的地;消息发送给谁.
Destination destination;
// 消费者,消息接收者
MessageConsumer consumer;
connectionFactory = new ActiveMQConnectionFactory(
ActiveMQConnection.DEFAULT_USER,
ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");
try {
// 构造从工厂得到连接对象
connection = connectionFactory.createConnection();
// 启动
connection.start();
// 获取操作连接
session = connection.createSession(Boolean.FALSE,
Session.AUTO_ACKNOWLEDGE);
// 获取session注意参数值xingbo.xu-queue是一个服务器的queue,须在在ActiveMq的console配置
destination = session.createQueue("FirstQueue");
consumer = session.createConsumer(destination);
while (true) {
// 设置接收者接收消息的时间,为了便于测试,这里谁定为100s
TextMessage message = (TextMessage) consumer.receive(500000);
if (null != message) {
System.out.println("收到消息" + message.getText());
} else {
break;
}
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (null != connection)
connection.close();
} catch (Throwable ignore) {
}
}
}
}
5.测试过程
先运行:Receiver.java
再运行:Sender.java
可以看到结果
Sender运行后:
发送消息:ActiveMq 发送的消息1
发送消息:ActiveMq 发送的消息2
发送消息:ActiveMq 发送的消息3
发送消息:ActiveMq 发送的消息4
发送消息:ActiveMq 发送的消息5
Receiver运行后:
收到消息ActiveMq 发送的消息1
收到消息ActiveMq 发送的消息2
收到消息ActiveMq 发送的消息3
收到消息ActiveMq 发送的消息4
收到消息ActiveMq 发送的消息5
要想看到不同的输出内容,通过点击如下图的按钮切换console
相关文章
- java.lang.NoSuchMethodException: tk.mybatis.mapper.provider.base.BaseSelectProvider.<init>()
- Java Collection笔记之ArrayList
- mybatis简单案例源码详细【注释全面】——实体层(Role.java)
- Servlet使用适配器模式进行增删改查案例(DeptDaoImpl.java)
- Mybatis+mysql动态分页查询数据案例——工具类(MybatisUtil.java)
- Mybatis+mysql动态分页查询数据案例——分页工具类(Page.java)
- Java实现 蓝桥杯 算法训练 Lift and Throw
- java实现第五届蓝桥杯六角幻方
- Java实现第八届蓝桥杯日期问题
- Java实现 蓝桥杯VIP 算法训练 排列问题
- Java 8十个lambda表达式案例
- 【JAVA】基于MVC架构Java技术荟萃案例演练
- java多线程 -- 创建线程的第三者方式 实现Callable接口
- Java案例-用户注册邮箱验证将邮箱激活码存入redis功能实现
- Java动态代理代码案例:使用jdk自带的Proxy只能对有接口的类进行动态代理
- Java动态代理代码案例:使用cglib实现对无接口的类进行动态代理
- Java方法案例--比较三个数中的最大值
- Atitit 纯java项目的提升进度大法---通用json dsl接口
- java 反射设置属性 案例
- java 导出excel(复杂案例)
- Eclipse编写Java时printf出现错误
- Java递归基础案例
- JAVA编程:i=i++的理解
- Java乐观锁的实现原理(案例)
- 1.java线程的源码解析和两种线程创建方法
- zookeeper报错: org.I0Itec.zkclient.exception.ZkMarshallingError: java.io.EOFException
- Java设计一个同学通信录程序,用户名用学号(整型数)表示,并记录每个人电话号码及QQ号,可以添加,删除查询。
- JAVA开发讲义(二)-Java程序设计之数据之谜一