SpringBoot + RabbitMQ 使用Demo

2019-11-06 07:11:06

字体：大中小

来源：转载

供稿：网友

SPRing-Boot 使用RabbitMQ

1.安装&运行 rabbitmq

安装服务器 :brew install rabbitmq运行Server:rabbitmq-server

安装完之后:

应用端口:15672服务端口:5672

如果没有此命令，可以去/usr/local/Cellar/rabbitmq/3.6.6目录下找rabbitmq-server命令（具体目录，安装的时候会有）参考 rabbitmq 安装与配置

2. 搭建环境

2.1 引入包

compile('org.springframework.boot:spring-boot-starter-amqp')

2.2 建立接收者

import java.util.concurrent.CountDownLatch;import org.springframework.stereotype.Component;@Componentpublic class Receiver { private CountDownLatch latch = new CountDownLatch(1); public void receiveMessage(String message) { System.out.println("Received <" + message + ">"); latch.countDown(); } public CountDownLatch getLatch() { return latch; }}

2.3 建立监听者

import com.igouc.receiveMQ.Receiver;import org.springframework.amqp.core.*;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.autoconfigure.SpringBootapplication;import org.springframework.context.annotation.Bean;@SpringBootApplicationpublic class ConfigMq { final static String QueueName = "test-rmq"; final static String ExchangeName = "test"; @Bean Queue queue(){ return new Queue(QueueName, false); } @Bean TopicExchange exchange(){ return new TopicExchange(ExchangeName); } @Bean Binding binding(Queue queue, TopicExchange topicExchange){ return BindingBuilder.bind(queue).to(topicExchange).with(ExchangeName); } @Bean MessageListenerAdapter listenerAdapter(Receiver receiver) { return new MessageListenerAdapter(receiver, "receiveMessage"); } @Bean SimpleMessageListenerContainer container(ConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) { SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(); container.setConnectionFactory(connectionFactory); container.setQueueNames(QueueName); container.setMessageListener(listenerAdapter); return container; }}

2.4 建立发送者

import com.igouc.receiveMQ.Receiver;import org.springframework.amqp.rabbit.core.RabbitTemplate;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.CommandLineRunner;import org.springframework.stereotype.Component;import java.util.concurrent.TimeUnit;@Componentpublic class SendMQ implements CommandLineRunner{ final static String QueueName = "test-rmq"; final static String ExchangeName = "test"; @Autowired private RabbitTemplate rabbitTemplate; @Autowired private Receiver receiver; @Override public void run(String... args) throws Exception { System.out.println("start send message ...."); rabbitTemplate.convertAndSend(QueueName, "Hello From SendMQ"); //像 receiver.getLatch().await(10000, TimeUnit.MILLISECONDS); }}