Shulou(Shulou.com)06/02 Report--

Springboot in how to integrate ActiveMQ, many novices are not very clear about this, in order to help you solve this problem, the following editor will explain in detail for you, people with this need can come to learn, I hope you can gain something.

1. First create a new springboot project (the new process is brief). The springboot version of this article is 2.1.1.RELEASE.

2. Add activemq dependencies to the pom.xml file

Org.springframework.boot spring-boot-starter-activemq org.apache.activemq activemq-pool org.messaginghub pooled-jms

The dependencies related to connection pooling can not be configured.

3. Configure application.properties or application.yml this article takes application.properties as an example

Spring.activemq.broker-url=tcp://localhost:61616spring.activemq.user=adminspring.activemq.password=admin# activemq provides queue mode by default. To use topic mode, you need to configure the following configuration # spring.jms.pub-sub-domain=true#true means to use built-in MQ,false, then connect to the server spring.activemq.in-memory=false#true means to use connection pooling When false, create a connection for each piece of data sent spring.activemq.pool.enabled=true# connection pool maximum number of connections spring.activemq.pool.max-connections=10# idle connection expiration time, default is 30 seconds spring.activemq.pool.idle-timeout=15000

Add connection pool pool related dependencies to the pom file when spring.activemq.pool.enabled=true, and do not add connection pool pool related dependencies when false.

If you use connection pooling pool configuration, pay attention to two dependent configurations, otherwise startup fails.

The structure of the project is as follows

The Demo code is as follows

Package com.example.acmpp.config;import javax.jms.Queue;import javax.jms.Topic;import org.apache.activemq.command.ActiveMQQueue;import org.apache.activemq.command.ActiveMQTopic;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;@Configurationpublic class BeanConfig {/ / defines the queue @ Bean public Queue queue () {return new ActiveMQQueue ("ActiveMQQueue") where messages are stored } / / define the queue @ Bean public Topic topic () {return new ActiveMQTopic ("ActiveMQTopic");}}

Message producer code

Import javax.jms.Queue;import javax.jms.Topic;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.jms.core.JmsMessagingTemplate;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController;/* message producer * / @ RestControllerpublic class ProviderController {@ Autowired private JmsMessagingTemplate jmsMessagingTemplate; @ Autowired private Queue queue; @ Autowired private Topic topic / * message producer Queue mode * * / @ RequestMapping ("/ sendQ") public void sendQ (String msg) {/ / method 1: add a message to the message queue jmsMessagingTemplate.convertAndSend (queue, msg) / / method 2: this method does not require manual creation of queue, the system will create its own queue named test / / jmsMessagingTemplate.convertAndSend ("testQ", msg) } / * message producer Topic mode * @ param msg * / @ RequestMapping ("/ sendT") public void sendT (String msg) {/ / specify the destination and content System.out.println of the message ("@" + msg) This.jmsMessagingTemplate.convertAndSend (this.topic, msg);}}

Message consumer code

Import org.springframework.beans.factory.annotation.Autowired;import org.springframework.jms.annotation.JmsListener;import org.springframework.jms.core.JmsMessagingTemplate;import org.springframework.messaging.handler.annotation.SendTo;import org.springframework.stereotype.Component;/** * message consumers * @ author FFF * * / @ Componentpublic class ConsumerService {@ Autowired private JmsMessagingTemplate jmsMessagingTemplate / * consume ActiveMQQueue * / / configure the queue for consumer monitoring using JmsListener, where name is the received message @ JmsListener (destination = "ActiveMQQueue") / / SendTo will write the data returned by this method to OutQueue. @ SendTo ("SQueue") public String handleMessage (String name) {System.out.println ("ActiveMQQueue successfully accepted Name" + name); return "ActiveMQQueue successfully accepted Name" + name } / * * consumption ActiveMQ.DLQ * / / configure the queue monitored by consumers using JmsListener, where name is the received message @ JmsListener (destination = "ActiveMQ.DLQ") public void DLQ (String name) {System.out.println ("ActiveMQ.DLQ successfully accepts Name==" + name) } / * * consumption SQueue * / / configure the queue monitored by consumers using JmsListener, where name is the received message @ JmsListener (destination = "SQueue") public void SQueue (String name) {System.out.println ("SQueue successfully accepts Name==" + name) } / * * consumption testQ * / / configure the queue monitored by consumers using JmsListener, where name is the received message @ JmsListener (destination = "testQ") public void testQMessage (String name) {System.out.println ("testQ successfully accepts Name" + name) } / * * Consumer topic * * / / configure the queue monitored by consumers using JmsListener, where name is the received message @ JmsListener (destination = "ActiveMQTopic") public void topicMessage (String name) {System.out.println ("topicMessage successfully accepted Name" + name);}}

Is it helpful for you to read the above content? If you want to know more about the relevant knowledge or read more related articles, please follow the industry information channel, thank you for your support.

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.