天天看点
返回

Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试

1.eureka 和 “服务提供者”的高可用

Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试

1.1 item-service 高可用

启动参数 --server.port 可以覆盖yml中的端口配置

1.1.1 配置启动参数

Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试
Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试

1.1.2 启动测试

访问 eureka 查看 item-service 注册信息

Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试

访问两个端口测试

http://localhost:8001/35
http://localhost:8002/35

1.2 eureka 高可用

添加两个服务器的 profile 配置文件

1.2.1 application-eureka1.yml 

eureka:
  instance:
    hostname: eureka1
  client:
    register-with-eureka: true  #profile的配置会覆盖公用配置
    fetch-registry: true        #profile的配置会覆盖公用配置
    service-url: 
      defaultZone: http://eureka2:2002/eureka  #eureka1启动时向eureka2注册

1.2.2 application-eureka2.yml 

eureka:
  instance:
    hostname: eureka2
  client:
    register-with-eureka: true  #profile的配置会覆盖公用配置
    fetch-registry: true        #profile的配置会覆盖公用配置
    service-url: 
      defaultZone: http://eureka1:2001/eureka  #eureka2启动时向eureka1注册

1.2.3 java源文件

Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试

1.2.4 配置启动参数 --spring.profiles.active 和 --server.port

eureka1 启动参数：

Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试
Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试

eureka2 启动参数：

Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试

如果在命令行运行,可以在命令行中添加参数：

1.2.5 访问 eureka 服务器，查看注册信息

Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试
Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试

1.2.6 eureka客户端注册时，向两个服务器注册

修改以下微服务

sp02-itemservice

sp03-userservice

sp04-orderservice 

#yml
eureka:
  client:
    service-url:
      defaultZone: http://eureka1:2001/eureka, http://eureka2:2002/eureka

当一个 eureka 服务宕机时，仍可以连接另一个 eureka 服务

2.ribbon 服务消费者

Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试

ribbon 提供了负载均衡和重试功能, 它底层是使用 RestTemplate 进行 Rest api 调用

2.1 RestTemplate

RestTemplate 是SpringBoot提供的一个Rest远程调用工具

它的常用方法:

getForObject() - 执行get请求
postForObject() - 执行post请求

2.1.1 之前的系统结构是浏览器直接访问后台服务

Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试

2.2.2 后面我们通过一个Demo项目演示 Spring Cloud 远程调用

Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试

2.3 下面我们先不使用ribbon, 单独使用RestTemplate来执行远程调用

2.3.1 新建 sp06-ribbon 项目

Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试

2.3.2 添加依赖

Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试

2.3.3 pom.xml

eureka-client 中已经包含 ribbon 依赖

需要添加 sp01-commons 依赖 

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.9.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>cn.tedu</groupId>
    <artifactId>sp06-ribbon</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>sp06-ribbon</name>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Hoxton.SR10</spring-cloud.version>
    </properties>
    <dependencies>
        <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>
        <dependency>
            <groupId>org.springframework.retry</groupId>
            <artifactId>spring-retry</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>cn.tedu</groupId>
            <artifactId>sp01-commons</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    </dependencies>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

2.3.4 application.yml 

spring:
  application:
    name: ribbon
    
server:
  port: 3001
  
eureka:
  client:
    service-url:
      defaultZone: http://eureka1:2001/eureka, http://eureka2:2002/eureka

2.3.5 java源文件

Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试

2.3.6 主程序

创建 RestTemplate 实例

RestTemplate 是用来调用其他微服务的工具类，封装了远程调用代码，提供了一组用于远程调用的模板方法，例如：getForObject()、postForObject() 等 
package cn.tedu.sp06;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@EnableDiscoveryClient
@SpringBootApplication
public class Sp06RibbonApplication {
	
	//创建 RestTemplate 实例，并存入 spring 容器
	@Bean
	public RestTemplate getRestTemplate() {
		return new RestTemplate();
	}

	public static void main(String[] args) {
		SpringApplication.run(Sp06RibbonApplication.class, args);
	}

}

2.3.7 RibbonController 

package cn.tedu.sp06.controller;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import cn.tedu.sp01.pojo.Item;
import cn.tedu.sp01.pojo.Order;
import cn.tedu.sp01.pojo.User;
import cn.tedu.web.util.JsonResult;

