SpringBoot 集成RabbitMQ集群及简单操作

我就是我 2022-03-09 09:42 586阅读 0赞

RabbitMQ集群搭建参考：[https://blog.csdn.net/weixin\_42465125/article/details/88368784][https_blog.csdn.net_weixin_42465125_article_details_88368784]

在Spring官网的生成器，生成两个Maven工程：

![20190312210610749.png][]

### rabbit-producer-demo： ###

Pom文件生成者和消费者一致

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    	<modelVersion>4.0.0</modelVersion>
    	<parent>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-parent</artifactId>
    		<version>2.1.3.RELEASE</version>
    		<relativePath/> 
    	</parent>
    	<groupId>cn.cuit.rabbit</groupId>
    	<artifactId>rabbit-producer-demo</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<name>rabbit-producer-demo</name>
    	<description>Demo project for Spring Boot</description>
    
    	<properties>
    		<java.version>1.8</java.version>
    	</properties>
    
    	<dependencies>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-amqp</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
    
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    			<scope>test</scope>
    		</dependency>
    	</dependencies>
    
    	<build>
    		<plugins>
    			<plugin>
    				<groupId>org.springframework.boot</groupId>
    				<artifactId>spring-boot-maven-plugin</artifactId>
    			</plugin>
    		</plugins>
    	</build>
    
    </project>

properties文件也是一致的：

spring.application.name=spirng-boot-rabbitmq-producer
    
    # 配置集群的VIP # 192.168.174.150:5672
    spring.rabbitmq.addresses=192.168.174.150:5672
    # 配置真实IP也可以
    #spring.rabbitmq.addresses=192.168.174.140:5672,192.168.174.141:5672     
    
    spring.rabbitmq.username=cuit
    spring.rabbitmq.password=cuit
    
    spring.rabbitmq.connection-timeout=15000
    
    # confirm模式
    spring.rabbitmq.publisher-confirms=true
    # return机制
    spring.rabbitmq.publisher-returns=true
    # 与return机制结合配置次属性
    spring.rabbitmq.template.mandatory=true

配置一个队列：

package cn.cuit.rabbit.one2one.producer;
    
    import org.springframework.amqp.core.Queue;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    @Configuration
    public class RabbitConfig {
    	@Bean
    	public Queue queue() {
    		return new Queue("q_hello");
    	}
    }

消息生成者：

package cn.cuit.rabbit.one2one.producer;
    
    import java.text.SimpleDateFormat;
    import java.util.Date;
    
    import org.springframework.amqp.core.AmqpTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    
    /**
     * 简单队列
     *
     * 更多例子参考
     * https://blog.csdn.net/hellozpc/article/details/81436980#8SpringbootRabbitMQ_1267
     * https://blog.csdn.net/aa1215018028/article/details/81325082
     */
    @Component
    public class HelloSender {
    	@Autowired
    	private AmqpTemplate rabbitTemplate;
    
    	public void send() {
    		String date = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());// 24小时制
    		String context = "hello " + date;
    		System.out.println("Sender : " + context);
    		// 简单对列的情况下routingKey即为Q名
    		this.rabbitTemplate.convertAndSend("q_hello", context);
    	}
    }

生产者发送消息测试:

package cn.cuit.rabbit.one2one.producer;
    
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.test.context.junit4.SpringRunner;
    
    @RunWith(SpringRunner.class)
    @SpringBootTest
    public class RabbitMqHelloTest {
    
    	@Autowired
    	private HelloSender helloSender;
    
    	@Test
    	public void hello() throws Exception {
    		helloSender.send();
    	}
    }

运行测试，然后观察在RabbitMQ的web界面去看看：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjQ2NTEyNQ_size_16_color_FFFFFF_t_70][]

可以看到我们刚刚代码中创建的q\_hello队列

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjQ2NTEyNQ_size_16_color_FFFFFF_t_70 1][]

查看消息：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjQ2NTEyNQ_size_16_color_FFFFFF_t_70 2][]

下面来消费端是否可以在RabbitMQ中获取到这个消息

消费端：

package cn.cuit.rabbit.one2one.consumer;
    
    import org.springframework.amqp.rabbit.annotation.RabbitHandler;
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.stereotype.Component;
    
    @Component
    @RabbitListener(queues = "q_hello")
    public class HelloReceiver {
    
    	@RabbitHandler
    	public void process(String hello) {
    		System.out.println("Receiver  : " + hello);
    	}
    }

启动类：

package cn.cuit.rabbit;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    
    @SpringBootApplication
    public class RabbitConsumerDemoApplication {
    
    	public static void main(String[] args) {
    		SpringApplication.run(RabbitConsumerDemoApplication.class, args);
    	}
    
    }

启动消费端SpringBoot程序，观察控制台输出：

![20190312212631948.png][]

OK的，消费者从RabbitMQ中获取到刚刚的消息了，RabbitMQ有好几种发送消息的模式和消费消息的模式，更多例子参考代码中的链接

\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\* 不积跬步无以至千里，不积小流无以成江海 \*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*

[https_blog.csdn.net_weixin_42465125_article_details_88368784]: https://blog.csdn.net/weixin_42465125/article/details/88368784
[20190312210610749.png]: /images/20220309/c68cc8b89ef84599917493dcf1c88f79.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjQ2NTEyNQ_size_16_color_FFFFFF_t_70]: /images/20220309/f6430ea443ac45f69ca1c1fdd571e4d7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjQ2NTEyNQ_size_16_color_FFFFFF_t_70 1]: /images/20220309/e2aef125296442089df899f30ddde584.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjQ2NTEyNQ_size_16_color_FFFFFF_t_70 2]: /images/20220309/6e95b16daa0b4f23bc6f4c56ddd4b83e.png
[20190312212631948.png]: /images/20220309/a1063f35b402403ab6049a016c7af87e.png