AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

Spring JMS

2017-11-16 926
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：

1. 创建maven工程

   这个工程的文件结构如下图

  

 

2. pom配置

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
<? xml  version="1.0" encoding="UTF-8"?>
< project  xmlns="http://maven.apache.org/POM/4.0.0"
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     < modelVersion >4.0.0</ modelVersion >
 
     < groupId >com.example.jms</ groupId >
     < artifactId >jms-spring</ artifactId >
     < version >1.0-SNAPSHOT</ version >
 
     < properties >
         < spring.version >4.2.5.RELEASE</ spring.version >
     </ properties >
     < dependencies >
         < dependency >
             < groupId >junit</ groupId >
             < artifactId >junit</ artifactId >
             < version >4.11</ version >
             < scope >test</ scope >
         </ dependency >
 
         < dependency >
             < groupId >org.springframework</ groupId >
             < artifactId >spring-context</ artifactId >
             < version >${spring.version}</ version >
         </ dependency >
 
         < dependency >
             < groupId >org.springframework</ groupId >
             < artifactId >spring-jms</ artifactId >
             < version >${spring.version}</ version >
         </ dependency >
 
         < dependency >
             < groupId >org.springframework</ groupId >
             < artifactId >spring-test</ artifactId >
             < version >${spring.version}</ version >
         </ dependency >
 
         < dependency >
             < groupId >org.apache.activemq</ groupId >
             < artifactId >activemq-core</ artifactId >
             < version >5.7.0</ version >
             < exclusions >
                 < exclusion >
                     < artifactId >spring-content</ artifactId >
                     < groupId >org.springframework</ groupId >
                 </ exclusion >
             </ exclusions >
         </ dependency >
     </ dependencies >
</ project >

　　

3. 创建生产者

3.1 创建ProducerServer接口

1
2
3
4
public  interface  ProducerService {
     void  sendMessage(String message);
 
}

3.2 创建ProducerServiceImpl类

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
public  class  ProducerServiceImpl  implements  ProducerService {
 
     @Autowired
     JmsTemplate jmsTemplate;
 
     @Resource (name= "queueDestination" )
     Destination destination;
 
 
     public  void  sendMessage( final  String message) {
         // 使用JmsTemplate发送消息
         jmsTemplate.send(destination,  new  MessageCreator(){
             //创建一个消息
             public  Message createMessage(Session session)  throws  JMSException {
                 TextMessage textMessage = session.createTextMessage(message);
                 return  textMessage;
             }
         });
 
         System.out.println( "发送消息: "  + message);
     }
}

　　

 

　　

 3.3 创建配置文件producer.xml

配置如下：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
<? 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"
        xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
 
     < context:annotation-config ></ context:annotation-config >
 
     <!--ActiveMQ为我们提供的ConnectinFactory -->
     < bean  id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
         < property  name="brokerURL" value="tcp://192.168.2.121:61616"></ property >
     </ bean >
     <!--spring jms为我们提供的连接池-->
     < bean  id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
         < property  name="targetConnectionFactory" ref="targetConnectionFactory"></ property >
     </ bean >
 
     <!--一个队列目的地，点对点的-->
     < bean  id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">
         < constructor-arg  value="queue" />
     </ bean >
 
     <!--配置JmsTemplate， 用于发送消息-->
     < bean  id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
         < property  name="connectionFactory" ref="connectionFactory"></ property >
     </ bean >
 
     < bean  class="com.example.jms.producer.ProducerServiceImpl">
 
     </ bean >
</ beans >

　

3.4 创建启动类

1
2
3
4
5
6
7
8
9
10
11
12
public  class  AppProducer {
     public  static  void  main(String[] args) {
         ClassPathXmlApplicationContext context =  new  ClassPathXmlApplicationContext( "producer.xml" );
         ProducerService service = context.getBean(ProducerService. class );
         for  ( int  i =  0 ; i <  100 ; i++) {
             service.sendMessage( "text"  + i);
         }
         context.close();
 
     }
 
}

　　

　

