Springboot整合adiveMQ Demo

 <dependencies>
        <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>
            <scope>test</scope>
        </dependency>
        <!--热部署 不用重启项目-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
        </dependency>
        <!--springboot整合activemq-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-activemq</artifactId>
        </dependency>

    </dependencies>

/**
 * 一个消息的生产者
 * 这是一个新建的类
 */
@RestController
public class QueueController {

    //发送只需要注入这个魔板方法
    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;

    @RequestMapping("/send")
   public void send(String text){
         //调用方法：转换并且发送   参数：1.队列名称 2.把传过来的文本传进去
       jmsMessagingTemplate.convertAndSend("xx",text);
   }
}

/**
 * 一个消费者类
 * 这是一个新建的类
 */
//标识这是一个组件
@Component
public class Consumer {
     //读取的是什么类型就封装什么类型
    //加入注解  标识监听哪个队列
    @JmsListener(destination = "xx")
     public void readMessage(String text){
         System.out.println("接收到消息："+text);
     }

}

spring.activemq.broker-url=tcp:192.168.25.135:61616