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

标签 java spring spring-boot websocket apache-kafka

我正在 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/

相关文章:

Java日期计算结果截断小数位

java - 静态成员有助于提高内存效率吗?

Spring MVC-Joda 日期时间错误消息无效日期

java - SpringBoot2 配置 JOOQ MariaDB : "required a bean of type ' javax. sql.DataSource' 找不到”

Java : Map and set to Uppercase

java - Java 中的自动文件/输入流处理

java - SolrJ 从 solr 查询中获取所有结果文档的文档分数

spring - spring Controller 中的单元测试响应状态代码

java - 在Interceptor中访问Spring的RequestEntity

java - @jsonRootName 不适用于 Spring Boot 启动器 hatoas