SpringBoot 整合 Apache ActiveMQ

SpringBoot 整合 Apache ActiveMQ

1. pom.xml 添加依赖

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

2. 修改application.yml

spring:
activemq:
broker-url: tcp://192.168.44.129:61616
user: admin
password: admin

3. 创建消息生产者Producer

package cn.tyrone.springboot.integrate.activemq;

import javax.jms.Queue;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Component;

/**
* 消息生产者
*
*/
@Component
public class Producer {

/*
* Jms消息模板
*/
@Autowired private JmsMessagingTemplate jmsMessagingTemplate;

/*
* 队列
*/
@Autowired private Queue queue;

/*
* 发送消息
*/
public void send(String msg){
this.jmsMessagingTemplate.convertAndSend(this.queue, msg);
}
}

4. 创建消息消费者Consumer

package cn.tyrone.springboot.integrate.activemq;

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

@Component
public class Consumer {

@JmsListener(destination = "sample.queue")
public void receiveMessge(String text){
System.out.println("发送的消息:\t" + text);
}
}

5. 创建SpringBoot启动类

package cn.tyrone.springboot.integrate.activemq;

import javax.jms.Queue;

import org.apache.activemq.command.ActiveMQQueue;
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.context.annotation.Bean;
import org.springframework.jms.annotation.EnableJms;

@SpringBootApplication
@EnableJms
public class Application implements CommandLineRunner {

/*
* 声明一个消息队列
*/
@Bean
public Queue queue() {
return new ActiveMQQueue("sample.queue");
}

/*
* 注入消息生产者
*/
@Autowired private Producer Producer;

@Override
public void run(String... args) throws Exception {
Producer.send("Hello! SpringBoot integrate Apache ActiveMQ!!!");
System.out.println("发送消息结束！！！");

}

public static void main(String[] args) throws Exception {
SpringApplication.run(Application.class, args);
}

}

.   ____          _            __ _ _
/\\ / ___'_ __ _ _(_)_ __  __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
\\/  ___)| |_)| | | | | || (_| |  ) ) ) )
'  |____| .__|_| |_|_| |_\__, | / / / /
=========|_|==============|___/=/_/_/_/
:: Spring Boot ::        (v1.5.3.RELEASE)

2017-07-20 15:02:27.237  INFO 3796 --- [           main] c.t.s.integrate.activemq.Application     : Starting Application on EZ-20161228YDGX with PID 3796 (D:\tyrone-workspace\springboot-study\tyrone-springboot-integrate-activemq\target\classes started by Administrator in D:\tyrone-workspace\springboot-study\tyrone-springboot-integrate-activemq)
2017-07-20 15:02:27.242  INFO 3796 --- [           main] c.t.s.integrate.activemq.Application     : No active profile set, falling back to default profiles: default
2017-07-20 15:02:27.310  INFO 3796 --- [           main] s.c.a.AnnotationConfigApplicationContext : Refreshing org.springframework.context.annotation.AnnotationConfigApplicationContext@1f0f1111: startup date [Thu Jul 20 15:02:27 CST 2017]; root of context hierarchy
2017-07-20 15:02:28.801  INFO 3796 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Registering beans for JMX exposure on startup
2017-07-20 15:02:28.807  INFO 3796 --- [           main] o.s.c.support.DefaultLifecycleProcessor  : Starting beans in phase 2147483647
发送消息开始！！！
----接收消息开始 ----
接收的消息内容:    Hello! SpringBoot integrate Apache ActiveMQ!!!
----接收消息结束 ----
发送消息结束！！！
2017-07-20 15:02:29.100  INFO 3796 --- [           main] c.t.s.integrate.activemq.Application     : Started Application in 2.316 seconds (JVM running for 3.106)