Spring JMS 整合Weblogic JMS

2024-09-04 03:48
文章标签 java spring 整合 weblogic jms

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

1.1     JMS简介

       JMS的全称是Java Message Service,即Java消息服务。它主要用于在生产者和消费者之间进行消息传递,生产者负责产生消息,而消费者负责接收消息。把它应用到实际的业务需求中的话我们可以在特定的时候利用生产者生成一消息,并进行发送,对应的消费者在接收到对应的消息后去完成对应的业务逻辑。对于消息的传递有两种类型,一种是点对点的,即一个生产者和一个消费者一一对应;另一种是发布/订阅模式,即一个生产者产生消息并进行发送后,可以由多个消费者进行接收。

1.2     Spring整合JMS

       对JMS做了一个简要介绍之后,接下来就讲一下Spring整合JMS的具体过程。JMS只是一个标准,真正在使用它的时候我们需要有它的具体实现,这里我们就使用Weblogic的Weblogic JMS来作为它的实现。首先我们需要搭建一个Spring框架,并引用操作Weblogic JMS所需要的jar包。搭建Spring框架可以参考博客:https://blog.csdn.net/qq_36769100/article/details/70908148     ,Spirng框架依赖jar包下载地址:https://download.csdn.net/download/u013310119/10311191   。操作Weblogic JMS所需要的jar包下载地址为:https://download.csdn.net/download/u013310119/10311218       。搭建完成Spring框架,把Weblogic JMS的jar包导入后,就可以进行,Spring整合Weblogic JMS的开发。

