SpringBoot2.0應用（二）：SpringBoot2.0整合ActiveMQ

本篇開始將具體介紹SpringBoot如何整合其它項目。

如何建立SpringBoot項目

訪問https://start.spring.io/。

依次選擇構建工具Maven Project、語言java、Spring Boot版本2.0.5，點擊Generate Project下載項目壓縮包，解壓後倒入到ide中便可。（idea集成了SpringBoot，可直接建立項目）

如何整合ActiveMQ

一、添加spring-boot-starter-activemq依賴

<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-activemq</artifactId>
		</dependency>
複製代碼

二、添加配置

spring.activemq.in-memory=true
spring.activemq.pool.enabled=false
複製代碼

三、添加SampleActiveMQApplication類

@SpringBootApplication
@EnableJms
public class SampleActiveMQApplication {
	@Bean
	public Queue queue() {
		return new ActiveMQQueue("sample.queue");
	}

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

}
複製代碼

四、添加Consumer類

@Component
public class Consumer {
	@JmsListener(destination = "sample.queue")
	public void receiveQueue(String text) {
		System.out.println(text);
	}

}
複製代碼

五、添加Producer類

@Component
public class Producer implements CommandLineRunner {
	@Autowired
	private JmsMessagingTemplate jmsMessagingTemplate;

	@Autowired
	private Queue queue;

	@Override
	public void run(String... args) throws Exception {
		send("Sample message");
		System.out.println("Message was sent to the Queue");
	}

	public void send(String msg) {
		this.jmsMessagingTemplate.convertAndSend(this.queue, msg);
	}

}
複製代碼

六、啓動服務 控制檯輸出：

Message was sent to the Queue
Sample message
複製代碼

---

以上例子使用的是SpringBoot內部的ActiveMQ，實際使用時確定會用外部的ActiveMQ。

如何鏈接外部的ActiveMQ

一、添加依賴

<dependency>
			<groupId>org.apache.activemq</groupId>
			<artifactId>activemq-pool</artifactId>
		</dependency>
複製代碼

二、修改配置

spring.activemq.broker-url=tcp://localhost:61616
spring.activemq.close-timeout=5000
spring.activemq.in-memory=false
spring.activemq.pool.enabled=true
spring.activemq.pool.max-connections=100
spring.activemq.send-timeout=3000
複製代碼

三、啓動服務 首先，確保ActiveMQ已經啓動。控制檯輸出：

Message was sent to the Queue
Sample message
複製代碼

如何使用topic

一、在SampleActiveMQApplication中添加：

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

    @Bean
    public JmsListenerContainerFactory<?> jmsListenerContainerTopic(ConnectionFactory activeMQConnectionFactory) {
        DefaultJmsListenerContainerFactory bean = new DefaultJmsListenerContainerFactory();
        bean.setPubSubDomain(true);
        bean.setConnectionFactory(activeMQConnectionFactory);
        return bean;
    }
複製代碼

二、建立TopicConsumer類

@Component
public class TopicConsumer {

    @JmsListener(destination = "sample.topic", containerFactory = "jmsListenerContainerTopic")
    public void receiveTopic1(String text) {
        System.out.println(text);
    }

    @JmsListener(destination = "sample.topic", containerFactory = "jmsListenerContainerTopic")
    public void receiveTopic2(String text) {
        System.out.println(text);
    }
}
複製代碼

三、建立TopicProducer類

@Component
public class TopicProducer implements CommandLineRunner {

    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;

    @Autowired
    private Topic topic;

    @Override
    public void run(String... args) throws Exception {
        send("Topic message");
        System.out.println("Message was sent to the Topic");
    }

    public void send(String msg) {
        this.jmsMessagingTemplate.convertAndSend(this.topic, msg);
    }

}
複製代碼

四、啓動服務 控制檯輸出：

Message was sent to the Topic
Topic message
Topic message
複製代碼

項目地址：SpringBoot2.0整合ActiveMQ

---

本篇到此結束，若是讀完以爲有收穫的話，歡迎點贊、關注、加公衆號【貳級天災】，查閱更多精彩歷史！！！