ActiveMQ入门教程(七)----SpringBoot整合ActiveMQ

忘是亡心i 2021-09-01 07:17 466阅读 0赞

### SpringBoot整合ActiveMQ ###

*  队列生产者
 *   *  新建Maven工程并配置包名类名
     *  配置Pom.xml
     *  配置application.yml
     *  配置Bean
     *  编写 Queue\_Produce
     *  编写主启动类
     *  编写测试类
 *  队列生产者间隔定投
 *   *  修改Queue\_Produce新增定时投送方法
     *  修改主启动类APP
     *  直接开启主启动类，间隔发消息OK
 *  队列消费者
 *   *  新建Maven工程
     *  配置Pom.xml
     *  配置application.yml
     *  配置Queue\_Consume.java
     *  配置启动类APP.java
 *  主题生产者
 *   *  创建Maven工程
     *  配置Pom.xml
     *  配置application.yml
     *  配置ConfigBean
     *  配置Topic\_produce.java
     *  配置启动类
 *  主题消费者
 *   *  创建Maven工程
     *  配置Pom.xml
     *  配置application.yml
     *  配置Topic\_consumer.java
     *  配置启动类

# 队列生产者 #

## 新建Maven工程并配置包名类名 ##

*  工程名: boot\_mq\_produce
 *  包名：com.fyh.boot.activemq

## 配置Pom.xml ##

<?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>
    
      <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.5.RELEASE</version>
        <relativePath/> 
      </parent>
    
      <groupId>com.fyh.boot.activemq</groupId>
      <artifactId>boot_mq_produce</artifactId>
      <version>1.0-SNAPSHOT</version>
    
      <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.8</maven.compiler.source>
        <maven.compiler.target>1.8</maven.compiler.target>
      </properties>
    
      <dependencies>
        <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-test</artifactId>
        </dependency>
    
        <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-activemq</artifactId>
          <version>2.1.5.RELEASE</version>
        </dependency>
    
        <dependency>
          <groupId>junit</groupId>
          <artifactId>junit</artifactId>
          <version>4.12</version>
          <scope>test</scope>
        </dependency>
      </dependencies>
    
      <build>
        <plugins>
          <plugin>
             <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
          </plugin>
        </plugins>
      </build>
    </project>

## 配置application.yml ##

#端口
    server:
      port: 3332
    #activemq配置
    spring:
      activemq:
        broker-url: tcp://127.0.0.1:61616
        user: admin
        password: admin
      jms:
        pub-sub-domain: false   #默认是Queue队列模式 是false 主题是Topic 为true
    #自己定义自己的队列
    myqueue:
      boot-activemq-queue

## 配置Bean ##

@Component
    @EnableJms //开启响应的jms服务
    public class ConfigBean {
        @Value("${myqueue}")
        private String myQueue;
        @Bean
        public Queue queue(){
            return new ActiveMQQueue(myQueue);
        }
    }

## 编写 Queue\_Produce ##

## 编写主启动类 ##

@SpringBootApplication
    public class App 
    {
        public static void main( String[] args )
        {
            SpringApplication.run(App.class);
        }
    }

## 编写测试类 ##

@SpringBootTest(classes = App.class)
    @RunWith(SpringJUnit4ClassRunner.class)
    @WebAppConfiguration
    public class AppTest 
    {
        @Resource
        private Queue_Produce queue_produce;
        @Test
        public void testSend() throws  Exception
        {
            queue_produce.produceMsg();
        }
    }

# 队列生产者间隔定投 #

需求：每个3秒钟往MQ推送消息以下定时发送case

## 修改Queue\_Produce新增定时投送方法 ##

@Component
    public class Queue_Produce {
    
        @Autowired
        private JmsMessagingTemplate jmsMessagingTemplate;
    
        @Autowired
        public Queue queue;
    
        public void  produceMsg(){
            jmsMessagingTemplate.convertAndSend(queue,"******" + UUID.randomUUID().toString().substring(0,6));
        }
    
        //定时3秒投送
        @Scheduled(fixedDelay = 3000)
        public void producerMsgScheduled(){
            jmsMessagingTemplate.convertAndSend(queue,"******Scheduled" + UUID.randomUUID().toString().substring(0,6));
            System.out.println("****producerMsgScheduled send success");
        }
    }

## 修改主启动类APP ##

@SpringBootApplication
    @EnableScheduling  //激活定时投送3秒的Schedule
    public class App 
    {
        public static void main( String[] args )
        {
            SpringApplication.run(App.class);
        }
    }

## 直接开启主启动类，间隔发消息OK ##

![在这里插入图片描述][20200103145810256.jpg]  
![在这里插入图片描述][20200103145822916.jpg]

# 队列消费者 #

## 新建Maven工程 ##

*  工程名: boot\_mq\_consume
 *  包名：com.fyh.boot.activemq

## 配置Pom.xml ##

<?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>
    
      <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.5.RELEASE</version>
        <relativePath/> 
      </parent>
    
      <groupId>com.fyh.boot.active</groupId>
      <artifactId>boot_mq_consumer</artifactId>
      <version>1.0-SNAPSHOT</version>
    
      <name>boot_mq_consumer</name>
      
      <url>http://www.example.com</url>
    
      <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.7</maven.compiler.source>
        <maven.compiler.target>1.7</maven.compiler.target>
      </properties>
    
      <dependencies>
        <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-test</artifactId>
        </dependency>
    
        <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-activemq</artifactId>
          <version>2.1.5.RELEASE</version>
        </dependency>
    
        <dependency>
          <groupId>junit</groupId>
          <artifactId>junit</artifactId>
          <version>4.12</version>
          <scope>test</scope>
        </dependency>
      </dependencies>
    
      <build>
        <plugins>
          <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
          </plugin>
        </plugins>
      </build>
    </project>

