SpringBoot整合RabbitMQ并入门使用

柔情只为你懂 2022-01-26 16:09 221阅读 0赞

### 文章目录 ###

*  安装
 *  1.依赖
 *  2.配置
 *  3.实战中使用

# 安装 #

![在这里插入图片描述][20190529150727607.png]  
准备这些安装包，然后一个一个安装上，然后安装插件

rabbitmq开启web管理后台：http://blog.csdn.net/mighty13/article/details/51802942
    	rabbitmq自带管理后台，安装后需要配置开启
    	进入rabbitmq安装目录中的sbin目录执行
    	rabbitmq-plugins enable rabbitmq_management
    	重启rabbitmq服务生效
    	打开http://localhost:15672/即可看到管理后台
    	用户名密码均为guest
    
    STOMP plugin：http://blog.csdn.net/azhegps/article/details/53815283
    	rabbitmq-plugins enable rabbitmq_web_stomp  
    	rabbitmq-plugins enable rabbitmq_web_stomp_examples

# 1.依赖 #

<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-amqp</artifactId>
    		</dependency>
    		
    		<dependency>
    		    <groupId>org.springframework.boot</groupId>
    		    <artifactId>spring-boot-starter-websocket</artifactId>
    		</dependency>
    		<dependency>
    		    <groupId>com.rabbitmq</groupId>
    		    <artifactId>amqp-client</artifactId>
    		</dependency>
    		<dependency>
    		    <groupId>io.projectreactor</groupId>
    		    <artifactId>reactor-net</artifactId>
    		    <version>2.0.8.RELEASE</version>
    		</dependency>

# 2.配置 #

spring.rabbitmq.host: 127.0.0.1
    spring.rabbitmq.port: 15672
    spring.rabbitmq.username: guest
    spring.rabbitmq.password: guest
    spring.rabbitmq.virtual-host: /
    # 消息发送到交换机确认机制,是否确认回调
    spring.rabbitmq.publisher-confirms: true 
    spring.rabbitmq.publisher-returns: true

# 3.实战中使用 #

注入template

@Autowired
    private AmqpTemplate amqpTemplate;
    
    //发送消息
    amqpTemplate.convertAndSend("topic","queue","内容");
    
    //接收消息
    @RabbitListener(queues="queue")    //监听器监听指定的Queue
    public void processC(String str) { 
        System.out.println("你收到的消息是:"+str);
    }

[20190529150727607.png]: /images/20220126/56e372efc297476380c4b3327dc17fec.png