基于数据库条目以编程方式生成新接收器

Question

我正在构建一个模拟城市公共交通网络的小应用程序。这个想法是，每个公交车站都是一个接收器，可以监听其他公交车站的信息，从而计算出公交车出现的时间。具有唯一ID的公交车站存储在数据库中，我需要生成并运行具有唯一ID的确切数量的接收器。我该怎么做？

我的猜测是可以使用Spring Cloud Data Flow完成的任务，该任务将使用（--id）属性启动. jar文件，该属性将注入@Value表示法。但我不明白如何实现它。

也找到了这个，但没用。

Answer 1

您正确理解了一些概念，但您的实现可能需要一些帮助。

因此，Spring云数据流是一个编排引擎，它部署引导应用程序并使用中间件连接它们。

这些应用程序可以是流式应用程序，这意味着它们使用Spring Cloud Stream作为抽象层与中间件（Rabbit或Kafka）html" target="_blank">通信，其核心有三种类型的应用程序：源（数据发射器）、处理器（数据转换）和接收器（数据接收器）

您可以使用数据流将它们组合起来，并部署到运行时（本地、CloudFoundry、K8S、Thread）

所以，是的，SCDF可以用于您的任务，但是您不想为每条总线创建一个接收器，这是在滥用您的资源。

您可以有一个简单的流来捕获来自总线（源）的数据，也许可以进行一些转换并将其沉入数据库

然后，如果您有兴趣处理它们，您可以创建一个监听存储在数据库中的消息的点击。

您可以点击该信息，并让客户端在下游广播该信息（您在每个公交车站的显示器）

例如，您可以只有一个接收器，但有一个websocket，例如每个客户端连接并传递一个id。然后，您可以将接收到的由该id过滤的事件转发到该特定客户端。

这是一种更有效的处理方法。