文档章节

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. 运行

© 著作权归作者所有

共有 人打赏支持
慕容若冰
粉丝 0
博文 44
码字总数 9774
作品 0
广州
程序员

暂无文章

Shiro | 实现权限验证完整版

写在前面的话 提及权限,就会想到安全,是一个十分棘手的话题。这里只是作为学校Shiro的一个记录,而不是,权限就应该这样设计之类的。 Shiro框架 1、Shiro是基于Apache开源的强大灵活的开源...

冯文议
今天
1
0
linux 系统的运行级别

运行级别 运行级别 | 含义 0 关机 1 单用户模式,可以想象为windows 的安全模式,主要用于修复系统 2 不完全的命令模式,不含NFS服务 3 完全的命令行模式,就是标准的字符界面 4 系统保留 5 ...

Linux学习笔记
今天
2
0
学习设计模式——命令模式

任何模式的出现,都是为了解决一些特定的场景的耦合问题,以达到对修改封闭,对扩展开放的效果。命令模式也不例外: 命令模式是为了解决命令的请求者和命令的实现者之间的耦合关系。 解决了这...

江左煤郎
今天
3
0
字典树收集(非线程安全,后续做线程安全改进)

将500W个单词放进一个数据结构进行存储,然后进行快速比对,判断一个单词是不是这个500W单词之中的;来了一个单词前缀,给出500w个单词中有多少个单词是该前缀. 1、这个需求首先需要设计好数据结...

算法之名
昨天
15
0
GRASP设计模式

此文参考了这篇博客,建议读者阅读原文。 面向对象(Object-Oriented,OO)是当下软件开发的主流方法。在OO分析与设计中,我们首先从问题领域中抽象出领域模型,在领域模型中以适当的粒度归纳...

克虏伯
昨天
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部