文档章节

JMS

慕容若冰
 慕容若冰
发布于 2016/12/09 15:35
字数 186
阅读 10
收藏 0
  1. 安装ActiveMQ,运行ActiveMQ
  2. 新建Spring Boot项目,添加spring-jms和activemq-client依赖
  3. 消息定义
    package com.jms;
    
    import org.springframework.jms.core.MessageCreator;
    
    import javax.jms.JMSException;
    import javax.jms.Message;
    import javax.jms.Session;
    
    /**
     * 消息定义
     * Created by Administrator on 2016/12/9.
     */
    public class Msg implements MessageCreator{
        @Override
        public Message createMessage(Session session) throws JMSException {
            return session.createTextMessage("测试消息");
        }
    }
  4. 消息发送及目的地定义
    package com.jms;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.CommandLineRunner;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.jms.core.JmsTemplate;
    
    /**
     * 消息发送及目的地定义
     */
    @SpringBootApplication
    public class JmsApplication implements CommandLineRunner{
    
       @Autowired
       JmsTemplate jmsTemplate;//注入Spring Boot配置好的JmsTemplate Bean
    
       public static void main(String[] args) {
          SpringApplication.run(JmsApplication.class, args);
       }
    
       @Override
       public void run(String... strings) throws Exception {
          jmsTemplate.send("my-destination", new Msg());//向my-destination目的地发送Msg消息
       }
    }
  5. 消息监听
    package com.jms;
    
    import org.springframework.jms.annotation.JmsListener;
    import org.springframework.stereotype.Component;
    
    /**
     * 消息监听
     * Created by Administrator on 2016/12/9.
     */
    @Component
    public class Receiver {
    
        @JmsListener(destination = "my-destination")
        public void receiveMessage(String message) {
            System.out.print("接收到:<" + message + ">");
        }
    }
  6. 运行

© 著作权归作者所有

共有 人打赏支持
上一篇: AMQP
慕容若冰
粉丝 1
博文 44
码字总数 9774
作品 0
广州
程序员
私信 提问

暂无文章

jquery通过id显示隐藏

var $div3 = $('#div3'); 显示 $div3.show(); 隐藏 $div3.hide();

yan_liu
今天
3
0
《乱世佳人》读书笔记及相关感悟3900字

《乱世佳人》读书笔记及相关感悟3900字: 之前一直听「荔枝」,后来不知怎的转向了「喜马拉雅」,一听就是三年。上班的时候听房产,买房了以后听装修,兴之所至时听旅行,分手后听亲密关系,...

原创小博客
今天
3
0
大数据教程(9.6)map端join实现

上一篇文章讲了mapreduce配合实现join,本节博主将讲述在map端的join实现; 一、需求 实现两个“表”的join操作,其中一个表数据量小,一个表很大,这种场景在实际中非常常见,比如“订单日志...

em_aaron
今天
3
0
cookie与session详解

session与cookie是什么? session与cookie属于一种会话控制技术.常用在身份识别,登录验证,数据传输等.举个例子,就像我们去超市买东西结账的时候,我们要拿出我们的会员卡才会获取优惠.这时...

士兵7
今天
3
0
十万个为什么之为什么大家都说dubbo

Dubbo是什么? 使用背景 dubbo为什么这么流行, 为什么大家都这么喜欢用dubbo; 通过了解分布式开发了解到, 为适应访问量暴增,业务拆分后, 子应用部署在多台服务器上,而多台服务器通过可以通过d...

尾生
今天
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部