Spring Cloud Eureka基础应用及原理

2024-04-02 19:04:59 685人浏览八月长安

Python 官方文档：入门教程 => 点击学习

摘要

目录Eureka简介搭建Eureka服务注册中心搭建Eureka服务提供者搭建Eureka服务调用者Eureka服务注册和发现Eureka简介 Eureka这个词来源于古希腊语，意为

Eureka简介

Eureka这个词来源于古希腊语，意为“我找到了!我发现了!”。据传，阿基米德在洗澡时发现浮力原理，高兴得来不及穿上衣服，跑到街上大喊:“Eureka! ”。
在Netflix中，Eureka是一个RESTful风格的服务注册与发现的基础服务组件。Eureka由两部分组成，一个是Eureka Server，提供服务注册和发现功能，即我们上面所说的服务器端;另一个是Eureka Client，它简化了客户端与服务端之间的交互。Eureka Client会定时将自己的信息注册到Eureka Server中，并从Server中发现其他服务。Eureka Client中内置一个负载均衡器，用来进行基本的负载均衡。
下面我们将通过搭建一个简单的Eureka例子来了解Eureka的运作原理。

搭建Eureka服务注册中心

可以搭建包含Eureka Server依赖的Spring Boot项目。主要依赖如下:

在启动类中添加注解@EnableEurekaServer，代码如下所示:

@SpringBootApplication
//会为项目自动配置必须的配置类，标识该服务为注册中心
@EnableEurekaServer
public class DemoApplication {

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

在application.yml配置文件中添加以下配置，配置注册中心的端口和标识自己为Eureka Server:

server:
  port: 8761
#eureka配置--4部分
#1.dashboard WEB控制台
#2.server服务端配置--配置过期时间等
#3.client客户端配置--配置注册发现地址
#4.instance项目实例
eureka:
  #配置服务可视化默认开启
  dashboard:
    enabled: true
    path: /
  instance:
    hostname: localhost
  #这个是euraka暴漏给提供者和消费者服务发现注册用的
  client:
    service-url:
      #defaultZone: Http://localhost:8761/eureka不能写死
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka
    #是否注册到eureka上注册中心是不用把自己上床到自己的provider
    reGISter-with-eureka: false
    #是否需要到eureka上拉去服务路径--consumer需要
    fetch-registry: false

lnstanceld是Eureka服务的唯一标记，主要用于区分同一服务集群的不同实例。一般来讲，一个Eureka服务实例默认注册的Instanceld是它的主机名(即一个主机只有一个服务）。但是这样会引发一个问题，一台主机不能启动多个属于同一服务的服务实例。为了解决这种情况，spring-cloud-netflix-eureka提供了一个合理的实现，如上面代码中的Instanceld设置样式。通过设置random.value可以使得每一个服务实例的lnstanceld独一无二，从而可以唯一标记它自身。

Eureka Server既可以独立部署，也可以集群部署。在集群部署的信况下，EurekaServeri间会进行注册表信息同步的换作，这时被同步注册表信息的Eureka Server将会被其他同步注册表信息的Eureka Server称为peer。

请注意，上述配置中的service-url指向的注册中心为实例本身。通常来讲，一个Eureka Server也是一个Eureka Client，它会尝试注册自己，所以需要至少一个注册中心的URL来定位对等点peer。如果不提供这样一个注册端点，注册中心也能工作，但是会在日志中打印无法向peer注册自己的信息。在独立(Standalone) Eureka Server的模式下，Eureka Server一般会关闭作为客户端注册自己的行为。

Eureka Server与Eureka Client之间的联系主要通过心跳的方式实现。心跳(Heartbeat)即Eureka Client定时向Eureka Server汇报本服务实例当前的状态，维护本服务实例在注册表中租约的有效性。

Eureka Server需要随时维持最新的服务实例信息，所以在注册表中的每个服务实例都需要定期发送心跳到Server中以使自己的注册保持最新的状态.（数据一般直接保存在内存中）。为了避免Eureka Client在每次服务间调用都向注册中心请求依赖服务实例的信息，Eureka Client将定时从Eureka Server中拉取注册表中的信息，并将这些信息缓存到本地，用于服务发现。

启动Eureka Server后，应用会有一个主页面用来展示当前注册表中的服务实例信息并同时暴露一些基于HTTP协议的端点在/eureka路径下，这些端点将由EurekaClient用于注册自身、获取注册表信息以及发送心跳等。

搭建Eureka服务提供者

可以搭建包含Eurake Client依赖的Spring Boot项目。主要依赖有:

<!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-netflix-eureka-client -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    <version>3.1.2</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-web -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
    <version>2.6.7</version>
</dependency>

启动类如下：

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

在spring cloud的Finchley版本中，只要引入spring-cloud-starter-netflix-eureka-client的依赖，应用就会自动注册到Eureka Server，但是需要在配置文件中添加Eureka Server的地址。在application.yml添加以下配置:

# Eureka配置
eureka:
  instance:
     hostname: client
     instance-id: ${spring.application.name} :$ lvcap.application.instance_id:$ lspring.application.instance_id:$trandom value}}}
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/
server :
  port : 8760
