Spring-Cloud-Eureka注册中心和调用实例

Eureka是Netflix开发的服务发现框架，本身是一个基于REST的服务，主要用于定位运行在AWS域中的中间层服务，以达到负载均衡和中间层服务故障转移的目的。 
SpringCloud将它集成在其子项目spring-cloud-netflix中，以实现SpringCloud的服务发现功能。

Eureka概述

Eureka包含两个组件：Eureka Server（服务器，或服务注册中心）和Eureka Client（客户端）。

Eureka Server提供服务注册服务，各个节点启动后，会在Eureka Server中进行注册，这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可以在界面中直观的看到。
Eureka Client是一个java客户端，用于简化与Eureka Server的交互，客户端同时也就是一个内置的、使用轮询(round-robin)负载算法的负载均衡器。
在应用启动后，将会向Eureka Server发送心跳,默认周期为30秒，如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳，Eureka Server将会从服务注册表中把这个服务节点移除(默认90秒)。

Eureka Server之间通过复制的方式完成数据的同步，Eureka还提供了客户端缓存机制，即使所有的Eureka Server都挂掉，客户端依然可以利用缓存中的信息消费其他服务的API。
综上，Eureka通过心跳检查、客户端缓存等机制，确保了系统的高可用性、灵活性和可伸缩性。

Eureka的服务发布与调用简单例子

一、构建服务器（服务注册中心）

注册中心这么关键的服务，如果是单点话，遇到故障就是毁灭性的。在一个分布式系统中，服务注册中心是最重要的基础部分，理应随时处于可以提供服务的状态。为了维持其可用性，使用集群是很好的解决方案。Eureka通过互相注册的方式来实现高可用的部署，所以我们只需要将Eureke Server配置其他可用的serviceUrl就能实现高可用部署。

实例结构如下图所示，服务中心双机部署（模仿集群）。

配置双节点注册中心

1.所有项目的父pom

<?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.4.RELEASE</version>
      <relativePath/> <!-- lookup parent from repository -->
  </parent>
  
  <groupId>com.cc8w</groupId>
  <artifactId>springcloud_eureka_demo</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>pom</packaging>
  <name>springcloud_eureka_demo</name>
  <url>http://maven.apache.org</url>

    <properties>
        <java.version>1.8</java.version>
        <spring.cloud-version>Hoxton.SR8</spring.cloud-version>
    </properties>
    <!-- 版本控制 -->
    <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>
    <dependencies>
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
    
  <modules>
    <module>eureka_service</module>
    <module>cureka_provider</module>
    <module>eureka_consumer</module>
  </modules>
</project>

2.创建注册中心的子maven工程

创建完成后的pom.xml配置文件，自动集成父项目SpringBoot2.3.4版本，对应SpringCould版本Hoxton.SR8。
加入的spring-cloud-starter-eureka-server会自动引入spring-boot-starter-web，因此可以不加web依赖，项目就具有Web容器的功能。
pom.xml完整内容如下：

<?xml version="1.0"?>
<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd" xmlns="http://maven.apache.org/POM/4.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
  <modelVersion>4.0.0</modelVersion>
  <parent>
    <groupId>com.cc8w</groupId>
    <artifactId>springcloud_eureka_demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
  </parent>

  <artifactId>eureka_service</artifactId>
  <name>eureka_service</name>
  <url>http://maven.apache.org</url>
  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  </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-config</artifactId>
        </dependency>
        <!--注册中心-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

  </dependencies>
</project>

3、创建application-peer1.properties，作为peer1服务中心的配置，并将serviceUrl指向peer2

# 服务名
spring.application.name=cloud-eureka-service
# 服务端口
server.port=8000

eureka.instance.hostname=peer1
# 指示此实例是否应将其信息注册到eureka服务器以供其他人发现。在某些情况下，您不希望发现实例，而您只想发现其他实例。
eureka.client.register-with-eureka=true
# 指示该客户端是否应从eureka服务器获取eureka注册表信息。
eureka.client.fetch-registry=false

eureka.client.service-url.defaultZone=http://peer2:8001/eureka/


# 关闭服务保护机制
eureka.server.enable-self-preservation=false
# 清理无效节点时间间隔（单位毫秒，默认是60*1000）
eureka.server.eviction-interval-timer-in-ms=30000

#每30S给其他服务发次请求，监测心跳
eureka.instance.lease-renewal-interval-in-seconds: 30
#如果其他服务没心跳，90S后剔除该服务
eureka.instance.lease-expiration-duration-in-seconds: 90

4、创建application-peer2.properties，作为peer2服务中心的配置，并将serviceUrl指向peer1

# 服务名
spring.application.name=cloud-eureka-service
# 服务端口
server.port=8001

eureka.instance.hostname=peer2
# 指示此实例是否应将其信息注册到eureka服务器以供其他人发现。在某些情况下，您不希望发现实例，而您只想发现其他实例。
eureka.client.register-with-eureka=true
# 指示该客户端是否应从eureka服务器获取eureka注册表信息。
eureka.client.fetch-registry=false

eureka.client.service-url.defaultZone=http://peer1:8000/eureka/


# 关闭服务保护机制
eureka.server.enable-self-preservation=false
# 清理无效节点时间间隔（单位毫秒，默认是60*1000）
eureka.server.eviction-interval-timer-in-ms=30000

#每30S给其他服务发次请求，监测心跳
eureka.instance.lease-renewal-interval-in-seconds: 30
#如果其他服务没心跳，90S后剔除该服务
eureka.instance.lease-expiration-duration-in-seconds: 90

