内部和外部沟通
正如Lagom设计理念中所讨论的,服务应该是隔离的和自治的。这样的服务通过在网络上发送消息来相互通信(服务间)。为了获得性能和弹性,通常会在同一节点上运行同一服务的多个实例,并且此类服务内通信也将通过网络进行。此外,第三方和/或旧式系统也可能会消耗或为您的微服务系统提供信息。
以下主题更详细地讨论了这些通信路径:
微服务系统内的通信
尽管原则上相似,但是服务间和服务内通信具有非常不同的需求,并且Lagom提供了多种实现选项。服务间通信必须使用松耦合的协议和消息格式来保持隔离和自治。协调不同服务之间的变更可能既困难又昂贵。您可以利用以下优势在系统中实现此目的:
服务调用(同步或异步(流))允许服务使用已发布的API和标准协议(HTTP和WebSockets)相互通信。
将消息发布到代理(例如Apache Kafka)会进一步使通信脱钩。Lagom的Message Broker API提供了至少一次的语义。如果新实例开始发布信息,则其消息将添加到先前发出的事件中。如果新实例订阅了主题,则它们将接收过去,现在和将来的所有事件(只要已订阅)。
单个服务(统称为群集)的节点需要较少的去耦。它们共享相同的代码,并且由一个团队或个人作为一个集合一起进行管理。因此,服务内通信可以利用开销较小,性能更好的机制。例如:
许多Lagom组件在内部使用Akka远程处理,您可以在服务中直接使用它。
-
分布式发布-订阅可用于节点之间的低延迟,最多一次消息传递。限制包括:
网络中断可能导致消息丢失。
当新实例启动,加入集群并进行预订时,它将不会接收在预订之前发送的消息。
数据库和其他持久性存储可以看作是服务节点通信的另一种方式。对于使用持久实体的微服务,Lagom鼓励事件流式传输,它还利用异步通信的优势并通过事件日志提供保证。
该图说明了分布在三个服务器上的Lagom系统中服务间和服务内通信中的每种类型。在该示例中,订购服务发布到一个或多个Kafka主题,而用户服务订阅以消费信息。用户服务使用Akka远程处理与其他用户服务实例(集群成员)进行通信。运送服务和用户服务通过在服务呼叫中流式传输信息来交换信息。
与微服务系统外部的各方进行通信
Lagom提倡使用异步通信,而不必在必要时阻止使用同步通信。第三方可以从发布到Broker API的Lagom服务异步获取数据,并享有至少一次保证。Lagom服务还公开了一个API,供第三方同步交换数据。通常将其映射到HTTP。Lagom服务API还通过websocket支持将数据流传输到外部客户端。有关更多信息,请参见ServiceDescriptors。
与外界的交互可能意味着通过互联网使用服务的客户,例如浏览器,移动应用或物联网设备。在使用标准HTTP或WebSocket时,通常此类客户端不会直接与单个服务进行通信。通常,网络边界充当外围,而控制良好的通信点充当外部世界与内部世界之间的中介。在Lagom中,此通信点是服务网关。将您的微服务系统构想成中世纪的城镇,四周环绕一堵墙,一扇门是进出的唯一途径。围墙内部的通信是免费和直接的,但与外部世界的通信必须通过服务网关进行,如下图所示。