Spring整合Weblogic jms实例详解

2023-08-10 03:58:04 75

本文主要介绍weblogicjms的配置，包括JMS服务器和JMS模块（连接工厂、队列、远程SAF上下文、SAF导入目的地、SAF错误处理）的配置；并在Spring环境下进行消息的监听及发送；为了更多的使用webloigcjms的功能，发送的队列使用saf配置的远程weblogicjms队列（两边的weblogic版本须一致），当然本地也是可以的。本文中demo所使用的软件环境为：weblogic10.3.6.0、spring5.1.2.RELEASE

注：saf配置的远程队列只能发送消息，不能监听消息。

1、weblogicjms配置

1.1、配置JMS服务器

注：需配置持久性存储，没有就创建一个

1.2、配置JMS模块

下面的功能都是在JMS模块中配置；连接工厂、队列、远程SAF上下文、SAF导入目的地、SAF错误处理

这里就不一一截图配置过程了，按页面提示配置就行；配置结果如下

连接工厂需设置jndi,程序里会用到

SAF远程上下文配置的远程地址及用户名密码信息

SAF导入目的地配置的远程的队列消息及对应到本地的jndi

SAF错误处理程序配置错误处理策略属性,选配

队列需设置jndi,程序里会用到

SAF导入目的地配置的队列消息如下：

点击队列名称：

本地JNDI名称程序里会用到，向该jndi发送消息实际会发送到远程的队列里。

2、spring配置

增加applicationContext-jms.xml文件：







weblogic.jndi.WLInitialContextFactory
t3://10.39.196.10:7001
weblogic
weblogic1

jndiTemplate配置weblogic的连接信息

jmsConnectionFactory配置连接工厂

testQueueSend向该队列发送消息，对应上面saf远程目的地里队列的本地jndi名称，

testQueueReceive对该队列进行监听，接受消息

jmsTemplate配置jms的模板

sender发送消息的类，把该类配置为定时任务，定时发送消息；

receiver监听的类

listenerContainer监听容器

3、类信息

发送者：

packagecom.inspur.demo.jms;

importjavax.jms.Destination;
importjavax.jms.JMSException;
importjavax.jms.Message;
importjavax.jms.Session;

importorg.slf4j.Logger;
importorg.slf4j.LoggerFactory;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.beans.factory.annotation.Qualifier;
importorg.springframework.jms.core.JmsTemplate;
importorg.springframework.jms.core.MessageCreator;

publicclassSender{
protectedstaticLoggerlogger=LoggerFactory.getLogger(Sender.class);

//发送消息的队列
@Autowired
@Qualifier("testQueueSend")
privateDestinationdestination;

@Autowired
privateJmsTemplatejmsTemplate;

publicvoidhello(){
Stringmessage=System.currentTimeMillis()+"-hello";
logger.info("MessageSend:{}",message);
jmsTemplate.send(destination,newMessageCreator(){
@Override
publicMessagecreateMessage(Sessionsession)throwsJMSException{
returnsession.createTextMessage(message);
}
});
}
}

使用JmsTemplate来发送消息。

接受者：

packagecom.inspur.demo.jms;
importjavax.jms.JMSException;
importjavax.jms.Message;
importjavax.jms.MessageListener;
importjavax.jms.TextMessage;

importorg.slf4j.Logger;
importorg.slf4j.LoggerFactory;

publicclassReceiverimplementsMessageListener{
protectedstaticLoggerlogger=LoggerFactory.getLogger(Receiver.class);

@Override
publicvoidonMessage(Messagemessage){
try{
Stringtext="";
if(messageinstanceofTextMessage){
text=((TextMessage)message).getText();
}
logger.info("Messagereceived:{}",text);
}catch(JMSExceptione){
e.printStackTrace();
}
}
}

4、测试

1.发送消息

启动程序后，每隔5秒中会往testQueueSend队列（远程队列）中发送一条消息，可到weblogic控制台查看消息.

2.接受消息

在weblogic控制台手工往testQueueReceive队列插入一条消息，程序日志会打印该消息内容。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。

声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。

Spring整合Weblogic jms实例详解

热门推荐

随机推荐