1、引入负载均衡组件
<!-- 在消费者侧添加"负载均衡"组件 --><!-- 组件的作用是注册了一个LoadBalancerClient类型的bean --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-loadbalancer</artifactId></dependency>2、使用负载均衡组件
@RestControllerpublic class NacosController{@Autowiredprivate LoadBalancerClient loadBalancerClient;@Autowiredprivate RestTemplate restTemplate;@Value("${spring.application.name}")private String appName;@GetMapping("/echo/app-name")public String echoAppName(){// <1>ServiceInstance serviceInstance = loadBalancerClient.choose("nacos-provider");String path = String.format("http://%s:%s/echo/%s",serviceInstance.getHost(),serviceInstance.getPort(),appName);System.out.println("request path:" +path);// <2>return restTemplate.getForObject(path,String.class);}}在代码<1>处,首先用复杂均衡组件提供的LoadBalancerClient选择出具体是哪一个微服务instance提供服务;然后在代码<2>处请求具体的instance获取结果。
注意:
1、此时的RestTemplate就是原始的RestTemplate,而没有加@LoadBalance注解,因为负载均衡功能已经由loadBalancerClient完成了。
@Beanpublic RestTemplate restTemplate(){return new RestTemplate();} 版本2:ribbon-loadbalancer方案1、引入组件
<dependency><groupId>com.netflix.ribbon</groupId><artifactId>ribbon-loadbalancer</artifactId></dependency>2、如何使用
添加了负载均衡的RestTemplate @Bean@LoadBalancedpublic RestTemplate restTemplate(){return new RestTemplate();} 正常调用 @RestControllerpublic class TestController {@Autowiredprivate RestTemplate restTemplate;@GetMapping(value = "/echo-rest/{str}")public String rest(@PathVariable String str) {// 会负载均衡服务名称nacos-providerreturn restTemplate.getForObject("http://nacos-provider/echo/" + str, String.class);}} 版本3:openfeign方案(即方案2+openfeign版本)该方案是目前市场流行度较高的方案,用接口+@FeignClient注解方式。
1、引入组件
openfeign 会间接引入@LoadBalance注解及负载均衡功能。
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency>2、如何使用
远程接口 @FeignClient(name = "nacos-provider")public interface EchoService {@GetMapping(value = "/echo/{str}")String echo(@PathVariable("str") String str);} 添加了负载均衡的RestTemplate @Bean@LoadBalancedpublic RestTemplate restTemplate(){return new RestTemplate();} 接口实现 @RestControllerpublic class TestController {@Autowiredprivate RestTemplate restTemplate;@GetMapping(value = "/echo-rest/{str}")public String rest(@PathVariable String str) {// 会负载均衡服务名称nacos-providerreturn restTemplate.getForObject("http://nacos-provider/echo/" + str, String.class);}} 验证结果是成功的。参考代码:https://gitee.com/firefish985/FireFish/FireFish-Learning/nacos-discovery-consumer