@RestController
public class RibbonController {
	@Autowired
	private RestTemplate rt;
	
	@GetMapping("/item-service/{orderId}")
	public JsonResult<List<Item>> getItems(@PathVariable String orderId) {
	    //向指定微服务地址发送 get 请求，并获得该服务的返回结果 
	    //{1} 占位符，用 orderId 填充
		return rt.getForObject("http://localhost:8001/{1}", JsonResult.class, orderId);
	}

	@PostMapping("/item-service/decreaseNumber")
	public JsonResult decreaseNumber(@RequestBody List<Item> items) {
	    //发送 post 请求
		return rt.postForObject("http://localhost:8001/decreaseNumber", items, JsonResult.class);
	}

	/
	
	@GetMapping("/user-service/{userId}")
	public JsonResult<User> getUser(@PathVariable Integer userId) {
		return rt.getForObject("http://localhost:8101/{1}", JsonResult.class, userId);
	}

	@GetMapping("/user-service/{userId}/score") 
	public JsonResult addScore(
			@PathVariable Integer userId, Integer score) {
		return rt.getForObject("http://localhost:8101/{1}/score?score={2}", JsonResult.class, userId, score);
	}
	
	/
	
	@GetMapping("/order-service/{orderId}")
	public JsonResult<Order> getOrder(@PathVariable String orderId) {
		return rt.getForObject("http://localhost:8201/{1}", JsonResult.class, orderId);
	}

	@GetMapping("/order-service")
	public JsonResult addOrder() {
		return rt.getForObject("http://localhost:8201/", JsonResult.class);
	}
}

2.3.8 启动服务，并访问测试

Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试
http://eureka1:2001

http://localhost:3001/item-service/35
http://localhost:3001/item-service/decreaseNumber
使用postman，POST发送以下格式数据：
[{"id":1, "name":"abc", "number":23},{"id":2, "name":"def", "number":11}]

http://localhost:3001/user-service/7
http://localhost:3001/user-service/7/score?score=100

http://localhost:3001/order-service/123abc
http://localhost:3001/order-service/

3. ribbon 负载均衡和重试

Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试
Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试

3.1 Ribbon 负载均衡

Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试

3.2 修改 sp06-ribbon 项目

3.2.1添加 ribbon 起步依赖（可选）

eureka 依赖中已经包含了 ribbon 

<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
</dependency>

3.3 RestTemplate 设置 @LoadBalanced 

package cn.tedu.sp06;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
public class Sp06RibbonApplication {
	
	@LoadBalanced //负载均衡注解
	@Bean
	public RestTemplate getRestTemplate() {
		return new RestTemplate();
	}

	public static void main(String[] args) {
		SpringApplication.run(Sp06RibbonApplication.class, args);
	}

}

3.4 访问路径设置为服务id 

package cn.tedu.sp06.controller;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import cn.tedu.sp01.pojo.Item;
import cn.tedu.sp01.pojo.Order;
import cn.tedu.sp01.pojo.User;
import cn.tedu.web.util.JsonResult;

@RestController
public class RibbonController {
	@Autowired
	private RestTemplate rt;
	
	@GetMapping("/item-service/{orderId}")
	public JsonResult<List<Item>> getItems(@PathVariable String orderId) {
	    //这里服务器路径用 service-id 代替，ribbon 会向服务的多台集群服务器分发请求
		return rt.getForObject("http://item-service/{1}", JsonResult.class, orderId);
	}

	@PostMapping("/item-service/decreaseNumber")
	public JsonResult decreaseNumber(@RequestBody List<Item> items) {
		return rt.postForObject("http://item-service/decreaseNumber", items, JsonResult.class);
	}

	/
	
	@GetMapping("/user-service/{userId}")
	public JsonResult<User> getUser(@PathVariable Integer userId) {
		return rt.getForObject("http://user-service/{1}", JsonResult.class, userId);
	}

	@GetMapping("/user-service/{userId}/score") 
	public JsonResult addScore(
			@PathVariable Integer userId, Integer score) {
		return rt.getForObject("http://user-service/{1}/score?score={2}", JsonResult.class, userId, score);
	}
	
	/
	
