当前位置：首页 > news >正文

小公司不能用 RabbitMQ？

news 2026/5/12 2:29:11

沉默是金，总会发光

大家好，我是沉默

上周，一个同事问：我们为啥不用 RabbitMQ？

“咱们这小系统，用啥消息队列？
直接同步调不行吗？别过度设计！”

这是在技术方案评审会上被主管当场拍死的对话。

RabbitMQ，被否了。
理由很简单：系统小、用户少、没必要。

但真正让我震惊的，是他接下来说的那句话：

“我知道不该这么干，但我还是……周末把 RabbitMQ 集成进了自己的模块。”

这不是叛逆。
这是很多技术人长期压抑后的本能反应。

-01-

我们到底在忍受什么？

不是 RabbitMQ。
而是一坨越来越臃肿、却没人敢动的同步代码。

假设你负责一个电商系统的优惠券发放模块，用户下单成功后，需要：

发放积分
发放优惠券
发送短信通知
更新用户标签
记录行为日志

传统同步调用（你一定写过）

public void afterOrderSuccess(Order order) { pointService.addPoints(order.getUserId(), 100); couponService.sendWelcomeCoupon(order.getUserId()); smsService.sendOrderSuccessSms(order.getPhone()); userTagService.updatePurchaseTag(order.getUserId()); logService.saveOrderLog(order); }

表面看：

简单、直接、好理解。

实际上：

性能瓶颈：5 个 RPC 串行，用户等 5～10 秒
稳定性灾难：短信服务挂了，整个下单流程失败
维护噩梦：每加一个功能，都要改这坨“核心代码”
扩展无解：想优化？只能重构整个链路

你不是在写业务代码，
你是在把所有风险绑在一个方法上赌命。

-02-

RabbitMQ 可以干啥？

用了 RabbitMQ 之后，这段代码会变成什么样？

下单成功，只做一件事

public voida fterOrderSuccess(Order order) { rabbitTemplate.convertAndSend("order.success", order); }

耗时：50ms
用户：立刻看到“下单成功”

消息去哪了？

[下单成功] ↓ RabbitMQ ├─→ 积分服务 ├─→ 优惠券服务 ├─→ 短信服务 ├─→ 标签服务 └─→ 日志服务

每个服务：

自己拿消息
自己慢慢处理
挂了也不拖别人下水

这不是“为了 MQ 而 MQ”，
这是把非核心逻辑，从主流程里解放出来。

-03-

RabbitMQ 的核心概念

1. 生产者 / 消费者

生产者：发消息的人（订单服务）
消费者：拿消息干活的人（积分、短信等）

2. 队列（Queue）

就是一个待办事项清单：

先进先出
消息不丢
消费能力慢，也不会把系统拖死

3. 交换机（Exchange）

消息的“路由大脑”：

类型	类比	场景
Direct	快递单号	精准投递
Fanout	群发邮件	广播通知
Topic	规则匹配	复杂业务

-04-

真正落地的代码

1. 引入依赖

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency>

2. 配置 RabbitMQ

spring: rabbitmq: host:localhost port:5672 username:guest password:guest

3. 发消息（生产者）

@Service public class OrderService {

@Autowiredprivate RabbitTemplate rabbitTemplate;

public void completeOrder(Order order) {

order.setStatus(SUCCESS);

orderRepository.save(order); rabbitTemplate.convertAndSend("order.exchange","order.success",newOrderMessage(order.getId(), order.getUserId())

);

}}

重点：

核心链路只做“必须成功”的事
其他逻辑全部异步

4. 收消息（消费者）

@Component public classCouponConsumer { @RabbitListener(queues = "coupon.queue") public voidhandle(OrderMessage msg) { couponService.sendCoupon(msg.getUserId()); } }

就算这里失败，
下单流程也早就结束了。

-05-

总结