1.RestTemplate实现远程调用

如果将一个系统进行拆分后,比如可以将一个电商系统可以拆分成订单模块,用户模块,商品模块,分别可以从数据库中的订单表,用户表,商品表中查询数据,那么如果根据订单id查询订单记录时,订单又需要根据userId查询用户信息,我们就需要在查询订单的时候,一并查询出用户信息,我们就需要使用RestTemplate进行跨服务查询.步骤如下:

• 注册一个RestTemplate的实例到Spring容器
• 根据RestTemplate对象进行远程调用

1.1 注册RestTemplate

在配置类中注册RestTemplate实例

@Bean
public RestTemplate restTemplate() {
    return new RestTemplate();
}

1.2 实现远程调用

通过restTemplate对象的getForObject方法实现远程调用,传入两个参数,一个是需要远程调用的url,二是返回的数据类型.

	private RestTemplate restTemplate;

    public Order queryOrderById(Long orderId) {
        // 1.查询订单
        Order order = orderMapper.findById(orderId);
        // 2.利用RestTemplate发起http请求，查询用户
        // 2.1.url路径
        String url = "http://localhost:8081/user/" + order.getUserId();
        // 2.2.发送http请求，实现远程调用
        User user = restTemplate.getForObject(url, User.class);
        // 3.封装user到Order
        order.setUser(user);
        // 4.返回
        return order;
    }

在此服务调用过程中,会有两个不同的角色

服务提供者：一次业务中，被其它微服务调用的服务。（提供接口给其它微服务）

服务消费者：一次业务中，调用其它微服务的服务。（调用其它微服务提供的接口）

2.Eureka注册中心

2.1 Eureka两大组件

• Eureka Server提供服务注册
• Eureka Client通过注册中心进行访问
  

2.2 搭建eureka-server

创建一个eureka-server的maven工程

2.2.1 引入eureka依赖

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

2.2.2 编写启动类

@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaApplication.class, args);
    }
}

2.2.3 编写配置文件

创建application.yml文件

server:
  port: 10086
spring:
  application:
    name: eureka-server
eureka:
  client:
    service-url: 
      defaultZone: http://127.0.0.1:10086/eureka

接下来启动微服务,然后在浏览器就可以访问: http://127.0.0.1:10086

2.3 服务注册

如果我们需要将user-service注册到eureka-server中去,那么我们只需要引入依赖和修改配置文件

2.3.1 引入依赖

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

2.3.2 编写配置文件

创建application.yml文件,添加服务名称,eureka地址

server:
  port: 8081
spring:
  application:
    name: userservice
eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:10086/eureka

为了模拟一个服务有多个实例的场景,我们可以再创建一个user-service2,修改其端口号为8082,其余配置和user-service完全一样.

2.4 服务发现

2.4.1 引入依赖

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

2.4.2 编写配置文件

server:
  port: 8080
spring:
  application:
    name: orderservice
eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:10086/eureka

2.5 服务拉取与负载均衡

最后，我们要去eureka-server中拉取user-service服务的实例列表，并且实现负载均衡。

使用@LoadBalanced注解赋予RestTemplate负载均衡的能力

	@Bean
    @LoadBalanced
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }

修改服务调用的url地址

	@Autowired
    private RestTemplate restTemplate;

    public Order queryOrderById(Long orderId) {
        // 1.查询订单
        Order order = orderMapper.findById(orderId);
        // 2.利用RestTemplate发起http请求，查询用户
        // 2.1.url路径
        String url = "http://userservice/user/" + order.getUserId();
        // 2.2.发送http请求，实现远程调用
        User user = restTemplate.getForObject(url, User.class);
        // 3.封装user到Order
        order.setUser(user);
        // 4.返回
        return order;
    }

3.Eureka自我保护

Eureka-Client默认30秒会向Eureka-Server发送一次心跳,证明它还活着,如果Eureka-Server在一定时间内(默认90秒)没有收到Eureka-Client发来的心跳,那么Eureka-Server将会把Eureka-Client服务剔除,但是如果Eureka-Server在短时间内丢失大量服务实例心跳,那Eureka-Server会开启自我保护机制,不会立刻将Eureka-Client服务剔除,而让其进入自我保护模式,待它再次发送心跳,该节点便会回到正常.

一句话：某时刻某一个微服务不可用了，Eureka不会立刻清理，依旧会对该微服务的信息进行保存