4. 创建接收者

4.1 创建监听器

1
2
3
4
5
6
7
8
9
10
11
public  class  ConsumerMessageListener  implements  MessageListener{
     public  void  onMessage(Message message) {
         TextMessage textMessage = (TextMessage)message;
         try  {
             System.out.println( "接收消息"  + textMessage.getText());
         }  catch  (JMSException e) {
             e.printStackTrace();
         }
 
     }
}

　　

4.2 创建配置文件

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
<?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"
        xsi:schemaLocation= "http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd" >
 
     <context:annotation-config></context:annotation-config>
 
     <!--ActiveMQ为我们提供的ConnectinFactory -->
     <bean id= "targetConnectionFactory"  class = "org.apache.activemq.ActiveMQConnectionFactory" >
         <property name= "brokerURL"  value= "tcp://192.168.2.121:61616" ></property>
     </bean>
     <!--spring jms为我们提供的连接池-->
     <bean id= "connectionFactory"  class = "org.springframework.jms.connection.SingleConnectionFactory" >
         <property name= "targetConnectionFactory"  ref= "targetConnectionFactory" ></property>
     </bean>
 
     <!--一个队列目的地，点对点的-->
     <bean id= "queueDestination"  class = "org.apache.activemq.command.ActiveMQQueue" >
         <constructor-arg value= "queue"  />
     </bean>
 
     <!--配置消息监听器-->
     <bean id= "consumerMessageListener"  class = "com.example.jms.consumer.ConsumerMessageListener"  />
     <!--配置消息监听容器-->
     <bean id= "jmsContainer"  class = "org.springframework.jms.listener.DefaultMessageListenerContainer" >
         <property name= "connectionFactory"  ref= "connectionFactory"  />
         <property name= "destination"  ref= "queueDestination"  />
         <property name= "messageListener"  ref= "consumerMessageListener"  />
     </bean>
</beans>

　　

4.3 创建启动类

1
2
3
4
5
6
public  class  APPConsumer {
     public  static  void  main(String[] args) {
         ApplicationContext context =  new  ClassPathXmlApplicationContext( "consumer.xml" );
 
     }
}

　　

5. 主题模式

5.1 配置消费者

修改consumer.xml文件

 

5.2 配置生产者

 

5.3 修改生产者



本文转自Work Hard Work Smart博客园博客，原文链接：http://www.cnblogs.com/linlf03/p/8047897.html，如需转载请自行联系原作者

文章标签：
Spring
Apache
Java
关键词：
Spring JMS
zting科技
目录
相关文章
泥腿子架构师
|
7月前
|
消息中间件 Java Spring
Spring Boot与JMS消息中间件的集成
Spring Boot与JMS消息中间件的集成
泥腿子架构师
74 0
多多!
|
7月前
|
消息中间件 存储 Java
后端开发Spring框架之消息介绍 同步异步 JMS AMQP MQTT Kafka介绍
后端开发Spring框架之消息介绍 同步异步 JMS AMQP MQTT Kafka介绍
多多!
48 0
热烈的马
|
8月前
|
消息中间件 Java Spring
Spring Boot中异步消息JMS的讲解与通信实例
Spring Boot中异步消息JMS的讲解与通信实例
热烈的马
101 1
怒放de生命
|
消息中间件 搜索推荐 Java
消息中间件JMS介绍、入门demo与spring整合
消息中间件JMS介绍、入门demo与spring整合
怒放de生命
399 12
消息中间件JMS介绍、入门demo与spring整合
llsydn
|
消息中间件 存储 网络协议
Spring Boot与消息(JMS、AMQP、RabbitMQ)
1.概述。 大多应用中，可通过消息服务中间件来提升系统异步通信、扩展解耦能力。 消息服务中两个重要概念： 消息代理（message broker）和目的地（destination）。 当消息发送者发送
llsydn
308 0
蒋老湿
|
Java 数据库连接 应用服务中间件
分布式事务之Spring/JPA/JMS事务（二）
分布式事务之Spring/JPA/JMS事务
蒋老湿
309 0
分布式事务之Spring/JPA/JMS事务（二）
程序员石磊
|
消息中间件 Java Spring
spring ehcache jms activemq 分布式实现方案
spring ehcache jms activemq 分布式实现方案
程序员石磊
152 0
技术小美
|
消息中间件 Java 中间件
Java中间件JMS(四)之ActiveMQ整合spring之类转换
技术小美
1317 3
elim1
|
Java Spring 容器
Spring整合JMS(二)——三种消息监听器
1.3     消息监听器MessageListener        在Spring整合JMS的应用中我们在定义消息监听器的时候一共可以定义三种类型的消息监听器，分别是MessageListener、SessionAwareMessageListener和MessageListenerAdapter。
elim1
963 0
Spring整合JMS(二)——三种消息监听器
jmcui
|
消息中间件 Java Spring
Spring消息之JMS.
一、概念 异步消息简介     与远程调用机制以及REST接口类似，异步消息也是用于应用程序之间通信的。     RMI、Hessian、Burlap、HTTP invoker和Web服务在应用程序之间的通信机制是同步的，即客户端应用程序直接与远程服务相交互，并且一直等到远程过程完成后才继续执行。
jmcui
1247 0

