四、服务间通信方式

1、创建示例demo
- 1.1 创建 springcloud-consul-users-6104
  - 1.1.1 pom.xml文件
  - 1.1.2 yml 文件
- 1.2 创建 springcloud-consul-products-6105
2、服务间通信方式
3、示例代码

微服务架构中,我们比较关心的就是服务间的服务改如何调用,有哪些调用方式

在springcloud中服务间调用方式主要是使用 http restful方式进行服务间调用

1、创建示例demo

1.1 创建 springcloud-consul-users-6104

1.1.1 pom.xml文件

<?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.5.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.morrow</groupId>
    <artifactId>springcloud-consul-users-6104</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>springcloud-consul-users-6104</name>
    <description>springcloud-consul-users-6104 project for Spring Boot</description>
    <properties>
        <java.version>11</java.version>
        <spring-cloud.version>Hoxton.SR6</spring-cloud.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!--引入consul依赖-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-consul-discovery</artifactId>
        </dependency>
        <!-- 健康度监控-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
    </dependencies>
    <!--全局管理springcloud版本,并不会引入具体依赖-->
    <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>

1.1.2 yml 文件

server:
  port: 6104
spring:
  application:
    name: users
  cloud:
    consul:
      host: localhost        #注册consul服务的主机
      port: 8500             #注册consul服务的端口号
      discovery:
        #        register-health-check: true                 # 开启 关闭consul 服务的健康检查[不推荐]
        service-name: ${spring.application.name}    #指定注册的服务名称 默认就是应用名

1.2 创建 springcloud-consul-products-6105

1.2.1 pom.xml文件

<?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.5.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.morrow</groupId>
    <artifactId>springcloud-consul-products-6105</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>springcloud-consul-products-6105</name>
    <description>springcloud-consul-products-6105 project for Spring Boot</description>
    <properties>
        <java.version>11</java.version>
        <spring-cloud.version>Hoxton.SR6</spring-cloud.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!--引入consul依赖-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-consul-discovery</artifactId>
        </dependency>
        <!-- 健康度监控-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
    </dependencies>
    <!--全局管理springcloud版本,并不会引入具体依赖-->
    <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>

1.2.2 yml 文件

server:
  port: 6105
spring:
  application:
    name: products
  cloud:
    consul:
      host: localhost        #注册consul服务的主机
      port: 8500             #注册consul服务的端口号
      discovery:
        #        register-health-check: true                 # 开启 关闭consul 服务的健康检查[不推荐]
        service-name: ${spring.application.name}    #指定注册的服务名称 默认就是应用名

1.2.3 ProductController文件

@RestController
@Slf4j
public class ProductController {
    @Value("${server.port}")
    private int port;
    @GetMapping("/product/findAll")
    public Map<String,Object> findAll(){
        log.info("商品服务查询所有调用成功,当前服务端口:[{}]",port);
        Map<String, Object> map = new HashMap<String,Object>();
        map.put("msg","服务调用成功,服务提供端口为: "+port);
        map.put("status",true);
        return map;
    }
}

2、服务间通信方式

2.1 基于 RestTemplate 的服务调用

spring框架提供的RestTemplate类可用于在应用中调用rest服务，它简化了与http服务的通信方式，统一了RESTful的标准，封装了http链接，我们只需要传入url及返回值类型即可。相较于之前常用的HttpClient，RestTemplate是一种更优雅的调用RESTful服务的方式。

RestTemplate直接调用存在问题

1.直接使用restTemplate方式调用没有经过服务注册中心获取服务地址,代码写死不利于维护,当服务宕机时不能高效剔除

2.调用服务时没有负载均衡需要自己实现负载均衡策略

2.1.1 UserController文件

@RestController
@Slf4j
public class UserController {
    @GetMapping("/user/findAll")
    public String findAll(){
        log.info("调用用户服务...");
        //1.使用restTemplate调用商品服务
        RestTemplate restTemplate = new RestTemplate();
        String forObject = restTemplate.getForObject("http://localhost:6105/product/findAll",
                String.class);
        return forObject;
    }
}

2.1 基于 Ribbon 的服务调用

官方网址: https://github.com/Netflix/ribbon Spring Cloud Ribbon是一个基于HTTP和TCP的客户端负载均衡工具，它基于Netflix Ribbon实现。通过Spring Cloud的封装，可以让我们轻松地将面向服务的REST模版请求自动转换成客户端负载均衡的服务调用。

1.如果使用的是eureka client 和 consul client,无须引入依赖,因为在eureka,consul中默认集成了ribbon组件
2.如果使用的client中没有ribbon依赖需要显式引入如下依赖
org.springframework.cloud spring-cloud-starter-netflix-ribbon

