java - 根据客户端请求将数据流式传输到 Web 套接字

Question

我正在 Spring boot 中使用 Stomp 开发 WebSocket 应用程序。目前正在开发示例应用程序以了解消息流。

这是我的用例:

• 客户端显示不同数据的图表。例如。总订单、总收入等。
• 用户登录客户端后，可以请求不同的数据类型。
• 收到客户端对特定类型的请求后数据，服务器应该从数据库中提取请求的数据，每 x 分钟生成一个模型并推送到 WebSocket。
• 同样，如果用户使用不同的数据类型发送下一个请求，则相应的数据应每 x 分钟推送一次

** 现在我想澄清一些疑问，以便进一步探索 **

• 对于上述用例，我可以采用哪些不同的选项？
• Kafka 支持 stomp 吗？我目前对Kafka还不熟悉，但我打算探索和学习它。
• 我仍然不清楚是否可以使用 Kafka 作为 stomp 代理？!？
• 我是否能够在使用 kafka 传递特定参数后持续从数据库推送数据集？
• 不使用 Kafka 是否可以实现这一目标？

有人可以解释一下吗？

Answer 1

Kafka不支持STOMP。不，这个问题似乎不需要 Kafka

如果你想使用 Kafka 从数据库中提取数据，你可以找到像 Debezium 这样的解决方案