由于最近的项目中使用了JBOSSMQ,之前没有接触过这方面的知识,所以记录下相关的笔记。
JBOSSMQ 是Jboss message 的简称,目前最新的jbossMQ已经修改为jboss message了最新的版本以为2.0。
在JMS中有两种域:topics 和queues 。一个消息发送到一个topics ,可以有多个客户端。用topic发布允许一对多,或多对多通讯通道。消息的产生者被叫做publisher, 消息接受者叫做subscriber。
queue 是另外一种方式,仅仅允许一个消息传送给一个客户。一个发送者将消息放在消息队列中,接受者从队列中抽取并得到消息,消息就会在队列中消失。第一个接受者抽取并得到消息后,其他人就不能在得到它。
为了能发送和接收消息,必须得到一个JMS连接。该连接是使用JMS Provider得到连接的,在得到连接之后,建立一个会话(Session)。然后再建立publisher/sender 来发送消息或subscriber/receiver来接收消息。
JBOSSMQ框架基本流程如下:
消息发送端
1.初始化JNDI上下文对象,首先设置JNDI相关的属性
Properties props = new Properties();
props.setProperty(Context.INITIAL_CONTEXT_FACTORY,
"org.jnp.interfaces.NamingContextFactory");
props.setProperty(Context.PROVIDER_URL, jmsUrl);//jmsurl是访问地址
props.setProperty(Context.URL_PKG_PREFIXES, "org.jboss.naming");
Context context = new InitialContext(props);
2. // 根据上下文来查找一个连接工厂TopicConnectFactory/ QueueConnectionFactory
// (有两种连接工厂,根据是topic/queue来使用相应的类型);
QueueConnectionFactory queueFactory = (QueueConnectionFactory) context
.lookup("/ConnectionFactory");
3.//从连接工厂得到一个连接(Connect 有两种[TopicConnection/ QueueConnection]);
QueueConnection queueConnection = queueFactory.createQueueConnection();
配置的连接的工厂都可以在${JBOSS_HOME}/server/default/conf目下的jboss-service.xml文件中。
4.//通过连接来建立一个会话(Session)
QueueSession queueSession = queueconnection.createQueueSession (false,QueueSession.AUTO_ACKNOWLEDGE);
5.查找目的地(Topic/ Queue)
Queue queue = (Queue) context.lookup("/queue/testqueue");
6.根据会话以及目的地来建立消息制造者(TopicPublisher/QueueSender)和消费者(TopicSubscriber/ QueueReceiver)
QueueSender queueSender = queueSession.createSender(queue);
7.创建消息
TextMessage textMessage = queueSession.createTextMessage();
8. 发送消息
queueSender.send(queue,message);
消息接收端
消息接收端和消息的发送端前5步的步骤都一样,不同的是6-8的步骤不一样,具体如下:
// 根绝会话以及目的地建立消息接收者QueueReceiver
QueueReceiver queueReceiver = queueSession.createReceiver(queue);
// 设置队列消息监听
queueReceiver.setMessageListener(this);
//获取消息
TextMessage textMessage = (TextMessage) message;
String str = textMessage.getText();
其次我们在开发jms是要注意及时的释放资源,防止资源泄漏问题。
在开发jms客户端时需要实现ExceptionListener和MessageListener接口,其中MessageListener中包含了onMessage方法用于处理消息内容,而ExceptionListener中的onException用于当jms出现异常时,进行关闭queueConnection连接。
eg:public void onException(JMSException arg0) {
stopRegisterConnect();
}
public synchronized void stopRegisterConnect() {
try {
if (null != queueConnection) {
queueConnection.close();
}
if (null != queueSession) {
queueSession.close();
}
} catch (Exception e) {
e.printStackTrace();
}
queueConnection = null;
}
接下来我们需要进行jboss配置,这里采用的jboss4.2.3的版本进行配置。
a.添加目的
进入${JBOSS_HOME}/server/default/deploy/jms 中的jbossmq-destinations-service.xml文件
<mbean code="org.jboss.mq.server.jmx.Queue"
name="jboss.mq.destination:service=Queue,name=testqueue">
<depends optional-attribute-name="DestinationManager">jboss.mq:service=DestinationManager</depends>
</mbean>
其中新增的目的的名称(name)与步骤5中的名称保持一致。 这种方式是配置的目的是长期存在的,不会随jboss的关闭和消失。
b.jms端口配置
${JBOSS_HOME}/server/default/conf 下的jboss-service.xml文件找到配置连接工厂的上下文,设置相关的端口即可。
<mbean code="org.jboss.naming.NamingService"
name="jboss:service=Naming"
xmbean-dd="resource:xmdesc/NamingService-xmbean.xml">
<attribute name="Port">17299</attribute>
</mbean>
分享到:
相关推荐
探究comsol热电效应模型:多物理场耦合与计算模拟分析,comsol热电效应模型。 ,comsol; 热电效应; 模型; 仿真模拟; 物理效应,Comsol热电效应模型解析
1、文件内容:pcre2-10.23-2.el7.rpm以及相关依赖 2、文件形式:tar.gz压缩包 3、安装指令: #Step1、解压 tar -zxvf /mnt/data/output/pcre2-10.23-2.el7.tar.gz #Step2、进入解压后的目录,执行安装 sudo rpm -ivh *.rpm 4、安装指导:私信博主,全程指导安装
免费JAVA毕业设计 2024成品源码+论文+录屏+启动教程 启动教程:https://www.bilibili.com/video/BV1SzbFe7EGZ 项目讲解视频:https://www.bilibili.com/video/BV1Tb421n72S 二次开发教程:https://www.bilibili.com/video/BV18i421i7Dx
《三菱PLC与组态王联动的综合排水系统自动化控制解析与实践——包含5泵排水五泵矿井电气自动控制梯形图原理图及IO分配与组态画面详解》,No.914 三菱PLC和组态王组态5泵排水五泵矿井综合排水电气自动控 带解释的梯形图接线图原理图图纸,io分配,组态画面 ,核心关键词:三菱PLC; 组态王组态; 5泵排水; 矿井综合排水; 电气自动控制; 梯形图接线图; 原理图图纸; IO分配; 组态画面。,"三菱PLC与组态王联控五泵矿井排水系统电气自动化"
免费JAVA毕业设计 2024成品源码+论文+录屏+启动教程 启动教程:https://www.bilibili.com/video/BV1SzbFe7EGZ 项目讲解视频:https://www.bilibili.com/video/BV1Tb421n72S 二次开发教程:https://www.bilibili.com/video/BV18i421i7Dx
免费JAVA毕业设计 2024成品源码+论文+录屏+启动教程 启动教程:https://www.bilibili.com/video/BV1SzbFe7EGZ 项目讲解视频:https://www.bilibili.com/video/BV1Tb421n72S 二次开发教程:https://www.bilibili.com/video/BV18i421i7Dx
基于Comsol模拟的近场金属探针激发表面等离子体激元(SPP)的研究,Comsol近场金属探针激发SPP。 ,Comsol; 近场金属探针; SPP; 激发。,"Comsol模拟激发金属探针的SPP现象"
"基于COMSOL损伤模型的井筒周围应力分布模拟研究",COMSOL损伤模型,模拟井筒周围应力分布。 ,COMSOL损伤模型; 井筒应力分布模拟; 周围应力分布; 井筒损伤模型。,COMSOL模拟井筒应力分布模型
1、文件内容:pcp-webapp-graphite-4.3.2-13.el7_9.rpm以及相关依赖 2、文件形式:tar.gz压缩包 3、安装指令: #Step1、解压 tar -zxvf /mnt/data/output/pcp-webapp-graphite-4.3.2-13.el7_9.tar.gz #Step2、进入解压后的目录,执行安装 sudo rpm -ivh *.rpm 4、安装指导:私信博主,全程指导安装
1、文件内容:perl-Mozilla-CA-20130114-5.el7.rpm以及相关依赖 2、文件形式:tar.gz压缩包 3、安装指令: #Step1、解压 tar -zxvf /mnt/data/output/perl-Mozilla-CA-20130114-5.el7.tar.gz #Step2、进入解压后的目录,执行安装 sudo rpm -ivh *.rpm 4、安装指导:私信博主,全程指导安装
JEECGJ2EE“”(Online Coding() - > - > MERGE) Java90%
DeepSeek团队-V2大模型论文: A Strong, Economical, and Efficient Mixture-of-Experts Language Model 发表:2024年6月
生成式对抗网络在金融数据中的应用
激光清洗补技术:深入解析固体传热、变形几何与固体力学模块的教学视频,激光清洗补,用到的模块:固体传热,变形几何,固体力学。 教学视频 ,激光清洗补; 固体传热; 变形几何; 固体力学; 教学视频,激光清洗补教学视频:固体传热与固体力学原理的变形几何应用
Ollama ollama ollama ollama ollama ollama
参考链接:https://www.bilibili.com/video/BV1iFFVenEMi/?vd_source=bf2d43514ea61b1121399ab65421e37c 框架:SSM 数据库:MySQL 有数据库文件,项目完整,拿来即可用 1.登录模块:仓库管理员登录和退出系统。 2.库存管理模块:管理员在该模块中完成了对库存信息的查询功能。 3.仓库管理模块:管理员在该模块中完成了对仓库货物出入库信息的添加、查询、 删除、修改等功能。 4.人员管理模块:管理员可以在该模块中完成了对仓库管理员信息的添加、查询、 删除、修改等功能。 5.信息管理模块:管理员可以在该模块中定义了对供货商,客户,货物以及仓库信 息的添加、查询、删除、修改等功能。 6.系统维护模块:管理员可以在该模块修改登录密码与登录日志查询。
价值99元CoreNext主题1.5.2免授权 | WordPress主题模板 主题结合了知名框架Vue和element库,并且使用前端工程化webpack打包,将多个文件打包成一个文件,大幅度提升加载性能。使用了前端工程化的情况,并没有做到完全前后端分离,而是混合开发,保证主题流畅的同时,SEO功能同样不丢失。 目录结构,有别于传统主题,大幅度精简文件,统一入口。外保外观和功能的情况下,主题压缩后体积仅1M,有着无与伦比的优势,就算是虚拟机,也能非常流畅的运行。大家可以对比一下同类型的主题。 更新日志 v1.5.2 新增 本地头像系统,开启后彻底使用本地头像 优化 SEO功能 调整 作者边栏动态排序内容 调整 文章引用内容界面 v1.5.1 新增 头像系统 支持用户自行上传图片 [主题设置->用户中心->允许用户上传头像] 修复 自动深色模式 logo用默认 优化 小工具 首篇大图文章高度 调整 获取文章缩略图逻辑
1.版本:matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点:参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象:计算机,电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。
1、文件内容:perl-HTML-Tagset-3.20-15.el7.rpm以及相关依赖 2、文件形式:tar.gz压缩包 3、安装指令: #Step1、解压 tar -zxvf /mnt/data/output/perl-HTML-Tagset-3.20-15.el7.tar.gz #Step2、进入解压后的目录,执行安装 sudo rpm -ivh *.rpm 4、安装指导:私信博主,全程指导安装