java—在restweb服务内的resquest/response场景中使用kafka

xytpbqjk  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(357)

我目前正在构建一个restweb服务,它需要以请求/响应模式与kafka通信(我知道Kafka并不是为这个而设计的)。
客户端调用restweb服务。
restweb服务向kafka发布消息
在Kafka的另一边,应用程序使用消息并将响应发布回Kafka
(与#2在同一请求中)restweb服务侦听kakfa并等待对应于请求的响应
restweb服务将响应返回给客户机
第1步到第3步看起来很简单,但我正在努力完成第4步。
我的想法是在每条消息中传播一个id,以便检索与请求相对应的响应。
但是,我很难弄清楚如何在restweb服务上设置侦听器。侦听器如何将消息返回给控制器?

m3eecexj

m3eecexj1#

我认为最好只为每个用户创建一个主题,然后用户可以向另一个服务发送消息,这样的消息如下:

{
user:"myUserName"
data:"data of message"
}

然后服务只需要推到主题“user.myusername”,然后从web客户端只需要订阅“user.myusername”(使用consumergroup配置,这只用于读取最新消息)。。。
我认为最好的方法就是实现websocket,然后按这种方式推/读;)
再见,再见。

相关问题