RabbitMQ实现RPC调用的简单案例

RPC（远程过程调用协议）常见的实现方式包括RESTful API、Dubbo、WebService、Java RMI等。本文介绍了RabbitMQ如何实现RPC调用，并通过一个简单的Spring Boot+RabbitMQ案例进行了说明。

1. 架构

在RPC架构中，客户端发送消息时附带唯一的correlation_id和指定的reply_to回复队列名。服务端从队列接收消息，处理完成后将结果发送到reply_to指定的队列。客户端监听回调队列获取结果，适合处理异步调用。

2. 实践

2.1 客户端开发

创建Spring Boot项目producer作为消息生产者，配置RabbitMQ的基本信息。通过RabbitConfig配置类设置消息发送队列和返回队列，并绑定到交换机。RabbitTemplate被定制以发送消息并设置回调队列，同时设置监听器。在RpcClientController中，使用sendAndReceive方法发送消息并接收服务端返回的结果。

2.2 服务端开发

创建Spring Boot项目consumer作为服务端，配置文件与客户端相同。RabbitConfig类中配置消息队列和交换机绑定。RpcServerController消费消息，提取correlation_id，并使用sendAndReceive方法将处理结果发送回客户端。

2.3 测试

启动RabbitMQ、producer和consumer进行测试。Postman调用producer接口，可以看到服务端返回信息，日志显示消息发送和接收成功。

3. 小结

本文案例展示了如何使用RabbitMQ实现RPC调用，感兴趣的读者可以通过公众号江南一点雨获取案例代码进行实践。

老板：你来弄个团队代码提交规范

了解更多

想要了解更多内容？

查看原文：SpringBoot+RabbitMQ 实现 RPC 调用

文章来源：

江南一点雨

扫码关注公众号