## 配置application.yml ##

server:
      port: 8888
    spring:
      activemq:
        broker-url: tcp://localhost:61616
        user: admin
        password: admin
      jms:
        pub-sub-domain: false
    myqueue:
      boot-activemq-queue

## 配置Queue\_Consume.java ##

@Component
    public class Queue_Consumer {
    
        @JmsListener(destination = "${myqueue}")
        public void received(TextMessage textMessage) throws JMSException{
            System.out.println("********消费者收到消息：" + textMessage.getText());
        } @Component
    public class Queue_Consumer {
    
        @JmsListener(destination = "${myqueue}")
        public void received(TextMessage textMessage) throws JMSException{
            System.out.println("********消费者收到消息：" + textMessage.getText());
        }
    }
    }

## 配置启动类APP.java ##

@SpringBootApplication
    public class App 
    {
        public static void main( String[] args )
        {
            SpringApplication.run(App.class);
        }
    }

# 主题生产者 #

## 创建Maven工程 ##

*  工程名: boot\_topicmq\_producer
 *  包名：com.fyh.boot.activemq

## 配置Pom.xml ##

// Pom.xml
    <?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>
    
      <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.5.RELEASE</version>
        <relativePath/> 
      </parent>
    
      <groupId>com.fyh.boot.activemq</groupId>
      <artifactId>boot_topicMQ_produce</artifactId>
      <version>1.0-SNAPSHOT</version>
    
    
      <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.8</maven.compiler.source>
        <maven.compiler.target>1.8</maven.compiler.target>
      </properties>
    
      <dependencies>
        <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-test</artifactId>
        </dependency>
    
        <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-activemq</artifactId>
          <version>2.1.5.RELEASE</version>
        </dependency>
    
        <dependency>
          <groupId>junit</groupId>
          <artifactId>junit</artifactId>
          <version>4.12</version>
          <scope>test</scope>
        </dependency>
      </dependencies>
    
      <build>
        <plugins>
          <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
          </plugin>
        </plugins>
      </build>
    </project>

## 配置application.yml ##

# Application.yml
    server:
      port: 6666
    
    spring:
      activemq:
        broker-url: tcp://localhost:61616
        user: admin
        password: admin
      jms:
        pub-sub-domain: true   # true表示的是主题模式，订阅或发布
    
    myTopic:
      boot-activemq-topic

## 配置ConfigBean ##

@Component
    public class ConfigBean {
    
        @Value("${myTopic}")
        private String topicName;
    
        @Bean
        public Topic topic(){
            return new ActiveMQTopic(topicName);
        }
    }

## 配置Topic\_produce.java ##

@Component
    public class Topic_Produce {
    
        @Autowired
        private JmsMessagingTemplate jmsMessagingTemplate;
        @Autowired
        private Topic topic;
    
        @Scheduled(fixedDelay = 3000)  //三秒钟定时调动发送一次消息
        public  void produceTopic(){
            jmsMessagingTemplate.convertAndSend(topic,"主题消息"+ UUID.randomUUID().toString().substring(0,6));
        }
    }

## 配置启动类 ##

@SpringBootApplication
    @EnableScheduling
    public class App 
    {
        public static void main( String[] args )
        {
            SpringApplication.run(App.class);
        }
    }

# 主题消费者 #

## 创建Maven工程 ##

*  工程名: boot\_topicmq\_consumer
 *  包名：com.fyh.boot.activemq

## 配置Pom.xml ##

<?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>
    
      <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.5.RELEASE</version>
        <relativePath/> 
      </parent>
    
      <groupId>com.fyh.boot.activemq</groupId>
      <artifactId>boot_topicMQ_consumer</artifactId>
      <version>1.0-SNAPSHOT</version>
    
    
      <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.8</maven.compiler.source>
        <maven.compiler.target>1.8</maven.compiler.target>
      </properties>
    
      <dependencies>
        <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-test</artifactId>
        </dependency>
    
        <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-activemq</artifactId>
          <version>2.1.5.RELEASE</version>
        </dependency>
    
        <dependency>
          <groupId>junit</groupId>
          <artifactId>junit</artifactId>
          <version>4.12</version>
          <scope>test</scope>
        </dependency>
      </dependencies>
    
      <build>
        <plugins>
          <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
          </plugin>
        </plugins>
      </build>
    </project>

## 配置application.yml ##

server:
      port: 5566   # 设置两个端口  5555  |  5566  即在第一个启动之后修改端口号为5555
    spring:
      activemq:
        broker-url: tcp://localhost:61616
        user: admin
        password: admin
      jms:
        pub-sub-domain: true
    myTopic:
      boot-activemq-topic

## 配置Topic\_consumer.java ##

@Component
    public class Topic_Consumer {
        @JmsListener(destination = "${myTopic}")
        public  void receive(TextMessage textMessage) throws JMSException{
            System.out.println("消费者收到订阅的主题：" + textMessage.getText()    );
        }
    }

## 配置启动类 ##

// MainApp5555.java
    @SpringBootApplication
    public class MainApp5555{
        public static void main( String[] args ) {
            SpringApplication.run(MainApp5555.class);
        }
    }
    // MainApp5566.java
    @SpringBootApplication
    public class MainApp5566 {
        public static void main(String[] args) {
            SpringApplication.run(MainApp5566.class);
        }
    }

[20200103145810256.jpg]: /images/20210901/c83acab8815f42f1aff29399678e6ea9.png
[20200103145822916.jpg]: /images/20210901/13da020cac81439a8d476eddd4692216.png