创建一个名为 eureka-ribbon-client 的 Module 工程。
通过 RestTemplate 来远程调用 eureka-client 消费服务。
从 POM 引入相关依赖。
引入主 Maven 的 POM 文件 引入 Eureka Client 的起步依赖,引入 Ribbon 的起步依赖,引入 Web 的起步依赖。
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-ribbon</artifactId> </dependency>
配置 application.yml 文件 指定程序名,和服务注册地址。
spring: application: name: eureka-ribbon-client server: port: 8764 eureka: client: serviceUrl: defaultZone: http://localhost:8761/eureka/
启动类上加注解,开启 Eureka Client 功能 : @EnableEurekaClient
向 IOC 容器中注入一个 restTemplate 的 Bean ,并在这个 Bean 上加 @LoadBalanced 注解,这样 RestTemplate 就结合了 Ribbon 开启了负载均衡的功能:
@Configuration public class RibbonConfig { @Bean @LoadBalanced RestTemplate restTemplate(){ return new RestTemplate(); } }
写一个 RibbonService 类,用 restTemplate 调用 eureka-client 的 api 接口,不用写 IP 只写服务名 eureka-client 即可:
@Service public class RibbonService { @Autowired RestTemplate restTemplate; public String hi(String name){ return restTemplate.getForObject("http://eureka-client/hi?name="+name,String.class); } }
写一个 RibbonController 加上 @RestController 注解,开启 RestController 功能。
写一个 get 接口调用 RibbonServer 中的 方法。
@RestController public class RibbonController { @Autowired RibbonService ribbonService; @GetMapping("hi") public String hi(@RequestParam(required = false,defaultValue = "ioenn") String name){ return ribbonService.hi(name); } }
启动 ribbon 工程 ,
访问 服务注册中心。
访问 api :
http://localhost:8764/hi?name=ioenn
浏览器 会轮番显示接口的 调用 ,负载均衡器起了作用。
————————————————————————————————————————————————————————————
负载均衡的核心类: LoadBalancerClient .
它可以获取负载均衡的服务器提供者的实例信息。
代码如下:
使用 LoadBalancerClient 去选择 eureka-client 的服务实例信息,并将该信息返回。
@Autowired private LoadBalancerClient loadBalancer; @GetMapping("/testRibbon") public String testRibbon(){ ServiceInstance instance = loadBalancer.choose("eureka-client"); return instance.getHost()+":"+instance.getPort(); }
LoadBalancerClient 也可以不从 Eureka Client 获取注册列表信息,这时需要自己维护一份服务注册列表信息。
新建一个工程试试自己维护的服务列表:
新工程和 eureka-ribbon-client 工程类似。
修改 新工程的配置文件 application.yml 。
通过 配置 ribbon.eureka.enable 为 false 来禁止调用 Eureka client 获取注册列表 。
用 stores.ribbon.listOfServers 来配置服务实例 url
spring: application: name: ribbon-client stores: ribbon: listOfServers: ioenn.com,google.com ribbon: eureka: enabled: false server: port: 8769
新建一个 RestController 类,创建一个 Api 接口。
注入 LoadBalancerClient ,通过 LoadBalancerClient 的 choose() 方法获取服务的实例信息。
@RestController public class RibbonController { @Autowired private LoadBalancerClient loadBalancer; @GetMapping("/testRibbon") public String testRibbon(){ ServiceInstance instance = loadBalancer.choose("stores"); return instance.getHost()+":"+instance.getPort(); } }
启动工程 访问
http://localhost:8769/testRibbon
浏览器会交替出现 自己设置的服务注册列表的地址访问记录 。