创建一个名为 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
浏览器会交替出现 自己设置的服务注册列表的地址访问记录 。

京公网安备 11010502036488号