当前位置: 首页 > 知识库问答 >
问题:

大数据微服务之间的通信

濮波
2023-03-14

我正在构建一个基于Spring云的微服务ML管道。我有一个数据摄取服务,它(当前)从SQL接收数据,这些数据需要被预测服务使用。

普遍的共识是写入应该使用kafka/Rabbitmq使用基于异步消息的通信。

我不确定的是如何编排这些服务?

我是否应该使用API网关来调用启动管道的摄取?

共有1个答案

鲁浩言
2023-03-14

通常,您会构建一个带有restendpoint(Spring Boot)的服务来接收数据。然后,可以在负责路由的api网关(Zuul、Spring Cloud)后面多次部署这个服务。这是默认的spring cloud微服务设置。然后,摄取服务可以转换数据,并将其生成到RabbitMQ或Kafka。我推荐使用Spring Cloud Stream与队列进行交互,它是RabbitMQ和Kafka之上的抽象,可以使用启动器/绑定器进行配置。

Spring Cloud Dataflow是一种用于编排队列的声明性方法,并且还负责在多个云服务/平台上进行部署。也可以使用此功能,但可能会增加用例的额外复杂性。

 类似资料:
  • 当前体系结构: 问题: 我们在前端和后端层之间有一个两步流程。 null 微服务2(MS2)需要验证I1的完整性,因为它来自前端。如何避免对MS1进行新的查询?最好的办法是什么? 我试图优化的流删除了步骤1.3和2.3 流程1: null 流程2: 2.1用户X已在本地/会话存储中存储了数据(MS2_Data) 2.2用户X在MS1上保留数据(MS2_Data+MS1_Data) 2.3 MS1使

  • 我正在设计一个微服务架构中的评审分析平台。 应用程序如下所示; null null 问题在于,验证服务需要获取site-a的所有评论,应用验证规则并生成错误(如果有的话)。我知道共享数据库模式和实体打破了微服务体系结构。 一个可能的解决方案是 每当验证服务需要对站点进行审查时,它就会请求网关,网关会将请求重定向到审查服务并采取响应。 这种方法的两个可能缺点是 验证服务是否知道网关?是否会带来依赖?

  • 我将非常感谢任何答复以及文章,在您的意见可能有助于这里。提前谢谢你。

  • 我目前正在做一个Spring Boot微服务项目。我已经创建了服务,每个服务都是单独运行的。有了这个,我需要一些服务来与其他服务进行通信。我怎样才能做到这一点? 我看到了一些关于这一点的博客,它们使用Netflix、Eureka云服务器来实现这一点。有没有什么方法可以在本地环境中实现这一点,而不使用云服务器?

  • 本文向大家介绍微服务之间如何独立通讯的?相关面试题,主要包含被问及微服务之间如何独立通讯的?时的应答技巧和注意事项,需要的朋友参考一下 同步通信:dobbo通过 RPC 远程过程调用、springcloud通过 REST 接口json调用 等。