由于最近的项目中使用了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>
分享到:
相关推荐
免费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
1、文件内容:perl-Class-Load-0.20-3.el7.rpm以及相关依赖 2、文件形式:tar.gz压缩包 3、安装指令: #Step1、解压 tar -zxvf /mnt/data/output/perl-Class-Load-0.20-3.el7.tar.gz #Step2、进入解压后的目录,执行安装 sudo rpm -ivh *.rpm 4、安装指导:私信博主,全程指导安装
FCN实现斑马线分割(含数据集)
,西门子200smart控制3轴伺服程序,plc程序结构条理清晰,层次分明,注释齐全。 西门子触摸屏程序画面功能齐全,画面精美。 有io图。 电气原理图。 参考本案例程序。 可快速掌握西门子200smart控制伺服编程技巧,扩展自己的编程逻辑思维。 节省大量不必要花费的时间,可快速上手。
资源说明: 1:csdn平台资源详情页的文档预览若发现'异常',属平台多文档切片混合解析和叠加展示风格,请放心使用。 2:29页图文详解文档(从零开始项目全套环境工具安装搭建调试运行部署,保姆级图文详解),旨在为更多的人甚至零基础的人也能运行、使用和学习。 3:配套毕业论文,万字长文,word文档,支持二次编辑。 4:范例参考答辩ppt,pptx格式,支持二次编辑。 5:工具环境、ppt参考模板、相关电子教程、视频教学资源分享。 6:资源项目源码均已通过严格测试验证,保证能够正常运行,本项目仅用作交流学习参考,请切勿用于商业用途。 7:项目问题、技术讨论,可以给博主私信或留言,博主看到后会第一时间与您进行沟通。 内容概要: 本系统基于B/S网络结构,在IDEA中开发。服务端用Java并借Spring Boot框架搭建后台。前台采用支持HTML5的VUE框架。用MySQL存储数据,可靠性强。 能学到什么: 使用Spring Boot搭建后台。VUE框架构建前端交互界面、前后端数据交互、MySQL管理数据、从零开始环境搭建、调试、运行、打包、部署流程。
"基于ADMM算法的多微网协同优化调度策略:实现分布式电能共享与信息保护",02-基于ADMM算法的多微网协同优化调度 摘要:为了实现微网间的电能以及能量共享,采用ADMM方法,实现了微网之间的电能与协同优化,方法为分布式算法,有效的保护了各个微网的信息,避免了集中优化的大量信息索取。 ,基于ADMM算法; 多微网; 协同优化调度; 分布式算法; 能量共享; 信息保护,基于ADMM算法的微网协同优化调度方案
b站弹幕格式转换 xml转ass
.NET SDK Senparc.Weixin for C# .NET Framework .NET Core.NET 8.0/JSSDK WeChat SDK for C#. github官网 github官网 github官网 github官网 github官网
ollama基础知识简介.md
免费JAVA毕业设计 2024成品源码+论文+录屏+启动教程 启动教程:https://www.bilibili.com/video/BV1SzbFe7EGZ 项目讲解视频:https://www.bilibili.com/video/BV1Tb421n72S 二次开发教程:https://www.bilibili.com/video/BV18i421i7Dx
,fx3u和西门子v20 台达vfd-m 三菱E700 rtu所需硬件:FX3U PLC,FX3U-485BD通信板,变频器。 功能:使用fx3u-485bd板,rtu通信控制西门子v20 台达VFD-M 三菱E700三种变频器正反转,停止,频率设定,加减速,以及对频率,电压,电流的读取,有运行指示,效果可以看视频,反应及时,运行可靠,三种变频器程序是单个的,非三台一起控制。 的内容包括程序,接线,参数说明
软件渲染器tinyrenderer
电脑调音软件下载是专为汽车音响爱好者和专业人士设计的一款强大工具, 这款软件的主要功能在于帮助用户对车载音频系统进行精确的数字信号处理,以提升音乐播放效果,提供更丰富的听觉体验。
1、文件内容:perl-Date-Calc-6.3-14.el7.rpm以及相关依赖 2、文件形式:tar.gz压缩包 3、安装指令: #Step1、解压 tar -zxvf /mnt/data/output/perl-Date-Calc-6.3-14.el7.tar.gz #Step2、进入解压后的目录,执行安装 sudo rpm -ivh *.rpm 4、安装指导:私信博主,全程指导安装
给山东大学软件学院的学弟学妹们使用
生成式对抗网络在金融数据中的应用
1.版本:matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点:参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象:计算机,电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。
资源说明: 1:csdn平台资源详情页的文档预览若发现'异常',属平台多文档切片混合解析和叠加展示风格,请放心使用。 2:29页图文详解文档(从零开始项目全套环境工具安装搭建调试运行部署,保姆级图文详解),旨在为更多的人甚至零基础的人也能运行、使用和学习。 3:配套毕业论文,万字长文,word文档,支持二次编辑。 4:配套答辩ppt,pptx格式,支持二次编辑。 5:工具环境、ppt参考模板、相关电子教程、视频教学资源分享。 6:资源项目源码均已通过严格测试验证,保证能够正常运行,本项目仅用作交流学习参考,请切勿用于商业用途。 7:项目问题、技术讨论,可以给博主私信或留言,博主看到后会第一时间与您进行沟通。 内容概要: 本系统基于B/S网络结构,在IDEA中开发。服务端用Java并借Spring Boot框架搭建后台。前台采用支持HTML5的VUE框架。用MySQL存储数据,可靠性强。 能学到什么: 使用Spring Boot搭建后台。VUE框架构建前端交互界面、前后端数据交互、MySQL管理数据、从零开始环境搭建、调试、运行、打包、部署流程。
内容概要:文章详细介绍了计算机二级和软考两类计算机认证考试的习题资源获取途径及相关备考建议。对于计算机二级考试,提供了官方教材与配套习题、在线题库、专业论坛、培训机构等多种渠道的习题来源介绍。而对于软考,则提及了官方指南与教程、历年真题及其解析、在线学习资源和各类辅导书籍等方面的习题资源,并阐述这些资源对于考生熟悉考试题型、检验学习成果的重要性。最后提出了如制定备考计划、多做练习、注意理解和模拟考试这四大备考要点。 适用人群:准备报考全国计算机等级考试二级或者软考的技术人员或学生群体。 使用场景及目标:旨在为备考人员提供全面有效的习题资源收集方式和支持性建议,助力他们高效备考并通过考试。 其他说明:文中特别强调理解知识点而非单纯记忆、利用各种线上线下的辅助工具和材料来加强对知识的掌握,还有就是实战演练的作用不可忽视。