我目前正在构建一个restweb服务，它需要以请求/响应模式与kafka通信(我知道Kafka并不是为这个而设计的）。
客户端调用restweb服务。
restweb服务向kafka发布消息
在Kafka的另一边，应用程序使用消息并将响应发布回Kafka
（与#2在同一请求中）restweb服务侦听kakfa并等待对应于请求的响应
restweb服务将响应返回给客户机
第1步到第3步看起来很简单，但我正在努力完成第4步。
我的想法是在每条消息中传播一个id，以便检索与请求相对应的响应。
但是，我很难弄清楚如何在restweb服务上设置侦听器。侦听器如何将消息返回给控制器？
1条答案
按热度按时间m3eecexj1#
我认为最好只为每个用户创建一个主题，然后用户可以向另一个服务发送消息，这样的消息如下：
然后服务只需要推到主题“user.myusername”，然后从web客户端只需要订阅“user.myusername”（使用consumergroup配置，这只用于读取最新消息）。。。
我认为最好的方法就是实现websocket，然后按这种方式推/读；）
再见，再见。