消息队列这东西，听起来高大上，用起来其实就像个超级快递站。你在项目里是不是也遇到过，用户注册成功了，但发欢迎邮件、送优惠券这些事儿把主流程卡得一愣一愣的？这时候，把“发货”任务扔给RabbitMQ这个快递站，让它去异步处理，主流程立马就流畅了。今天咱们就来聊聊，在Spring Boot项目里，怎么把RabbitMQ这个快递小哥用起来。
一、先把快递站开在你家隔壁：项目配置
想用快递，总得先联系上快递站对吧。第一步就是在你的
pom.xml里引入spring-boot-starter-amqp这个依赖。接着，在application.yml里告诉Spring Boot你家快递站的地址、账号和密码。这步简单，就像在手机App里保存收货地址一样。spring:
rabbitmq:
host: localhost
port: 5672
username: guest
password: guest
virtual-host: /配置完，Spring Boot就会自动帮你创建好连接工厂和
RabbitTemplate这些工具，开箱即用。二、规划快递收发规则：定义交换机和队列
RabbitMQ不是简单的点对点发消息，它有一套“交换机-队列-绑定”的规则。你得先定义好这些基础设施。通常我们在一个配置类里，用
@Bean来声明。比如，定义一个叫
myDirectExchange的直连交换机，一个叫myQueue的队列，然后用一个路由键my.routing.key把它们绑定在一块。这相当于在快递站里设立了一个专门的“电子产品货架”（交换机），并规定只有贴有“手机”标签（路由键）的快递才能放到“A区货架”（队列）上。三、开始寄快递：发送消息流程
发送端是相对轻松的活儿。在你的Service里，注入
RabbitTemplate。当业务触发需要发消息时，比如用户下单成功，调用convertAndSend方法。你需要告诉它三个信息：刚才定义的交换机名字、路由键是啥、以及你要发送的消息体。消息体通常是个JSON字符串。这个方法一执行，你的业务就完成了，剩下的事就交给RabbitMQ了。消息“嗖”的一声就发出去了，至于能不能送到、什么时候送到，发送端基本不用等。
rabbitTemplate.convertAndSend("myDirectExchange", "my.routing.key", orderJson);四、在家门口收快递：处理消息流程
收件方，也就是消费者这边，需要竖起耳朵监听那个特定的队列。我们用
@RabbitListener注解来实现。在一个方法上加上这个注解，并指定监听的队列名。当有消息飞到对应的队列时，这个方法就会被自动触发，消息内容会作为参数传进来。你就在这个方法里写你的业务逻辑，比如解析消息、给用户发短信、更新积分等等。
这里有个关键点，消息确认机制。默认是自动确认，一旦方法执行完（没抛异常），RabbitMQ就认为消息处理成功，会从队列里删除它。但在生产环境，我们强烈建议改为手动确认，在你的逻辑真正成功后，再调用
channel.basicAck来确认。这样可以防止程序崩溃导致消息丢失。五、几个让快递更靠谱的小技巧
光能收发还不够，还得考虑快递会不会丢。有几个配置可以让你的消息更可靠：
-
队列和消息持久化：声明队列和发送消息时，都设置为持久化的，这样服务器重启了，队列和消息还在。
-
生产者确认：在配置里开启
publisher-confirm，这样你就知道消息到底有没有成功到达交换机。 -
消费者重试：在配置里可以设置消费失败后的重试次数和策略，比如隔2秒、5秒、10秒各重试一次，多次失败后再转入死信队列，而不是让消息堵在那。
把这些步骤串起来，就是一个完整的流程：配置连接 -> 声明路由规则 -> 业务触发发送 -> 监听器异步处理。整个下来，你的应用解耦了，响应变快了，系统也显得更从容、更专业。折腾过一次之后，你会发现，这种“甩手掌柜”式的编程，还真有点上瘾。
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 qiqicto@qq.com 举报，一经查实，本站将立刻删除。
