SpringBoot整合RabbitMQ-创建队列并绑定交换机

pom依赖<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId><version>2.2.5.RELEASE</version></dependency>yml配置文件：rabbitmq:virtual-host: maomao #我自己的虚拟主机port: 5672host: 192.168.6.128 #我自己的虚拟机地址username: rabbitpassword: 123456 #我自己的rabbitmq的密码

import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.TopicExchange;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** rabbitMq 配置类*/
@Configuration
public class RabbitConfig {/*** 计划消息交换机名称*/@Value("${rabbitmq.plan.exchangeName}")public String exchangeName;/*** 计划消息队列*/@Value("${rabbitmq.plan.queueName}")public String queueName;/*** 定义一个的队列* Queue 可以有4个参数*      1.队列名*      2.durable       持久化消息队列 ,rabbitmq重启的时候不需要创建新的队列 默认true*      3.auto-delete   表示消息队列没有在使用时将被自动删除 默认是false*      4.exclusive     表示该消息队列是否只在当前connection生效,默认是false*/@Bean("PLAN_QUEUE")public Queue PLAN_QUEUE() {return new Queue(queueName);}/*** 计划消息交换机* @return*/@Bean("PLAN_TOPIC_EXCHANGE")public TopicExchange TOPIC_EXCHANGE(){return new TopicExchange(exchangeName);}/*** 计划消息队列绑定计划交换机* @param queue 计划队列* @param topicExchange 计划交换机* @return*/@Beanpublic Binding planQueueBinding(@Qualifier("PLAN_QUEUE") Queue queue,@Qualifier("PLAN_TOPIC_EXCHANGE") TopicExchange topicExchange){return BindingBuilder.bind(queue).to(topicExchange).with("");}/*** 序列化机制为JSON* @return*/@Beanpublic MessageConverter messageConverter(){return new Jackson2JsonMessageConverter();}}

SpringBoot整合RabbitMQ-创建队列并绑定交换机相关推荐

SpringBoot整合RabbitMQ消息队列
RabbitMQ 一.RabbitMQ介绍 1.1 现存问题服务调用:两个服务调用时,我们可以通过传统的HTTP方式,让服务A直接去调用服务B的接口,但是这种方式是同步的方式,虽然可以采用Sprin ...
SpringBoot整合RabbitMQ 消息可靠投递、手动ack、延迟队列、死信队列、消息幂等性保障、消息积压
1.消息可靠投递在使用 RabbitMQ 的时候,作为消息发送方希望杜绝任何消息丢失或者投递失败场景.RabbitMQ 为我们提供了两种方式用来控制消息的投递可靠性模式. confirm 确认模式 ...
SpringBoot使用RabbitMQ消息队列
RabbitMQ简介 AMQP,即Advanced Message Queuing Protocol,高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计.消息中间件主要用于组件之间的 ...
RabbitMQ,RabbitMQ 的工作模式,Spring 整合 RabbitMQ,Springboot 整合RabbitMQ
什么是RabbitMQ 1.1 MQ概述 MQ全称 Message Queue(消息队列),是在消息的传输过程中保存消息的容器.多用于分布式系统之间进行通信. ⚫ MQ,消息队列,存储消息的中间件 ⚫ ...
RabbitMq(八) SpringBoot整合RabbitMQ 生产者代码实现
在本章中我们将创建RabbitMQ的生产者工程,并实现生产者端代码实现. springboot整合RabbitMQ生产者工程步骤如下: 创建maven工程引入springboot及RabbitMQ依 ...
Springboot整合一之Springboot整合RabbitMQ
前言目前,springboot已然成为了最热的java开发整合框架,主要是因其简单的配置,并且本身提供了很多与第三方框架的整合,甚至可以让我们在短短的几分钟里就可以搭建一个完整的项目架构.所以,博主 ...
Springboot整合RabbitMQ,包含direct,topic,fanout三种模式的整合
一 RabbitMQ的介绍 RabbitMQ是消息中间件的一种,消息中间件即分布式系统中完成消息的发送和接收的基础软件.这些软件有很多,包括ActiveMQ(apache公司的),RocketMQ(阿 ...
RabbitMQ 第一天基础 6 SpringBoot 整合RabbitMQ
RabbitMQ [黑马程序员RabbitMQ全套教程,rabbitmq消息中间件到实战] 文章目录 RabbitMQ 第一天基础 6 SpringBoot 整合RabbitMQ 6.1 Sprin ...
SpringBoot 整合RabbitMq
SpringBoot 整合RabbitMq (黑马讲义) SpringAMQP是基于RabbitMQ封装的一套模板,并且还利用SpringBoot对其实现了自动装配,使用起来非常方便. SpringA ...

SpringBoot整合RabbitMQ-创建队列并绑定交换机

SpringBoot整合RabbitMQ-创建队列并绑定交换机相关推荐

最新文章

热门文章