RabbitMQ使用总结（代码）

爱被打了一巴掌 2023-05-28 12:57 13阅读 0赞

## 应用情景： ##

SpringCloud项目中，当一个模块A调用模块B中的方法，使用消息队列RabbitMQ。

## **模块A中需要增加配置：** ##

/**
     * rabbitmq配置
     * Springboot 容器启时将Rabbitmq加载
     * @author Administrator
     *
     */
    @Configuration
    public class RabbitmqConfig {
    
    	@Bean
    	public TopicExchange topicExchange() {
    		return new TopicExchange(UserCenterMq.MQ_EXCHANGE_USER);
    	}
    }

**对应接口：**

/**
     * rabbitmq的exchange和routing key定义
     * 
     * @author Administrator
     *
     */
    public interface UserCenterMq {
    
    	/**
    	 * 用户系统exchange名
    	 */
    	String MQ_EXCHANGE_USER = "user.topic.exchange";
    
    	/**
    	 * 角色删除routing key
    	 */
    	String ROUTING_KEY_ROLE_DELETE = "role.delete";
    }

**发布消息：**

amqpTemplate.convertAndSend(UserCenterMq.MQ_EXCHANGE_USER, UserCenterMq.ROUTING_KEY_ROLE_DELETE, id);

## 模块B中的配置： ##

/**
     * 删除角色时，处理消息
     * 
     * @author Administrator
     *
     */
    @Slf4j
    @Component
    @RabbitListener(queues = RabbitmqConfig.ROLE_DELETE_QUEUE)
    public class RoleDeleteConsumer {
    
    	@Autowired
    	private RoleMenuDao roleMenuDao;
    
    	/**
    	 * 接收到删除角色的消息<br>
    	 * 删除角色和菜单关系
    	 * 
    	 * @param roleId
    	 */
    	@RabbitHandler
    	public void roleDeleteHandler(String roleId) {
    		log.info("接收到删除角色的消息,roleId:{}", roleId);
    		try {
    			roleMenuDao.delete(roleId, null);
    		} catch (Exception e) {
    			log.error("角色删除消息处理异常", e);
    		}
    	}
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，13人围观）

还没有评论，来说两句吧...

相关阅读

相关 RabbitMQ篇：RabbitMQ总结

1、生产者、交换机、队列、消费者关系 [![img][]][img 1] 2、如何保证RabbitMQ的高可用 `RabbitMQ` 有三种模式：单机模式、普通集

Bertha 。/ 2024年03月17日 14:12/ 0 赞/ 94 阅读

相关【RabbitMQ】RabbitMQ自我总结

典型应用场景跨系统的异步通信对接系统等应用内的同步变成异步秒杀，接口发送消息然后自己消费处理基于Pub/Sub模型实现的事件驱动发布/订阅

你的名字/ 2023年10月18日 10:52/ 0 赞/ 170 阅读

相关 RabbitMQ使用总结（代码）

应用情景： SpringCloud项目中，当一个模块A调用模块B中的方法，使用消息队列RabbitMQ。模块A中需要增加配置： / rabb

爱被打了一巴掌/ 2023年05月28日 12:57/ 0 赞/ 14 阅读

相关 RabbitMQ总结

简介 RabbitMQ是一个开源的AMQP实现，服务器端用Erlang语言编写的消息队列，可以做到服务间高度解耦，异步通信性能高，流量削峰 AMQP 即Advance

末蓝、/ 2023年01月09日 12:49/ 0 赞/ 141 阅读

相关 RabbitMQ spring 使用总结

rabbitMQ相关概念不在本文介绍范围，rabbitMQ官网和其他博客都有大量介绍。本文重点内容是spring和rabbit环境搭建以及使用中注意事项总结。 1

柔情只为你懂/ 2022年09月25日 15:18/ 0 赞/ 241 阅读

相关 rabbitmq_在代码中使用

简单点说，分为消息生产者与消费者，两均需要通过地址\+端口\+账号创建一个通道：channel 再通过队列名及exchange名连接一个队列。然后就可以发送或者接受消息了

叁歲伎倆/ 2022年05月24日 01:52/ 0 赞/ 241 阅读

相关 RabbitMQ总结

文章目录 RabbitMQ官方文档中介绍了六种工作模式: 点对点模式工作队列模式(Work

约定不等于承诺〃/ 2022年03月26日 07:28/ 0 赞/ 232 阅读

相关 RabbitMQ总结

目录是什么？为什么要引入消息中间件？系统解耦流量削锋异步调用有那些消息中间件？为什么选择rabbitmq？ AMQP协议是什么？ RabbitM

川长思鸟来/ 2022年01月28日 02:57/ 0 赞/ 384 阅读

相关 python使用pika操作rabbitmq总结(一)

python 连接操作rabbitMQ 主要是使用pika库安装： pip install pika==1.0.1 注意： pika 1.x 与 pika 0.

╰半夏微凉°/ 2021年12月24日 08:15/ 0 赞/ 1127 阅读

相关 RabbitMQ的使用总结

RabbitMQ介绍 ![这里写图片描述][SouthEast] 说明: Consumer （消费者）：使用队列 Queue 从 Exchange 中获取消息的应用

素颜马尾好姑娘i/ 2021年09月13日 23:56/ 0 赞/ 442 阅读