我正在 Spring boot 中使用 Stomp 开发 WebSocket 应用程序。目前正在开发示例应用程序以了解消息流。
这是我的用例:
- 客户端显示不同数据的图表。例如。总订单、总收入等。
- 用户登录客户端后,可以请求不同的 数据类型。
- 收到客户端对特定类型的请求后 数据,服务器应该从数据库中提取请求的数据, 每 x 分钟生成一个模型并推送到 WebSocket。
- 同样,如果用户使用不同的数据类型发送下一个请求,则 相应的数据应每 x 分钟推送一次
** 现在我想澄清一些疑问,以便进一步探索 **
- 对于上述用例,我可以采用哪些不同的选项?
- Kafka 支持 stomp 吗?我目前对Kafka还不熟悉,但我打算探索和学习它。
- 我仍然不清楚是否可以使用 Kafka 作为 stomp 代理?!?
- 我是否能够在使用 kafka 传递特定参数后持续从数据库推送数据集?
- 不使用 Kafka 是否可以实现这一目标?
有人可以解释一下吗?
最佳答案
Kafka不支持STOMP。不,这个问题似乎不需要 Kafka
如果你想使用 Kafka 从数据库中提取数据,你可以找到像 Debezium 这样的解决方案
关于java - 根据客户端请求将数据流式传输到 Web 套接字,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/60597025/