设置服务端口、服务器注册开关。
默认情况下，服务器启动时会把自己当做一个客户端，去注册Eureka服务器，并且会到Eureka服务器抓取注册信息。
但这里只是作为一个服务器，而不是服务的提供者（客户端），因此设置属性值为flase，否则启动时会在控制台看到异常信息。
Caused by: java.net.ConnectException: Connection refused: connect
com.netflix.discovery.shared.transport.TransportException: Cannot execute request on any known server

5.总的application.properties

#多配置文件
spring.profiles.active=peer1

6、host转换 （system32下... host文件）

127.0.0.1 peer1 
127.0.0.1 peer2 

7.启动类

package com.cc8w;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;


@SpringBootApplication
@EnableEurekaServer //启用注册中心,增加注解@EnableEurekaServer，声明这是一个Eureka服务器。
public class EurekaServiceApplication 
{
    public static void main( String[] args )
    {
        SpringApplication.run(EurekaServiceApplication.class, args);
    }
}

8. 启动（两个注册中心）

启动第一个注册中心后，修改application.properties文件改为peer2，再启动.

服务方生产者 eureka_provider

 

 

 1.pom.xml文件

<?xml version="1.0"?>
<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd" xmlns="http://maven.apache.org/POM/4.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
  <modelVersion>4.0.0</modelVersion>
  <parent>
    <groupId>com.cc8w</groupId>
    <artifactId>springcloud_eureka_demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
  </parent>

  <artifactId>cureka_provider</artifactId>
  <name>cureka_provider</name>
  <url>http://maven.apache.org</url>
  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  </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-config</artifactId>
        </dependency>
        <!--注册中心-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
        <!--消费者-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
  </dependencies>
</project>

2.修改配置文件application.properties

# 服务名
spring.application.name=cloud-eureka-provider
# 服务端口
server.port=8761

eureka.instance.hostname=localhost
eureka.client.service-url.defaultZone=http://localhost:8000/eureka/

3.添加实体类UserEntity(一般实体类最好序列化)

package com.cc8w.entity;

import java.io.Serializable;

public class UserEntity implements Serializable {
    
    /**
     * 
     */
    private static final long serialVersionUID = 1L;
    private Integer id;
    private String name;
    public UserEntity() {
        
    }
    public UserEntity(Integer id, String name){
        this.id = id;
        this.name = name;
    }

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }
}

4.添加控制器

package com.cc8w.controller;

import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import com.cc8w.entity.UserEntity;

@RestController
public class UserController {
    @RequestMapping(value = "/user/{userId}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
    public UserEntity findUser(@PathVariable("userId") Integer userId){
        UserEntity user = new UserEntity(userId, "cc8w");
        return user;
    }
}

5.修改启动类

package com.cc8w;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

@SpringBootApplication
@EnableEurekaClient //添加注解@EnableEurekaClient，声明这是一个Eureka客户端。
public class EurekaProviderApplication 
{
    public static void main( String[] args )
    {
        SpringApplication.run(EurekaProviderApplication.class, args);
    }
}

启动服务，浏览器访问http://localhost:8000，服务实例列表已经增加了CLOUD-EUREKA-PROVIDER。

 

调用方消费者 eureka_consumer

1.pom.xml文件(可和生产者一样)

2.修改配置文件application.properties

# 服务名
spring.application.name=cloud-eureka-consumer
# 服务端口
server.port=8762

eureka.instance.hostname=localhost
eureka.client.service-url.defaultZone=http://localhost:8000/eureka/

3.添加控制器

package com.cc8w.controller;

import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

/**
 * 在控制器中，配置了RestTemplate的Bean，RestTemplate是spring-web模块下面的类，主要用来调用REST服务。
 * 本身不具有调用分布式服务的能力，但被@LoadBalanced注解修饰后，这个RestTemplate实例就具有访问调用分布式服务的能力。
 * 另外，下面调用服务，通过服务名称进行调用。
 */

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

    @RequestMapping(value = "/router", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
    public String router(){
        RestTemplate restTpl = getRestTemplate();
        //根据应用名称调用服务
        String json = restTpl.getForObject("http://cloud-eureka-provider/user/1", String.class);
        return json;
    }

}

4.添加启动器

package com.cc8w;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

/**
 * 添加注解@EnableDiscoveryClient，使得服务调用者可以去Eureka中发现服务。
 * 说明：@EnableDiscoveryClient注解已经包含了@EnableEurekaClient的功能。
 */
@SpringBootApplication
@EnableDiscoveryClient
public class EurekaConsumerApplication 
{
    public static void main( String[] args )
    {
        SpringApplication.run(EurekaConsumerApplication.class, args);
    }
}

启动服务，浏览器访问http://localhost:8000，服务实例列表又增加了CLOUD-EUREKA-CONSUMER。

备注：上面的红色粗体警告信息表示Eureka已经进入自我保护模式，暂时不用理会。

浏览器访问http://localhost:8762/router，页面输出：

{"id":1,"name":"cc8w"}

可知，成功调用了服务提供者的服务。

总结，本例子的结构图：

 代码在： https://gitee.com/fps2tao/javaboot_study/tree/master/springcloud_eureka_demo

转与参考：

https://www.cnblogs.com/gdjlc/p/11784681.html

https://www.cnblogs.com/e206842/p/11726734.html

https://www.cnblogs.com/xujie09/p/8469735.html

https://www.cnblogs.com/itgaofei/p/9334741.html

https://blog.csdn.net/weixin_42949808/article/details/108018471