	@GetMapping("/order-service/{orderId}")
	public JsonResult<Order> getOrder(@PathVariable String orderId) {
		return rt.getForObject("http://order-service/{1}", JsonResult.class, orderId);
	}

	@GetMapping("/order-service")
	public JsonResult addOrder() {
		return rt.getForObject("http://order-service/", JsonResult.class);
	}
}

3.5 访问测试

访问测试，ribbon 会把请求分发到 8001 和 8002 两个服务端口上

3.5.1 便于观看端口

Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试
Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试
Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试

4. ribbon 重试

Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试

4.1 pom.xml 添加 spring-retry 依赖

复制代码到 pom.xml 

<dependency>
	<groupId>org.springframework.retry</groupId>
	<artifactId>spring-retry</artifactId>
</dependency>

4.1.1 application.yml 配置 ribbon 重试 

spring:
  application:
    name: ribbon
    
server:
  port: 3001
  
eureka:
  client:    
    service-url:
      defaultZone: http://eureka1:2001/eureka, http://eureka2:2002/eureka
      
ribbon:
  MaxAutoRetriesNextServer: 2
  MaxAutoRetries: 1
  OkToRetryOnAllOperations: true

           
ConnectionTimeout
ReadTimeout
OkToRetryOnAllOperations=true

默认只对GET请求重试, 当设置为true时, 对POST等所有类型请求都重试

MaxAutoRetriesNextServer

更换实例的次数

MaxAutoRetries

当前实例重试次数，尝试失败会更换下一个实例

4.2 主程序设置 RestTemplate 的请求工厂的超时属性 

package cn.tedu.sp06;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.http.client.SimpleClientHttpRequestFactory;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
public class Sp06RibbonApplication {

	@LoadBalanced
	@Bean
	public RestTemplate getRestTemplate() {
		SimpleClientHttpRequestFactory f = new SimpleClientHttpRequestFactory();
		f.setConnectTimeout(1000);
		f.setReadTimeout(1000);
		return new RestTemplate(f);
		
		//RestTemplate 中默认的 Factory 实例中，两个超时属性默认是 -1，
		//未启用超时，也不会触发重试
		//return new RestTemplate();
	}

	public static void main(String[] args) {
		SpringApplication.run(Sp06RibbonApplication.class, args);
	}

}

4.3 item-service 的 ItemController 添加延迟代码，以便测试 ribbon 的重试机制 

package cn.tedu.sp02.item.controller;

import java.util.List;
import java.util.Random;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;

import cn.tedu.sp01.pojo.Item;
import cn.tedu.sp01.service.ItemService;
import cn.tedu.web.util.JsonResult;

import lombok.extern.slf4j.Slf4j;

@Slf4j
@RestController
public class ItemController {
	@Autowired
	private ItemService itemService;
	
	@Value("${server.port}")
	private int port;
	
	@GetMapping("/{orderId}")
	public JsonResult<List<Item>> getItems(@PathVariable String orderId) throws Exception {
		log.info("server.port="+port+", orderId="+orderId);

        ///--设置随机延迟
		if(Math.random()<0.6) { 
			long t = new Random().nextInt(5000);
			log.info("item-service-"+port+" - 暂停 "+t);
			Thread.sleep(t);
		}
		///~~
		
		List<Item> items = itemService.getItems(orderId);
		return JsonResult.ok(items).msg("port="+port);
	}
	
	@PostMapping("/decreaseNumber")
	public JsonResult decreaseNumber(@RequestBody List<Item> items) {
		itemService.decreaseNumbers(items);
		return JsonResult.ok();
	}
}

4.4 访问，测试 ribbon 重试机制

通过 ribbon 访问 item-service，当超时，ribbon 会重试请求集群中其他服务器

Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试
Spring Cloud Day021.eureka 和 “服务提供者”的高可用2.ribbon 服务消费者3. ribbon 负载均衡和重试4. ribbon 重试
ribbon的重试机制，在 feign 和 zuul 中进一步进行了封装，后续可以使用feign或zuul的重试机制
java eureka spring boot spring cloud ribbon
上一篇: RedisUtils中 redisTemplate注入为null
下一篇: spring cloud day02【 ribbon】

继续阅读