Spring JMS 整合Weblogic JMS(weblogicMQ)

2023-12-10 08:32

本文主要是介绍Spring JMS 整合Weblogic JMS(weblogicMQ),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

1. Weblogic JMS配置

1.1.  JMS Server配置
1)      启动weblogic11g 管理控制台;
2)      在左窗格中选择”Services”—“Messaging”—“JMS Servers”;
3)      点击右窗格的”New”按钮;
4)      输入JMS Server的名称JMSServer-0,点击”Next”;



5)      将Target选择指向AdminServer,点击”Finish”;



1.2. JMS Modules配置
1)      在左窗格中选择”Services”—“Messaging”—“JMS Modules”;
2)      点击右窗格的”new”按钮;
3)      输入System Module的名称SystemModule-0,点击”Next”;



4)      将Servers表框中”AdminServer”前面的复选框选中,点击”Next”;



5)      选中” Would you like to add resources to this JMS system module?”,点击”Finish”;



1.3. JMS Subdeployments配置
1)      在左窗格中选择”Services”—“Messaging”—“JMS Modules”;
2)      点击右窗格的”SystemModule-0”,然后点击”Subdeployments”选项卡中的”New”按钮;
3)      输入Subdeployment 的名称Subdeployment-0,点击”Next”;



4)      选中JMS Servers中”JMSServer-0”,点击”Finish”.



1.4. JMS Connection Factory配置
1)      在左窗格中选择”Services”—“Messaging”—“JMS Modules”;
2)      点击右窗格的” SystemModule-0””,然后点击”New”按钮;
3)      选择”Connection Factory”,点击”Next”;



4)      输入”Connection Factory”的名称ConnectionFactory-0和”JNDI”的名称weblogic.jms.ConnectionFactory0,点击”Next”;



5)      点击”Advanced Targeting”,将”Subdeployment”下拉选中Subdeployment-0;

6)      选中”JMS Servers”框中JMSServer-0,点击”Finish”;



1.5. JMS Queue配置
1)      在左窗格中选择”Services”—“Messaging”—“JMS Modules”;
2)      点击右窗格的” SystemModule-0””,然后点击”New”按钮;
3)      选择”Queue”,点击”Next”;



4)      输入” Queue”的名称Queue -0和”JNDI”的名称weblogic.jms.Queue0,点击”Next”;



5)      将”Subdeployment”下拉选中Subdeployment-0,点击”Finish”;




2.写Spring的配置文件,假设存在这个文件里:jms-weblogic.xml
Xml代码   收藏代码
  1. <beans xmlns="http://www.springframework.org/schema/beans"  
  2.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"   
  3.     xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">  
  4.   
  5.     <bean id="weblogicJms" class="org.springframework.jndi.JndiTemplate">  
  6.         <property name="environment">  
  7.             <props>  
  8.                 <prop key="java.naming.factory.initial">  
  9.                     weblogic.jndi.WLInitialContextFactory   
  10.                 </prop>  
  11.                 <prop key="java.naming.provider.url">  
  12.                     t3://localhost:7001  
  13.                 </prop>  
  14.                 <prop key="java.naming.factory.url.pkgs">  
  15.                     weblogic.jndi.factories  
  16.                 </prop>  
  17.                 <prop key="java.naming.security.principal">  
  18.                     weblogic  
  19.                 </prop>  
  20.                 <prop key="java.naming.security.credentials">  
  21.                     weblogic11  
  22.                 </prop>  
  23.             </props>  
  24.         </property>  
  25.     </bean>  
  26.       
  27.     <!-- Connection factory -->  
  28.     <bean id="jmsConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">  
  29.         <property name="jndiName" value="weblogic.jms.ConnectionFactory0" />  
  30.         <property name="jndiTemplate" ref="weblogicJms"/>  
  31.     </bean>  
  32.       
  33.     <!-- Queue -->  
  34.     <bean id="jmsQueue" class="org.springframework.jndi.JndiObjectFactoryBean">  
  35.         <property name="jndiName" value="weblogic.jms.Queue0" />  
  36.         <property name="jndiTemplate" ref="weblogicJms"/>  
  37.     </bean>  
  38.       
  39.     <!-- Receiver -->  
  40.     <bean id="jmsReceiver" class="com.xp.MessageQueueReceiver">  
  41.     </bean>  
  42.       
  43.     <!-- Message Listener -->  
  44.     <bean id="listenerContainer"  
  45.         class="org.springframework.jms.listener.DefaultMessageListenerContainer">  
  46.         <property name="connectionFactory" ref="jmsConnectionFactory"/>  
  47.         <property name="destination" ref="jmsQueue"/>  
  48.         <property name="messageListener" ref="jmsReceiver"/>  
  49.         <property name="autoStartup" value="true"/>  
  50.     </bean>  
  51.       
  52.     <!-- Spring JMS Template -->  
  53.     <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate" lazy-init="true">  
  54.         <property name="connectionFactory" ref="jmsConnectionFactory" />  
  55.         <property name="defaultDestination" ref="jmsQueue" />   
  56.    </bean>  
  57.       
  58.     <!-- Sender -->  
  59.     <bean id="jmsSender" class="com.xp.MessageQueueSender"  
  60.         lazy-init="true">  
  61.         <property name="jmsTemplate" ref="jmsTemplate"></property>  
  62.     </bean>  
  63.       
  64. </beans>  


