如何解决如何使用gin处理异步请求-回复架构?
我正在尝试使用杜松子酒构建一个API,该API支持带有ZMQ消息传递组件的POST请求。
我当前的方法是创建一个ZMQ Router
套接字,该套接字负责向其他后端组件传递消息。
我将onMessageReceived()
回调传递给ZMQ Router
,该回调应在从套接字(异步)接收到消息时调用。
我这样处理POST请求:
r.POST("/update",func(c *gin.Context) {
// business logic
a.ZMQHandler.Send(updateMsg)
// receive logic,depending on response from ZMQ
c.JSON(200,gin.H{})
})
我的问题是,我希望既能支持对外部组件的异步请求,又能在收到ZMQ答复后将响应发送到HTTP客户端。
在onMessageReceived()
回调中,我可以手动发送HTTP响应,但是到那时,我不再在gin.Context
范围内进行回复了。
我觉得这应该是一种相对常见的功能-我的方法是否错误?谢谢!
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。