RabbitMQ入门例子

谁践踏了优雅 2023-07-03 06:11 6阅读 0赞

spring boot版本：2.1.10.RELEASE

## 添加依赖 ##

<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>

## 配置文件 ##

#rabbitmq配置
    spring.rabbitmq.host=192.168.xxx.xxx
    spring.rabbitmq.port=5672
    spring.rabbitmq.username=admin
    spring.rabbitmq.password=admin
    spring.rabbitmq.virtual-host=/

## 创建队列 ##

package com.ebook.rabbitmq;
    
    import org.springframework.amqp.core.Queue;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    
    /** * @author:JZ * @date:2020/2/2 */
    
    @Configuration
    public class SenderConfig { 
    
    	//创建名为hello-jz-queue的队列
        @Bean
        public Queue queue() { 
            return new Queue("hello-jz-queue");
        }
    
    }

## 消息发送者 ##

package com.ebook.rabbitmq;
    
    import org.springframework.amqp.core.AmqpTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    
    import java.util.Date;
    
    /** * @author:JZ * @date:2020/2/2 */
    
    @Component
    public class Sender { 
    
        @Autowired
        private AmqpTemplate rabbitTemplate;
    
        public void send() { 
            String msg = "hello" + new Date();
            //用名为hello-jz-queue的队列传递消息
            this.rabbitTemplate.convertAndSend("hello-jz-queue", msg);
        }
    
    }

## 消息接收者 ##

package com.ebook.rabbitmq;
    
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.stereotype.Component;
    
    /** * @author:JZ * @date:2020/2/2 */
    
    @Component
    public class Reciver { 
    	//@RabbitListener注解用来监听hello-jz-queue队列
        @RabbitListener(queues = "hello-jz-queue")
        public void process(String msg) { 
            System.out.println("receive：" + msg);
        }
    
    }

## 测试类 ##

import com.ebook.rabbitmq.RabbitmqHelloApplication;
    import com.ebook.rabbitmq.Sender;
    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(classes = RabbitmqHelloApplication.class)//RabbitmqHelloApplication是启动类
    public class RabbitMqHelloApplicationTests { 
    
    	@Autowired
    	private Sender sender;
    	
    	@Test
    	public void send() throws InterruptedException { 
    		while (true) { 
    			Thread.sleep(1000);
    			this.sender.send();
    		}
    			
    	}
    
    }