spring:
  application:
    rame: eureka-client

为服务提供者添加一个提供服务的接口，代码如下:

@RestContro11er
public class SayHe11oContro11er {
@RequestMapping(value = "/he11o/{name}")
public String sayHe11o(@PathVarivab1e("name") String name){
return "He11o,".concat(name).concat("! ");
}
}

上述接口将会向请求者返回打招呼的响应信息。

搭建Eureka服务调用者

可以搭建包含Eurake Client依赖的Spring Boot项目。主要依赖有:

<!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-netflix-eureka-client -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    <version>3.1.2</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-web -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
    <version>2.6.7</version>
</dependency>

启动类代码如下:

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

在application.yml添加eureka-client相关配置，代码如下所示:

# Eureka配置
eureka:
  instance:
     hostname: client
     instance-id: ${spring.application.name} :$ lvcap.application.instance_id:$ lspring.application.instance_id:$trandom value}}}
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/
server :
  port : 8765
spring:
  application:
    rame: eureka-client

添加一个AskController向eureka-client-service请求sayHello的服务。通过使用可以进行负载均衡的RestTemplate向eureka-client-service发起打招呼的请求，并直接返回对应的响应结果。具体代码如下所示:

@RestController
@Configuration
public class DemoController {
//注入本地服务名
@value("${spring.application. name}")
private string name;
@Autowired
RestTemplate restTemplate;
@RequestMapping(value = "/ask")
public string ask(){
//从eureka-client-service服务提供者中请求sayHello服务
string askHelloFromService = restTemplate.getForEntity("http ://EUREKA-CLIENT-SERVICE/hello/{name}", String.class,name).getBody();
return askHelloFromService;
}
//注入一个可以进行负载均衡的RestTemple用于服务间调用@Bean
@LoadBalanced
public RestTemplate restTemplate(){
return new RestTemplate();
}

Eureka服务注册和发现

搭建好上述三个Eureka应用后，依次启动三个应用。
1.Eureka Server主页
访问Eureka Server的主页http://localhost:8761，可以看到下图所示的界面。
从图中可以看到以下信息:
-展示当前注册到Eureka server上的服务实例信息。
-展示Eureka Server运行环境的通用信息。
-展示Eureka Server实例的信息。

2.服务间调用
访问http:l/localhost:8762/ask，eureka-client将调用eureka-client-service的sayHello服务，向eureka-client-service传递服务名，等待eureka-client-service返回请求响应，响应结果如下:

Hello， eureka-client !

RestTemplate将根据服务名eureka-client-service通过预先从eureka-service缓存到本地的注册表中获取到eureka-client-service服务的具体地址，从而发起服务间调用。

3.与服务注册中心交换信息
DiscoveryClient来源于spring-cloud-client-discovery，是Spring Cloud中定义用来服务发现的公共接口，在Spring Cloud的各类服务发现组件中(如Netflix Eureka或Consul）都有相应的实现。它提供从服务注册中心根据serviceld获取到对应服务实例信息的能力。当一个服务实例拥有DiscoveryClient的具体实现时，就可以从服务注册中心中发现其他的服务实例。
在Eureka Client中注入DiscoveryClient，并从Eureka Server获取服务实例的信息。在chapter4-eureka-client添加一个ServicelnstanceRestController的controller ,如下所示:

@RestController
public class ServiceInstanceRestController {
@Autowired
private DiscoveryClient discoveryClient ;
@RequestMapping(" /service-instances/ {applicationName}")
public List<ServiceInstance> serviceInstancesByApplicationName(
@Pathvariable 
String applicationName(){
return this.discoveryClient.getInstances(applicationName);
}
}

启动应用后，访问地址http://localhost:8765/service-instancesleureka-client，获取应用名为eureka-client(服务本身)的服务实例元数据，结果如下所示: