Spring Boot实现 RabbitMQ教程【1】

1.创建SpringBoot项目,项目结构如下：

2.在pom.xml中添加Maven依赖

<!-- rabbitMQ -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId><version>1.5.2.RELEASE</version>
</dependency>

3.在配置文件中添加RabbitMQ的配置信息。

spring.rabbitmq.host=127.0.0.1
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

4.创建一个队列类

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class QueueConfig {@Beanpublic Queue queue(){return new Queue("hello_rabbit");}
}

5.实现一个发送消息的类

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;import java.util.Date;
import java.util.Random;@Component
public class SendMQ {@Autowiredprivate AmqpTemplate amqpTemplate;public void send(){String mq = "Hello RabbitMQ" + new Date();this.amqpTemplate.convertAndSend("hello_rabbit" , mq);String ms = "Hello RabbitMQ" + new Random();this.amqpTemplate.convertAndSend("hello_rabbit" , ms);}
}

6.定义一个消息接收类

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;@Component
public class ReceiveMQ {@RabbitListener(queues = "hello_rabbit")public void process(String mag){System.out.println("接收的消息：："+mag);}}

7.定义测试类

import com.hw.rabbit.config.SendMQ;
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 = RabbitMQApplication.class)
public class RabbitMQApplicationTests {@Autowiredprivate SendMQ sendMQ;@Testpublic void contextLoads() {sendMQ.send();}
}

注意：4,5,6中的 hello_rabbit 要一致。

8.启动项目，在控制台输出如下：

在地址栏输入：127.0.0.1:15672，登录RabbitMQ ，在Queues模块下有队列如下：

Spring Boot实现 RabbitMQ教程【1】相关推荐

Spring Boot WebFlux 上手教程
Spring Boot WebFlux 上手教程背景大家都知道,Spring Framework 是 Java/Spring 应用程序跨平台开发框架,也是 Java EE(Java Enterpr ...
spring boot整合RabbitMQ —— 十分钟急速上手
安装运行rabbitmq 1.docker安装rabbitmq: docker run -it --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq ...
Spring Boot 整合 RabbitMQ 实现
Spring Boot 整合 RabbitMQ 实现 1. 开发环境搭建 1.1 pom配置 1.2 application.yml配置 2. 消费者模块(springboot-rabbitmq-co ...
Spring Boot： Spring Boot 整合 RabbitMQ
前言 RabbitMQ 是一个消息队列,说到消息队列,大家可能多多少少有听过,它主要的功能是用来实现应用服务的异步与解耦,同时也能起到削峰填谷.消息分发的作用. 消息队列在比较主要的一个作用是用来做应 ...
Spring Boot 操作 Redis教程
Spring Boot 操作 Redis教程在 Redis 出现之前,我们的缓存框架各种各样,有了 Redis ,缓存方案基本上都统一了使用 Java 操作 Redis 的方案很多,Jedis 是 ...
Spring Boot 入门实战教程
Spring Boot 2.0 入门实战教程开发环境:JDK1.8或以上源码下载:https://pan.baidu.com/s/1Z771VDiuabDBJJV445xLeA 欢迎访问我的个人博 ...
Spring Boot 2 快速教程：WebFlux 快速入门（二）
2019独角兽企业重金招聘Python工程师标准>>> 摘要: 原创出处 https://www.bysocket.com 「公众号:泥瓦匠BYSocket 」欢迎关注和转载,保留摘 ...
Spring Boot 集成 RabbitMq 实战操作（二）
本人学习新框架方法. 一.先学习框架基本知识,也就是看这本书的前三章,了解基本概念.比如这个Rabbitmq,我会先看一些概念,比如,交换机,路由器,队列,虚拟机. 二.然后写代码,写demo,有哪些 ...
【消息中间件】Spring Boot整合RabbitMQ
简介在Spring项目中,可以使用Spring-Rabbit去操作RabbitMQ 尤其是在spring boot项目中只需要引入对应的amqp启动器依赖即可,方便的使用RabbitTemplate ...

Spring Boot实现 RabbitMQ教程【1】

Spring Boot实现 RabbitMQ教程【1】相关推荐

最新文章

热门文章