在applicationContext.xml中配置Weblogic JMS的消息服务信息,队列,生参者,消费者和监听器信息。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"xmlns:jms="http://www.springframework.org/schema/jms"xmlns:jee="http://www.springframework.org/schema/jee"xmlns:tx="http://www.springframework.org/schema/tx"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans-3.0.xsdhttp://www.springframework.org/schema/jeehttp://www.springframework.org/schema/jee/spring-jee-3.0.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context-3.0.xsdhttp://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx-3.0.xsdhttp://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsdhttp://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.0.xsd"><bean id="weblogicJms" class="org.springframework.jndi.JndiTemplate">  <property name="environment">  <props>  <prop key="java.naming.factory.initial">  weblogic.jndi.WLInitialContextFactory   </prop>  <prop key="java.naming.provider.url">  t3://10.19.22.94:7011  </prop>  <prop key="java.naming.factory.url.pkgs">  weblogic.jndi.factories  </prop>  <prop key="java.naming.security.principal">  <!--用户名 -->weblogic  </prop>  <prop key="java.naming.security.credentials"> <!--密码  -->weblogic123  </prop>  </props>  </property>  </bean>  <!-- Connection factory -->  <bean id="jmsConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">  <property name="jndiName" value="gt3.esb.jms.con.ESBConnectionFactory" />  <property name="jndiTemplate" ref="weblogicJms"/>  </bean>  <!-- 用来接受消息的消息队列 -->  <bean id="jmsQueue" class="org.springframework.jndi.JndiObjectFactoryBean">  <property name="jndiName" value="gt3.esb.jms.mdb.BaseQueueAsynMDBean" /> <property name="jndiTemplate" ref="weblogicJms"/> <!-- <delivery-params-overrides><priority>9</priority>优先级,0最小,9最大</delivery-params-overrides> 批量还是实时,0为实时,25,75,100为批量<messaging-performance-preference>0</messaging-performance-preference> --></bean>  <!-- 用来测试消息回复的 --><bean id="responseQueue" class="org.springframework.jndi.JndiObjectFactoryBean">  <property name="jndiName" value="responseQueue" />  <property name="jndiTemplate" ref="weblogicJms"/>  </bean>  <!-- Receiver --> <!--消息消费者 --> <!-- <bean id="jmsReceiver" class="com.inspur.JMS.service.QueueMsgReceiver1">  </bean> --><bean id="jmsReceiverJDBC" class="com.inspur.JDBCTemplate.listener.ConsumerMessageListener">  </bean>  <bean id="jmsReceiverRsponse" class="com.inspur.JMS.service.ConsumerMessageListener">  </bean>  <!-- Message Listener -->  <!-- 在Spring整合JMS的应用中,如果我们要进行本地的事务管理的话非常简单,只需要在定义对应的消息监听容器时指定其sessionTransacted属性为true,如:  <property name="sessionTransacted" value="true"/>    该属性值默认为false,这样JMS在进行消息监听的时候就会进行事务控制,当在接收消息时监听器执行失败时JMS就会对接收到的消息进行回滚--><!--   如果想接收消息和数据库访问处于同一事务中,那么我们就可以配置一个外部的事务管理同时配置一个支持外部事务管理的消息监听容器(如DefaultMessageListenerContainer)。要配置这样一个参与分布式事务管理的消息监听容器,我们可以配置一个JtaTransactionManager,当然底层的JMS ConnectionFactory需要能够支持分布式事务管理,并正确地注册我们的JtaTransactionManager。这样消息监听器进行消息接收和对应的数据库访问就会处于同一数据库控制下,当消息接收失败或数据库访问失败都会进行事务回滚操作。当给消息监听容器指定了transactionManager时,消息监听容器将忽略sessionTransacted的值。 --><bean id="listenerContainer"  class="org.springframework.jms.listener.DefaultMessageListenerContainer">  <property name="connectionFactory" ref="jmsConnectionFactory"/>  <property name="destination" ref="jmsQueue"/>  <!-- <property name="messageListener" ref="jmsReceiver"/>   --><property name="messageListener" ref="jmsReceiverRsponse"/>  <!--  <property name="transactionManager" ref="jtaTransactionManager"/>   --><property name="autoStartup" value="true"/>  <!-- 设置固定的线程数 -->  <property name="concurrentConsumers" value="6"></property>  <!-- 	设置动态的线程数   --><property name="concurrency" value="2-9"></property>  <!-- 设置最大的线程数 -->  <property name="maxConcurrentConsumers" value="15"></property> </bean><!--  <bean id="jtaTransactionManager" class="org.springframework.transaction.jta.JtaTransactionManager"/>  <tx:annotation-driven transaction-manager="jtaTransactionManager"/> --><!-- Spring JMS Template -->  <!--Spring提供了专门的jmsTemplate对消息队列进行操作--><bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate" lazy-init="true">  <property name="connectionFactory" ref="jmsConnectionFactory" />  <property name="defaultDestination" ref="jmsQueue" /><property name="receiveTimeout">  <value>5000</value>  </property>     </bean>  <!-- Sender -->  <!--生产者--><bean id="jmsSender" class="com.inspur.JMS.controller.SendJMSMessage"  lazy-init="true">  <property name="jmsTemplate" ref="jmsTemplate"></property>  </bean>  <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"><property name="dataSource" ref="dataSource"/></bean><!-- 数据源配置 --><!-- <jee:jndi-lookup jndi-name="JDBC Data Source-0" id="dataSource"/> --><bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"       destroy-method="close">      <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver" />      <property name="url" value="jdbc:oracle:thin:@10.19.22.91:1521:orcl" />      <property name="username" value="ydpt" />      <property name="password" value="ydpt" />      </bean> <bean id="Student" class="entity.student">  <property name="name">  <value>Tom</value>  </property>  </bean>  <context:component-scan base-package="com.inspur" ><context:exclude-filter type="annotation" expression="org.springframework.stereotype.Controller"/></context:component-scan><!-- 配置spring注解扫描的包 -->    <context:component-scan base-package="com.elgin"></context:component-scan>    <!-- 或者不用注解的形式加载bean,改用配置的方式    <bean id="springWebService" class="com.elgin.spring.webservice.SpringWebServiceDemo ">      利用property可以对SpringService类进行初始化,比如<property name="name" value="姚明" /><property name="job" value="职业男篮" />,在配置完SpringService类后,就可以直接在程序中FileSystemXmlApplicationContext类或其他类似功能的类读取applicationContext.xml文件中的内容,并获得SpringService类的对象实例。但现在我们并不这样做,而是将SpringService类发布成WebService。在Tomcat的webapps项目中的WEB-INF\lib目录中有一个axis2-spring-1.4.1.jar文件, 该文件用于将被装配JavaBean的发布成WebService。  -->    </beans>

    接着我们来测试一下,看看我们的整合是否真的成功了,测试代码如下:

