微服务基础---Eureka注册中心

1.3Eureka注册中心

提供者与消费者

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

1.3.1服务调用出现的问题

1. 采用硬编码的形式

2. 当时一个分布式系统时

3. 提出问题

• 服务该如何获取服务提供者的地址信息？

• 如果有多个提供者，消费者该如何选择？

• 消费者如何得知服务提供者的健康状态？

4. 回顾问题

• 服务该如何获取服务提供者的地址信息？

  • 服务提供者启动时向eureka注册自己的信息
  • eureka保存这些信息
  • 消费者根据服务名称向eureka拉取提供者信息

• 如果有多个提供者，消费者该如何选择？

  • 消费者利用负载均衡算法，从服务列表中挑选一个

• 消费者如何得知服务提供者的健康状态？

  • 服务提供者会每隔30s向EurekaServer发送心跳请求，报告健康状态
  • eureka会更新记录服务列表信息，心跳不正常会被剔除
  • 消费者就可以拉取到最新的信息

---

在Eureka架构中，微服务角色有两类:

• EurekaServer:服务端，注册中心

  • 记录服务信息
  • 心跳监控

• EurekaClient:客户端

  • Provider:服务提供者，例如案例中的user-service
    • 注册自己的信息到EurekaServer
    • 每隔30秒向EurekaServer发送心跳
  • consumer:服务消费者，例如案例中的order-service
    • 根据服务名称从EurekaServer拉取服务列表
    • 基于服务列表做负载均衡，选中一个微服务后发起远程调用

1.3.2搭建Eureka服务

1.3.2.1搭建EurekaServer注册中心

1. 创建项目，引入spring-cloud-starter-netfix-eureka-server的依赖

		<dependency>
            <groupId>org.springframework.cloudgroupId>
            <artifactId>spring-cloud-starter-netflix-eureka-serverartifactId>
        dependency>
1
2
3
4

2. 编写配置类，添加@EnableEurekaServer注解
3. 编写yaml配置文件

server:
  port: 7070	#自定义端口

spring:
  application:
    name: eureka-server #微服务名称

eureka:
  client:
    register-with-eureka: true  #是否将自己注册到eureka中
    fetch-registry: true       #服务发现，是否从eureka中获取注册信息
    service-url:
      #地址信息，eureka自己也是个微服务，将自己也注册到eureka中，多个用逗号隔开
      defaultZone: http://127.0.0.1:7070/eureka
1
2
3
4
5
6
7
8
9
10
11
12
13
14

4. 启动后进入页面

1.3.2.2注册user-service、order-service

1. 在user-service项目有引入spring-cloud-started-netfix-eureka-client的依赖

		<dependency>
            <groupId>org.springframework.cloudgroupId>
            <artifactId>spring-cloud-starter-netflix-eureka-clientartifactId>
        dependency>
1
2
3
4

2. 配置yaml文件

spring:
  application:
    name: user-service #order-service

eureka:
  client:
    register-with-eureka: true  #是否将自己注册到eureka中
    fetch-registry: true       #服务发现，是否从eureka中获取注册信息
    service-url:
      #地址信息，eureka自己也是个微服务，将自己也注册到eureka中，多个用逗号隔开
      defaultZone: http://127.0.0.1:7070/eureka
1
2
3
4
5
6
7
8
9
10
11

3. 查看eureka服务列表

4. 多启动一个user-service

• 防止端口冲突，指定端口

5. 启动

6. 查看eureka服务列表

可以看到此时就有两条记录

1.3.2.3在order-service中拉取服务

1. 修改OrderService代码，修改访问路径，用服务器名代替ip、端口：

package com.xn2001.order.service;

import com.xn2001.order.mapper.OrderMapper;
import com.xn2001.order.pojo.Order;
import com.xn2001.order.pojo.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

@Service
public class OrderService {

    @Autowired
    private OrderMapper orderMapper;

    @Autowired
    private RestTemplate restTemplate;

    public Order queryOrderById(Long orderId) {
        // 1.查询订单
        Order order = orderMapper.findById(orderId);

        //2 利用RestTemplate发起Http请求，查询用户
        //2.1url路径
        String url = "http://user-service/user/"+order.getUserId();
        //2.2发送http请求，实现远程调用,getForObject get请求
        User user = restTemplate.getForObject(url, User.class);
        //3.封装user到Order
        order.setUser(user);
        // 4.返回
        return order;
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

2. OrderApplication添加的Bean添加负载均衡注解

	/**
     * 创建RestTemplate并注入spring容器
     * @return
     */
    @Bean
    @LoadBalanced  //负载均衡注解
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }
1
2
3
4
5
6
7
8
9

3. 重启访问接口，查看返回结果order/101、order/102

此时idea的日志会出现两条信息，两个user-service服务轮询操作