Golang 中的 JSON RPC 与 AMQP

golang学习网今天将给大家带来《Golang 中的 JSON RPC 与 AMQP》，感兴趣的朋友请继续看下去吧！以下内容将会涉及到等等知识点，如果你是正在学习Golang或者已经是大佬级别了，都非常欢迎也希望大家都能给我建议评论哈~希望能帮助到大家！

我使用“github.com/streadway/amqp”通过队列（RabbitMQ）异步处理请求。

我使用“github.com/gorilla/rpc”来注册我的服务，没有解决方法，但我必须使用丑陋的解决方案将 amqp.Delivery 转换为 http.Request （mux.Server 只能与 http.Request 一起使用） .

我可以使用更优雅的解决方案来完成此任务吗？

我找不到 AMQP 的 JSON RPC 路由器。

解决方案

首先，RPC 和 pub-sub（例如 AMQP）是两种非常不同的野兽；尝试使用一个来实现另一个并不一定是错误或不好的，但它绝对是可疑的，并且意味着设计中的某个地方可能存在故障。因此，我强烈建议从您的业务目标开始重新考虑设计，并确保您尝试实现的实际上是实现所需功能的正确方法。

也就是说，你所描述的基本上是可能的，但你想将你的抽象提升一个层次。尝试通过 AMQP 发送 http.Request 是以一种只会导致更多问题的方式混合协议。实现此行为的更简洁的方法是使用一个处理 http.Requests （正常）的 HTTP 处理程序和一个处理 amqp.Deliverys （正常）的 AMQP 处理程序，并让每个处理程序调用一个共享业务逻辑处理程序它仅处理您的域模型。

因此，您的 HTTP 处理程序将解析 HTTP 请求并将其转换为域对象 - 您没有在问题中提供任何具体细节，因此我将发明类似 myapp.UserRegistration 之类的东西。您的 HTTP 处理程序会将其传递给 myapp.UserService ，它将处理注册用户的实际业务逻辑，它将返回一个结果，然后您将其转换为适当的类型，编组为 JSON，并以以下方式发送回客户端http.Response。 myapp.UserService 对 HTTP 或 AMQP 一无所知；它仅在您自己的域类型上运行。

您的 AMQP 处理程序将拾取一条消息，将其解析为相同的 myapp.UserRegistration 类型，将其传递给相同的 myapp.UserService 处理程序，并获取相同的响应 - 确保 AMQP 和 HTTP 的业务逻辑表现如下同样的方式。然后您会收到响应，并且...好吧，这是 AMQP，因此您无需向客户端发送响应。我不知道你的设置，也许你有另一个队列可以发送响应，也许你不关心响应并且可以丢弃它。这是 RPC 和 AMQP 之间最明显的区别。

这还使您的业务逻辑、HTTP 处理程序和 AMQP 处理程序更易于单独测试，因为您将协议逻辑与业务逻辑分开，即使您不尝试处理多个协议，这也会很有帮助（也就是说，即使您只使用 HTTP，这也不是一个坏主意）

我希望至少能为您提供足够的信息，让您在实施过程中走上正确的轨道。祝你好运！

理论要掌握，实操不能落！以上关于《Golang 中的 JSON RPC 与 AMQP》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！