开发者社区> 沉江剑> 正文

ActiveMQ

简介: ActiveMQ
+关注继续查看

-1.导包

 <!-- ActiveMQ的启动器 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-activemq</artifactId>
        </dependency>

-2.配置信息

@Configuration
public class ActiveMQConfig {

    // 提供生产bean的方法
    @Bean
    public Queue createQueue() {
        return new ActiveMQQueue("bos.queue");
    }

    @Bean
    public Topic createTopic() {
        return new ActiveMQTopic("bos.topic");
    }

}

-3.使用 --生产者

@Autowired
    private Queue queue;

    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;


   public void run(){
      /*  前台获取数据
             telephone:137****7790
             code:***
       */
        //准备消息
        ActiveMQMapMessage mapMessage = new ActiveMQMapMessage();

        mapMessage.setString("telephone",telephone);
        mapMessage.setString("code",code);
        //发送消息
        jmsMessagingTemplate.convertAndSend(queue,mapMessage);
    }

-4.消费者 --消费

package com.czxy.sms.consumer;

import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

import javax.jms.MapMessage;
import javax.jms.Message;

@Component
public class SmsConsumer {

    @JmsListener(destination = "java1.bos.sms")
    public void recive(Message message) {
        try {
            MapMessage mapMessage = (MapMessage) message;
            String telephone = mapMessage.getString("telephone");
            String code = mapMessage.getString("code");
            System.out.println(telephone + ":" + code);
            // 发送短信,调用SMSutil
            // SmsUtil.sendSms(telephone,code);

        } catch (Exception e) {

        }

    }

}

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

相关文章
一篇文章搞懂数据仓库:数据仓库架构-Lambda和Kappa对比
一篇文章搞懂数据仓库:数据仓库架构-Lambda和Kappa对比
10 0
Android 彻底掌握 Handler 看这里就够了(下)
重点关注 Handler 的 post(Runnable) 与 sendMessage(Message msg) 有什么区别 Handler.post() Handler.getPostMessage() Handler.sendMessage() Handrle.dispatchMessage() Handrle.handleCallback() Looper.loop() 为什么不会阻塞主线程 MessageQueue.next() MessageQueue.nativePollOnce() android_os_MessageQueue_nativePollOnce
6 0
云原生消息队列Pulsar浅析
云原生消息队列Pulsar浅析
6 0
想知道大厂面试都问什么吗,附最强面试技巧!!(大数据开发岗)
想知道大厂面试都问什么吗,附最强面试技巧!!(大数据开发岗)
9 0
时光转眼即逝,半年过来了我们收获了啥?
时光匆匆!转眼间半年过来了。有人碌碌无为,有人忙忙碌碌,有人学到了职场经验,有人学到了一线前沿技术,有人拿到了半年的工资。总之每个人有每个人的生活方式,我们不妄加评判。这里讲述一下自己吧。
5 0
RocketMQ 特点
RocketMQ 特点
5 0
RocketMQ 优势
RocketMQ 优势
7 0
RocketMQ 核心概念
RocketMQ 核心概念
6 0
对“飞天加速计划·高校学生在家实践”体验
为了提高自己的知识量,在假期进行自我学习,写了一个微服务的项目,在网络上发现阿里云平台出了一个飞天加速计划·高校学生在家实践的计划,于是将自己的服务器部署到了阿里云。在自己体验后,发现阿里云服务器真的很不错,值得大家使用!!!
7 0
进程间通信和线程间通信的几种方式
进程间通信和线程间通信的几种方式
4 0
+关注
10
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
OceanBase 入门到实战教程
立即下载
阿里云图数据库GDB,加速开启“图智”未来.ppt
立即下载
实时数仓Hologres技术实战一本通2.0版(下)
立即下载