热门文章

最新文章

  • 1
    Spring Cloud Alibaba：一站式微服务解决方案
  • 2
    详解Spring Batch：在Spring Boot中实现高效批处理
  • 3
    从单体到微服务：如何借助 Spring Cloud 实现架构转型
  • 4
    深入 Spring Cloud Gateway 过滤器
  • 5
    使用 Spring Boot 执行数据库操作：全面指南
  • 6
    什么是JWT？如何使用Spring Boot Security实现它？
  • 7
    Spring MVC中的请求映射：@RequestMapping注解深度解析
  • 8
    【SpringFramework】Spring初体验
  • 9
    利用Spring Cloud Gateway Predicate优化微服务路由策略
  • 10
    京东面试：聊聊Spring事务？Spring事务的10种失效场景？加入型传播和嵌套型传播有什么区别？
  • 1
    Spring高手之路18——从XML配置角度理解Spring AOP
    103
  • 2
    Spring Boot中一般如何使用线程池？
    796
  • 3
    Spring Boot 源码面试知识点
    104
  • 4
    【MongoDB 专栏】MongoDB 与 Spring Boot 的集成实践
    263
  • 5
    深入探索Spring Boot Web应用源码及实战应用
    115
  • 6
    ruoyi-nbcio从spring2.7.18升级springboot到3.1.7，java从java8升级到17（二）
    366
  • 7
    springboot全局自定义异常
    47
  • 8
    RabbitMQ的springboot项目集成使用-01
    150
  • 9
    什么是Spring Boot 自动配置？
    63
  • 10
    Spring cloud原理详解
    82

    • 相关课程

    更多
  • 全面讲解Spring Cloud Alibaba技术栈（知识精讲+项目实战）第一阶段
  • 精通Spring Cloud Alibaba
  • 微服务框架 Spring Cloud 快速入门
  • Java Web开发系列课程 - Spring框架入门
  • Spring Boot 2.5.x开发实战
  • Spring Cloud微服务架构设计与开发实战

    • 相关电子书

    更多
  • 云栖社区特邀专家徐雷Java Spring Boot开发实战系列课程（第20讲）：经典面试题与阿里等名企内部招聘求职面试技巧
  • 微服务架构模式与原理Spring Cloud开发实战
  • 阿里特邀专家徐雷Java Spring Boot开发实战系列课程（第18讲）：制作Java Docker镜像与推送到DockerHub和阿里云Docker仓库

    • 相关实验场景

    更多
  • Spring-cloud-bus-rocketmq入门与实践
  • Spring-cloud-stream-binder-rocketmq入门与实践
  • Rocketmq-spring入门与实践
  • 从零搭建Spring Boot的Hello World
    • 下一篇
    阿里云无影云电脑免费试用，最长可试用3个月