其中java.naming.security.principal和java.naming.security.credentials是weblogic的用户名和密码
另外注释掉上一篇日志里用的jms-activemq.xml
可以发现,采用SpringJMS以后,从ActiveMQ切换到WeblogicJMS是多么的灵活,代码都不用改,就改一个配置文件

3.我们想通过Tomcat来访问WeblogicJMS,于是要导入以下Jar包,
wlclient.jar(可从C:\oracle\Middleware\wlserver_10.3\server\lib下找到并复制出来)

4.启动tomcat,发现出错了
java.security.AccessControlException: access denied (javax.management.MBeanTrustPermission register)

5.上网搜索找到解决问题的临时方法,修改%JAVA_HOME%\jre\lib\security下的java.policy
最后加一行
permission javax.management.MBeanTrustPermission "register";

6. 再次启动tomcat,没问题了。按照上一篇日志的测试方法,测试通过。

还可以在Weblogic管理台监控消息
1)      在左窗格中选择”Services”—“Messaging”—“JMS Modules”;
2)      点击右窗格的” SystemModule-0””,然后点击”Queue-0”;
3)      点击"Monitoring"选项卡
4)     勾选SystemModule-0!Queue-0,点击Show messages



5)      点击New,随便输入信息,按OK



可在控制台看到接受者能收到此消息




这篇关于Spring JMS 整合Weblogic JMS(weblogicMQ)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/476574

相关文章

springboot集成easypoi导出word换行处理过程

《springboot集成easypoi导出word换行处理过程》SpringBoot集成Easypoi导出Word时,换行符n失效显示为空格,解决方法包括生成段落或替换模板中n为回车,同时需确... 目录项目场景问题描述解决方案第一种:生成段落的方式第二种:替换模板的情况,换行符替换成回车总结项目场景s

SpringBoot集成redisson实现延时队列教程

《SpringBoot集成redisson实现延时队列教程》文章介绍了使用Redisson实现延迟队列的完整步骤,包括依赖导入、Redis配置、工具类封装、业务枚举定义、执行器实现、Bean创建、消费... 目录1、先给项目导入Redisson依赖2、配置redis3、创建 RedissonConfig 配

SpringBoot中@Value注入静态变量方式

《SpringBoot中@Value注入静态变量方式》SpringBoot中静态变量无法直接用@Value注入,需通过setter方法,@Value(${})从属性文件获取值,@Value(#{})用... 目录项目场景解决方案注解说明1、@Value("${}")使用示例2、@Value("#{}"php

SpringBoot分段处理List集合多线程批量插入数据方式

《SpringBoot分段处理List集合多线程批量插入数据方式》文章介绍如何处理大数据量List批量插入数据库的优化方案:通过拆分List并分配独立线程处理,结合Spring线程池与异步方法提升效率... 目录项目场景解决方案1.实体类2.Mapper3.spring容器注入线程池bejsan对象4.创建

线上Java OOM问题定位与解决方案超详细解析

《线上JavaOOM问题定位与解决方案超详细解析》OOM是JVM抛出的错误,表示内存分配失败,:本文主要介绍线上JavaOOM问题定位与解决方案的相关资料,文中通过代码介绍的非常详细,需要的朋... 目录一、OOM问题核心认知1.1 OOM定义与技术定位1.2 OOM常见类型及技术特征二、OOM问题定位工具

基于 Cursor 开发 Spring Boot 项目详细攻略

《基于Cursor开发SpringBoot项目详细攻略》Cursor是集成GPT4、Claude3.5等LLM的VSCode类AI编程工具,支持SpringBoot项目开发全流程,涵盖环境配... 目录cursor是什么?基于 Cursor 开发 Spring Boot 项目完整指南1. 环境准备2. 创建

Spring Security简介、使用与最佳实践

《SpringSecurity简介、使用与最佳实践》SpringSecurity是一个能够为基于Spring的企业应用系统提供声明式的安全访问控制解决方案的安全框架,本文给大家介绍SpringSec... 目录一、如何理解 Spring Security?—— 核心思想二、如何在 Java 项目中使用?——

SpringBoot+RustFS 实现文件切片极速上传的实例代码

《SpringBoot+RustFS实现文件切片极速上传的实例代码》本文介绍利用SpringBoot和RustFS构建高性能文件切片上传系统,实现大文件秒传、断点续传和分片上传等功能,具有一定的参考... 目录一、为什么选择 RustFS + SpringBoot?二、环境准备与部署2.1 安装 RustF

springboot中使用okhttp3的小结

《springboot中使用okhttp3的小结》OkHttp3是一个JavaHTTP客户端,可以处理各种请求类型,比如GET、POST、PUT等,并且支持高效的HTTP连接池、请求和响应缓存、以及异... 在 Spring Boot 项目中使用 OkHttp3 进行 HTTP 请求是一个高效且流行的方式。

java.sql.SQLTransientConnectionException连接超时异常原因及解决方案

《java.sql.SQLTransientConnectionException连接超时异常原因及解决方案》:本文主要介绍java.sql.SQLTransientConnectionExcep... 目录一、引言二、异常信息分析三、可能的原因3.1 连接池配置不合理3.2 数据库负载过高3.3 连接泄漏