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

What this article shares with you is about how Springboot integrates RabbitMQ. The editor thinks it is very practical, so I share it with you to learn. I hope you can get something after reading this article.

Preparatory work

15min

IDEA

Maven 3.0

Before starting to build the project, the machine needs to install rabbitmq, you can go to the official website to download http://www.rabbitmq.com/download.html, if you are using Mac (programmers should use mac), you can download it like this:

Brew install rabbitmq

Start the server after the installation is complete:

Rabbitmq-server

After starting the server successfully, you can see the following message:

RabbitMQ 3.1.3. Copyright (C) 2007-2013 VMware, Inc.## Licensed under the MPL. See http://www.rabbitmq.com/## # Logs: / usr/local/var/log/rabbitmq/rabbit@localhost.log# / usr/local/var/log/rabbitmq/rabbit@localhost-sasl.log# Starting broker... Completed with 6 plugins. Construction project

To construct a SpringBoot project, its pom file dependence plus spring-boot-starter-amqp start-up dependence:

Org.springframework.boot spring-boot-starter-amqp creates a message receiver

In any message queuing program, you need to create a message receiver to respond to the message sent.

@ Componentpublic class Receiver {private CountDownLatch latch = new CountDownLatch (1); public void receiveMessage (String message) {System.out.println ("Received"); latch.countDown ();} public CountDownLatch getLatch () {return latch;}}

The message receiver is a simple POJO class that defines a method to receive the message. When you register it to receive the message, you can give it any name. Among them, it has a class such as CountDownLatch, which is used to tell the sender that the message has been received, you do not need to implement it in the application, you just need to latch.countDown ().

Create a message monitor and send a message

In the spring program, RabbitTemplate provides all the methods for sending and receiving messages. All you need is a simple configuration:

Need a message listening container

Declare a quene, an exchange, and bind them

A component to send a message

The code listing is as follows:

Package com.forezp;import com.forezp.message.Receiver;import org.springframework.amqp.core.Binding;import org.springframework.amqp.core.BindingBuilder;import org.springframework.amqp.core.Queue;import org.springframework.amqp.core.TopicExchange;import org.springframework.amqp.rabbit.connection.ConnectionFactory;import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;import org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.context.annotation.Bean @ SpringBootApplicationpublic class SpringbootRabbitmqApplication {final static String queueName = "spring-boot"; @ Bean Queue queue () {return new Queue (queueName, false);} @ Bean TopicExchange exchange () {return new TopicExchange ("spring-boot-exchange");} @ Bean Binding binding (Queue queue, TopicExchange exchange) {return BindingBuilder.bind (queue) .to (exchange) .with (queueName) } @ Bean SimpleMessageListenerContainer container (ConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) {SimpleMessageListenerContainer container = new SimpleMessageListenerContainer (); container.setConnectionFactory (connectionFactory); container.setQueueNames (queueName); container.setMessageListener (listenerAdapter); return container;} @ Bean MessageListenerAdapter listenerAdapter (Receiver receiver) {return new MessageListenerAdapter (receiver, "receiveMessage") } public static void main (String [] args) {SpringApplication.run (SpringbootRabbitmqApplication.class, args);}}

Create a test method:

@ Componentpublic class Runner implements CommandLineRunner {private final RabbitTemplate rabbitTemplate; private final Receiver receiver; private final ConfigurableApplicationContext context; public Runner (Receiver receiver, RabbitTemplate rabbitTemplate, ConfigurableApplicationContext context) {this.receiver = receiver; this.rabbitTemplate = rabbitTemplate; this.context = context;} @ Override public void run (String... Args) throws Exception {System.out.println ("Sending message..."); rabbitTemplate.convertAndSend (Application.queueName, "Hello from RabbitMQ!"); receiver.getLatch () .await (10000, TimeUnit.MILLISECONDS); context.close ();}}

Start the program and you will find that the console prints:

Sending message...Received above is how Springboot integrates RabbitMQ. The editor believes that there are some knowledge points that we may see or use in our daily work. I hope you can learn more from this article. For more details, please follow the industry information channel.

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.