zoukankan      html  css  js  c++  java
  • Springboot整合activeMq

    1.maven依赖

     <dependency>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-activemq</artifactId>
     </dependency>

    2.properties.yml配置

    spring:
      activemq:
        broker-url: tcp://ip:61616
        user: admin
        password: admin
    queue: queue_name

    3.创建一个队列

    /**
     * 创建一个队列
     */
    @Configuration
    public class QueueConfig {
    
        @Value("${queue}")
        private String queueName;
    
        @Bean
        public Queue queue(){
            return new ActiveMQQueue(queueName);
        }
    }

    4.创建生产者

    /**
     * 生产者
     */
    @Component
    @EnableScheduling
    public class Producer {
    
    
        @Autowired
        JmsMessagingTemplate jmsMessagingTemplate;
    
    
        @Autowired
        private Queue queue;
    
        private int i = 0;
    
        //定时器每隔5秒向activmq服务器发送一条消息
        @Scheduled(fixedDelay = 5000)
        public void send(){
            i ++;
            jmsMessagingTemplate.convertAndSend(queue, "第"+i+"条数据");
        }
    
    }

    5.创建消费者

    /**
     * 消费者
     */
    @Component
    public class Consumer {
    
        @JmsListener(destination = "${queue}")
        public void receive(String msg){
            System.out.println("消费者"+msg);
        }
        
    }

    6.运行程序即可在控制台看到数据接收记录

  • 相关阅读:
    php二维数组排序
    重学C语言 -- printf,scanf
    php调试利器 -- xdebug
    composer php依赖管理工具
    现代php开发
    php新特性--持续更新
    2016年书单
    jenkins集成gitlab实现自动合并
    etcd安装
    nginx 日志切割
  • 原文地址:https://www.cnblogs.com/jsnan/p/9465124.html
Copyright © 2011-2022 走看看