SpringBoot 整合 RabbitMQ 测试发送接收消息

蔚落 2024-04-18 13:12 83阅读 0赞

### 前提：安装好RabbitMQ，配置[Exchanges][]\---[Queues][] ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNTY2Nzcy_size_16_color_FFFFFF_t_70][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNTY2Nzcy_size_16_color_FFFFFF_t_70 1][]

### 引入依赖： ###

<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-amqp</artifactId>
    		</dependency>

### 实体类Person：( 无参构造器不能少 )否则报错--jackson的反序列化需要无参构造函数 ###

package com.vortex.rabbitmqtest.bean;
    
    
    public class Person {
        private String name;
        private String age;
        private String address;
        public Person() {
        }
    
        public Person(String name, String age, String address) {
            this.name = name;
            this.age = age;
            this.address = address;
        }
    
        public String getName() {
            return name;
        }
    
        public void setName(String name) {
            this.name = name;
        }
    
        public String getAge() {
            return age;
        }
    
        public void setAge(String age) {
            this.age = age;
        }
    
        public String getAddress() {
            return address;
        }
    
        public void setAddress(String address) {
            this.address = address;
        }
    
        @Override
        public String toString() {
            return "person{" +
                    "name='" + name + '\'' +
                    ", age='" + age + '\'' +
                    ", address='" + address + '\'' +
                    '}';
        }
    }

### RabbitMQ配置类：（发送的消息 json 序列化） ###

package com.vortex.rabbitmqtest.config;
    
    import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
    import org.springframework.amqp.support.converter.MessageConverter;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    @Configuration
    public class MyAMQPConfig {
    
        @Bean
        public MessageConverter messageConverter(){
            return new Jackson2JsonMessageConverter();
        }
    }

### application.properties 配置文件： ###

spring.rabbitmq.host=192.168.25.146
    spring.rabbitmq.username=guest
    spring.rabbitmq.password=guest

### 测试类：（单点发送） ###

package com.vortex.rabbitmqtest;
    
    import com.vortex.rabbitmqtest.bean.person;
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.amqp.rabbit.core.RabbitTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.test.context.junit4.SpringRunner;
    import sun.font.TrueTypeFont;
    
    
    
    @RunWith(SpringRunner.class)
    @SpringBootTest
    public class RabbitmqtestApplicationTests {
    
    	@Autowired
    	RabbitTemplate rabbitTemplate;
    
    
    	@Test
    	public void test01(){
    		//交换器-exchange.direct 发送对象到 vortex
    		rabbitTemplate.convertAndSend("exchange.direct","vortex",new Person("typ","20","beijing"));
    	}
    	
    
    }

### 这是发送后的截图：（队列中有一个消息） ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNTY2Nzcy_size_16_color_FFFFFF_t_70 2][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNTY2Nzcy_size_16_color_FFFFFF_t_70 3][]

###  现在来接收数据： ###

@Test
    	public void test02(){
    		//接收
    		Person o = (Person) rabbitTemplate.receiveAndConvert("vortex");
    		System.out.println(o.getClass());
    		System.out.println(o);
    	}

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNTY2Nzcy_size_16_color_FFFFFF_t_70 4][]

###  队列中的消息被消费 ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNTY2Nzcy_size_16_color_FFFFFF_t_70 5][]

### fanout--订阅模式 ###

@Test
    	public void test03(){
    		rabbitTemplate.convertAndSend("exchange.fanout","",new Person("lpl","8","beijing"));
    	}

###  绑定的队列都接收到消息： ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNTY2Nzcy_size_16_color_FFFFFF_t_70 6][]

[Exchanges]: http://192.168.25.146:15672/#/exchanges
[Queues]: http://192.168.25.146:15672/#/queues
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNTY2Nzcy_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/1a837f695f9e44dda82d4d2202460975.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNTY2Nzcy_size_16_color_FFFFFF_t_70 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/d86d0e9b2abb491abdb10e6e158b670f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNTY2Nzcy_size_16_color_FFFFFF_t_70 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/31492ba3b5a742cf85b512ba98af71a7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNTY2Nzcy_size_16_color_FFFFFF_t_70 3]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/6f8b9dd471b043049881d5c5d103844b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNTY2Nzcy_size_16_color_FFFFFF_t_70 4]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/ef5f138b3ba046b2aa6a5a02526d49ee.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNTY2Nzcy_size_16_color_FFFFFF_t_70 5]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/60727f7f20374a1a9f3bf1438206a877.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNTY2Nzcy_size_16_color_FFFFFF_t_70 6]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/77dc2574a3fb4ad88db81974e51bbab4.png