2.1.1 UserController文件使用 discovery client 进行客户端调用


@Autowired
private DiscoveryClient discoveryClient;
@GetMapping("/user/findAll2")
    public String findAll2(){
        log.info("调用用户服务...");
        // 1. 使用discovery client  进行客户端调用
        List<ServiceInstance> serviceInstances = discoveryClient.getInstances("products");
        for (ServiceInstance product : serviceInstances) {
            log.info("服务主机:[{}]",product.getHost());
            log.info("服务端口:[{}]",product.getPort());
            log.info("服务地址:[{}]",product.getUri());
            log.info("====================================");
        }
        return null;
    }

2.1.2 UserController文件使用 loadBalanceClient 进行客户端调用

@Autowired
private LoadBalancerClient loadBalancerClient;
@GetMapping("/user/findAll3")
public ServiceInstance findAll3(){
    log.info("调用用户服务...");
    // 2. 使用loadBalanceClient 进行客户端调用
    ServiceInstance serviceInstance = loadBalancerClient.choose("products");
    log.info("服务主机:[{}]",serviceInstance.getHost());
    log.info("服务端口:[{}]",serviceInstance.getPort());
    log.info("服务地址:[{}]",serviceInstance.getUri());
    return serviceInstance;
}

2.1.3 UserController文件使用 @loadBalanced 进行客户端调用

@Autowired
private RestTemplate restTemplate;
@GetMapping("/user/findAll4")
public Map findAll4(){
    log.info("调用用户服务...");
    // 3. 使用@loadBalanced     进行客户端调用
    // 创建配置文件 RestTemplateConfig
    Map object = restTemplate.getForObject("http://products/product/findAll", Map.class);
    return object;
}

RestTemplateConfig 配置文件

@Configuration
public class RestTemplateConfig {
    @Bean
    @LoadBalanced
    public RestTemplate getRestTemplate() {
        return new RestTemplate();
    }
}

2.1.4 Ribbon负载均衡策略

负载均衡算法

RoundRobinRule 轮训策略按顺序循环选择 Server
RandomRule 随机策略随机选择 Server
AvailabilityFilteringRule 可用过滤策略
`会先过滤由于多次访问故障而处于断路器跳闸状态的服务，还有并发的连接数量超过阈值的服务，然后对剩余的服务列表按照轮询策略进行访问
WeightedResponseTimeRule 响应时间加权策略
`根据平均响应的时间计算所有服务的权重，响应时间越快服务权重越大被选中的概率越高，刚启动时如果统计信息不足，则使用
RoundRobinRule策略，等统计信息足够会切换到
RetryRule 重试策略
`先按照RoundRobinRule的策略获取服务，如果获取失败则在制定时间内进行重试，获取可用的服务。
BestAviableRule 最低并发策略
`会先过滤掉由于多次访问故障而处于断路器跳闸状态的服务，然后选择一个并发量最小的服务

product 启动 6106

2.1.4.1 配置轮训策略

yml 文件

server:
  port: 6104
spring:
  application:
    name: users
  cloud:
    consul:
      host: localhost        #注册consul服务的主机
      port: 8500             #注册consul服务的端口号
      discovery:
        #        register-health-check: true                 # 开启 关闭consul 服务的健康检查[不推荐]
        service-name: ${spring.application.name}    #指定注册的服务名称 默认就是应用名
products:
  ribbon:
    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

其它策略.. 类似

2.1.5 Ribbon停止维护

3、示例代码

springcloud-consul-users-6104 springcloud-consul-products-6105

1、创建示例demo

1.1 创建 springcloud-consul-users-6104

1.1.1 pom.xml文件

1.1.2 yml 文件

1.2 创建 springcloud-consul-products-6105

1.2.1 pom.xml文件

1.2.2 yml 文件

1.2.3 ProductController文件

2、服务间通信方式

2.1 基于 RestTemplate 的服务调用

2.1.1 UserController文件

2.1 基于 Ribbon 的服务调用

2.1.1 UserController文件 使用 discovery client 进行客户端调用

2.1.2 UserController文件 使用 loadBalanceClient 进行客户端调用

2.1.3 UserController文件 使用 @loadBalanced 进行客户端调用

2.1.4 Ribbon负载均衡策略

负载均衡算法

2.1.4.1 配置 轮训策略

2.1.5 Ribbon停止维护

3、示例代码

2.1.1 UserController文件使用 discovery client 进行客户端调用

2.1.2 UserController文件使用 loadBalanceClient 进行客户端调用

2.1.3 UserController文件使用 @loadBalanced 进行客户端调用

2.1.4.1 配置轮训策略