你是否精通 springcloud:使用 SpringCloud 进行同步通信?
==============
与 Ribbon 有关的主要概念是命名客户端(Client) 。这就是为什么开发人员可以使用客户端的名称而不是带有主机名和端口的完整地址来调用其他服务,并且无须连接到服务发现。在这种情况下,应该在 application.yml 文件内的 Ribbon 配置设置中提供地址的列表。
使用 Ribbon 客户端启用微服务之间的通信
=====================
现在来继续这个示例。它由 4 个独立的微服务组成,其中一些可能会调用其他微服务公开的端点。应用程序源代码可在以下地址处获得。
https://github . com/piomin/sample- spr ing-cloud-comm.git
在这个示例中,我们将尝试开发一个简单的订单系统,客户可以在该系统中购买产品。如果客户决定确认要购买的所选产品列表,则 POST 请求将发送到 order-service (订单服务)。它由 REST 控制器内的 Order prepare(@RequestBody Order rdre.)方法处理。该方法负责订单的准备。首先,它将从 order-service 中调用适当的 API 方法,考虑产品列表中每个产品的价格、客户订购的历史记录及客户在系统中的类别等因素,计算出最终价格:然后,它通过调用 account-service (账户服务),验证客户的账户余额是否足够执行订单:最后,它返回计算的价格。如果客户确认操作,则调用 PUT /{id}方法。该请求将由 REST 控制器内的 Order
accept(@PathVariable Long d...}方法处理。它会更改订单的状态并从客户的账户中提取资金。该系统架构可以分解为各个微服务,如图 6.1 所示。
静态负载均衡配置
========
本示例中的 order-service(订单服务)必须与该示例中的所有其他微服务进行通信,以执行所需的操作,因此,开发人员需要使用 ribbon.listOfServers 属性定义 3 个不同的 Ribbon 客户端,并且这些客户端需要包含网络地址设置。该示例中的第二个重要事项是在 Eureka 中禁用默认启用的发现服务。以下是 application.yml 文件中 orderservice 的所有己定义属性。
server:
port: 8090
account-service :
ribbon:
eureka:
enabled: false
listOfServers: localhost:8091
customer-service:
ribbon:
eureka:
enabled: false
listOfServers: localhost:8092
product- service:
ribbon:
eureka:
enabled: false
listOfServers: localhost:8093
开发人员还应该在项目中包含以下依赖项,以便将 RestTemplate 与 Ribbon 客户端结合在一起使用。
<dependency>
<groupId>org . springframework. cloud</groupId>
<arti factId>spring-cloud-starter-ribbon</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot/groupId>
<artifactId>spring-boot -starter-web</artifactId>
</ dependency>
然后,开发人员可以通过声明 application.yml 中配置的名称列表来启用 Ribbon 客户端。为完成此操作,可以使用 @RibbonClients 注解 main 类或任何其他 Spring 配置类。开发人员还应该注册 RestTemplate bean 并使用 @L oadBalanced 注解它,以启用与 SpringCloud 组件的交互。
@SpringBootApplication
QRibbonClients ({
@RibbonClient (name - " account-service"),
@RibbonClient (name = "customer-service") ,
eRibbonClient (name = "product-service")
})
public class OrderApplication
@LoadBalanced
@Bean
RestTemplate restTemplate() (
return new RestTemplate() ;
}
public static void main(String[] args);
}
评论