@Controller
@RequestMapping("test")
public class TestController {@Autowired@Qualifier("jmsQueue")private Destination destination;@Autowiredprivate ProducerServiceImpl producerService;@RequestMapping("first")public  String first() {producerService.sendMessage(destination, "你好,现在是:" + new Date().toLocaleString());return null;}}
@Component
public class ProducerServiceImpl  {@Autowiredprivate JmsTemplate jmsTemplate;public void sendMessage(Destination destination, final String message) {System.out.println("---------------生产者发送消息-----------------");System.out.println("---------------生产者发了一个消息:" + message);jmsTemplate.send(destination, new MessageCreator() {public Message createMessage(Session session) throws JMSException {/*TextMessage textMessage = session.createTextMessage(message);textMessage.setJMSReplyTo(responseDestination);return textMessage;*/return session.createTextMessage(message);/*MapMessage message = session.createMapMessage();message.setString("name1", "value1");message.setString("name2", "value2");message.setString("name3", "value3");return message;*/}});}public void sendMessage(final Destination destination, final Serializable obj) {//未使用MessageConverter的情况/*jmsTemplate.send(destination, new MessageCreator() {public Message createMessage(Session session) throws JMSException {ObjectMessage objMessage = session.createObjectMessage(obj);return objMessage;}});*///使用MessageConverter的情况jmsTemplate.convertAndSend(destination, obj);jmsTemplate.execute(new SessionCallback<Object>() {public Object doInJms(Session session) throws JMSException {MessageProducer producer = session.createProducer(destination);Message message = session.createObjectMessage(obj);producer.send(message);return null;}});jmsTemplate.execute(new ProducerCallback<Object>() {public Object doInJms(Session session, MessageProducer producer)throws JMSException {Message message = session.createObjectMessage(obj);producer.send(destination, message);return null;}});}}

消费者

public class ConsumerMessageListener implements MessageListener {


@Autowired
private TestDao testDao;

private int count = 0;

public void onMessage(Message message) {
//这里我们知道生产者发送的就是一个纯文本消息,所以这里可以直接进行强制转换,或者直接把onMessage方法的参数改成Message的子类TextMessage

System.out.println("在onMessage中线程ID是"+Thread.currentThread());  
TextMessage textMsg = (TextMessage) message;



System.out.println(new Date().toLocaleString() + "接收到一个纯文本消息。");
try {
String text = textMsg.getText();
System.out.println("消息内容是:" + text);

} catch (JMSException e) {
e.printStackTrace();
}
}


}

测试结果如下:


下面提供demo源码下载地址:

https://download.csdn.net/download/u013310119/10311333


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



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

相关文章

JVM 的类初始化机制

前言 当你在 Java 程序中new对象时,有没有考虑过 JVM 是如何把静态的字节码(byte code)转化为运行时对象的呢,这个问题看似简单,但清楚的同学相信也不会太多,这篇文章首先介绍 JVM 类初始化的机制,然后给出几个易出错的实例来分析,帮助大家更好理解这个知识点。 JVM 将字节码转化为运行时对象分为三个阶段,分别是:loading 、Linking、initialization

Spring Security 基于表达式的权限控制

前言 spring security 3.0已经可以使用spring el表达式来控制授权,允许在表达式中使用复杂的布尔逻辑来控制访问的权限。 常见的表达式 Spring Security可用表达式对象的基类是SecurityExpressionRoot。 表达式描述hasRole([role])用户拥有制定的角色时返回true (Spring security默认会带有ROLE_前缀),去

浅析Spring Security认证过程

类图 为了方便理解Spring Security认证流程,特意画了如下的类图,包含相关的核心认证类 概述 核心验证器 AuthenticationManager 该对象提供了认证方法的入口,接收一个Authentiaton对象作为参数; public interface AuthenticationManager {Authentication authenticate(Authenti

Spring Security--Architecture Overview

1 核心组件 这一节主要介绍一些在Spring Security中常见且核心的Java类,它们之间的依赖,构建起了整个框架。想要理解整个架构,最起码得对这些类眼熟。 1.1 SecurityContextHolder SecurityContextHolder用于存储安全上下文(security context)的信息。当前操作的用户是谁,该用户是否已经被认证,他拥有哪些角色权限…这些都被保

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明(认真看哦) AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证,则会调用 #attemptAuthentica

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门(一):登录与退出》 《Spring-Security-入门(二):基于数据库验证》 《Spring-Security-入门(三):密码加密》 《Spring-Security-入门(四):自定义-Filter》 《Spring-Security-入门(五):在 Sprin

Java架构师知识体认识

源码分析 常用设计模式 Proxy代理模式Factory工厂模式Singleton单例模式Delegate委派模式Strategy策略模式Prototype原型模式Template模板模式 Spring5 beans 接口实例化代理Bean操作 Context Ioc容器设计原理及高级特性Aop设计原理Factorybean与Beanfactory Transaction 声明式事物

Java进阶13讲__第12讲_1/2

多线程、线程池 1.  线程概念 1.1  什么是线程 1.2  线程的好处 2.   创建线程的三种方式 注意事项 2.1  继承Thread类 2.1.1 认识  2.1.2  编码实现  package cn.hdc.oop10.Thread;import org.slf4j.Logger;import org.slf4j.LoggerFactory

JAVA智听未来一站式有声阅读平台听书系统小程序源码

智听未来,一站式有声阅读平台听书系统 🌟&nbsp;开篇:遇见未来,从“智听”开始 在这个快节奏的时代,你是否渴望在忙碌的间隙,找到一片属于自己的宁静角落?是否梦想着能随时随地,沉浸在知识的海洋,或是故事的奇幻世界里?今天,就让我带你一起探索“智听未来”——这一站式有声阅读平台听书系统,它正悄悄改变着我们的阅读方式,让未来触手可及! 📚&nbsp;第一站:海量资源,应有尽有 走进“智听

在cscode中通过maven创建java项目

在cscode中创建java项目 可以通过博客完成maven的导入 建立maven项目 使用快捷键 Ctrl + Shift + P 建立一个 Maven 项目 1 Ctrl + Shift + P 打开输入框2 输入 "> java create"3 选择 maven4 选择 No Archetype5 输入 域名6 输入项目名称7 建立一个文件目录存放项目,文件名一般为项目名8 确定