Eureka注册中心

一、前言

　　服务治理是微服务架构体系中，不可或缺的重要的一部分。SpringCloud 中对 Netflix Eureka 进行了再封装，将其作为默认的推荐的服务注册中心。Spring Cloud Eureka 是一个基于 Rest 的服务，提供了基于 Java 的客户端，非常方便快捷的使用。

　　注册中心的存在，可以很好的隔绝生产者和消费者。当你需要调用某一个服务的时候，你不需要知道服务的具体实现细节，也不需要知道具体的是有多少的服务提供方在工作。你只需要去 Eureka 中去哪去服务列表，查看其中是否有你需要的服务，如果在其中，这获取服务地址、端口等信息，然后进行调用。

　　下面的配置使用过程中，均需要一些共同的 jar 依赖，故创建一个 maven 父工程，取名 nativecloud，具体pom配置如下：

<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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <groupId>com.cfang</groupId>
  <artifactId>nativecloud</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>pom</packaging>

  <parent>
      <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.0.3.RELEASE</version>
    <!-- 设置查找顺序：relativePath元素中的地址–本地仓库–远程仓库。 如果为空，则始终从仓库获取，不获取本地路径-->
    <relativePath/>
  </parent>

  <properties>
      <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
      <java.version>1.8</java.version>
      <spring-cloud.version>Finchley.RELEASE</spring-cloud.version>
      <fastjson.version>1.2.58</fastjson.version>
      <druid.version>1.1.18</druid.version>
  </properties>

  <modules>
       <module>nativeEureka</module>
       <module>nativefshService</module>
       <module>nativefshsubService</module>
   </modules>

  <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>
         <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>${fastjson.version}</version>
        </dependency>
        <dependency>
            <groupId>com.google.guava</groupId>
            <artifactId>guava</artifactId>
            <version>28.0-jre</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>${druid.version}</version>
        </dependency>
      </dependencies>
   </dependencyManagement>

   <dependencies>
           <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-lang3</artifactId>
        </dependency>
        <dependency>
            <groupId>commons-codec</groupId>
            <artifactId>commons-codec</artifactId>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <scope>provided</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
          </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
   </dependencies>

</project>

二、单机版 Eureka 配置使用

　　1、创建 maven 子工程 nativeEureka ，工程的 pom 配置如下:

<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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <parent>
    <groupId>com.cfang</groupId>
    <artifactId>nativecloud</artifactId>
    <version>0.0.1-SNAPSHOT</version>
  </parent>
  <artifactId>nativeEureka</artifactId>

  <dependencies>
          <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka-server</artifactId>
            <version>1.4.7.RELEASE</version>
        </dependency>
  </dependencies>

</project>

　　2、新建启动类 NativeEurekaApplication

package com.cfang;

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

@SpringBootApplication
@EnableEurekaServer
public class NativeEurekaApplication {

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

　　3、新建配置文件 application.properties

　　在 src/main/resources 目录下，新建 application.properties 配置文件：

server.port=8081
spring.application.name=nativeEureka

eureka.instance.hostname= server1
#是否将自己作为客户端注册到注册中心：false-不注册
eureka.client.register-with-eureka=false
#是否需要从注册中心检索获取服务的注册信息。默认值为true
#单机版的可设置成false，集群版的由于需要同步其他节点的服务注册数据，故设成true。
eureka.client.fetch-registry=false
#是否开启自我保护模式，默认值true
#eureka server默认在运行期间会去统计心跳失败比例在 15 分钟之内是否低于 85%，如果低于 85%，Eureka Server 会将这些实例保护起来，让这些实例不会过期，
#但是在保护期内如果服务刚好这个服务提供者非正常下线了，此时服务消费者就会拿到一个无效的服务实例，此时会调用失败
eureka.server.enable-self-preservation=false
#扫描失效服务的间隔时间，单位毫秒，默认值 60 * 1000
eureka.server.eviction-interval-timer-in-ms=10000
#服务地址
eureka.client.service-url.defaultZone= http://server1:8081/eureka/

　　其中，server1 是修改的本地 hosts 文件。

　　4、启动

　　直接运行 NativeEurekaApplication 就可以了启动注册中心服务了。由于在配置文件 application.properties 中配置的端口号为 8081，故可以直接在浏览器中输入 http://localhost:8081/ 进行Eureka控制绕的查看：

　　

三、服务提供者

　　编写个服务提供者，并注册到上面启动好的 Eureka 注册中心中去，并暴露一个 Rest 接口。

　　1、创建 maven 子工程 nativefshService ，工程 pom 配置如下：

<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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <parent>
    <groupId>com.cfang</groupId>
    <artifactId>nativecloud</artifactId>
    <version>0.0.1-SNAPSHOT</version>
  </parent>
  <artifactId>nativefshService</artifactId>

  <dependencies>
        <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-web</artifactId>
        </dependency>
  </dependencies>
</project>

　　2、src/main/resources 目录下，新建 application.properties 配置文件：

server.port=8701
spring.application.name=nativefshService

#是否将自己作为客户端注册到注册中心：false-不注册
eureka.client.register-with-eureka=true
#服务地址
eureka.client.service-url.defaultZone= http://server1:8081/eureka/

　　3、提供 REST 接口

package com.cfang.facade;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/user")
public class UserController {

    @GetMapping("/hello")
    public String hello() {
        return "hello world!";
    }
}

　　4、新建启动类 NativefshServiceApplication

package com.cfang;

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

@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
@EnableEurekaClient
public class NativefshServiceApplication {

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

　　编写好启动类，直接运行。查看控制台输出：

　　或者在 Eureka 注册中心页面上查看

　　说明服务已正常启动并注册到 Eureka 中。

　　5、验证 REST 接口可用性

　　浏览器测试访问 http://localhost:8701/user/hello , 打印出  hello world! 字符串，说明服务接口正常启用。

四、服务消费者

　　创建个服务的消费者，调用上面的 /user/hello 服务。

　　1、创建 maven 子工程 nativefshsubService，工程 pom 配置如下

<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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <parent>
    <groupId>com.cfang</groupId>
    <artifactId>nativecloud</artifactId>
    <version>0.0.1-SNAPSHOT</version>
  </parent>
  <artifactId>nativefshsubService</artifactId>

  <dependencies>
          <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
        </dependency>
  </dependencies>
</project>

　　2、配置文件 application.properties

server.port=8702
spring.application.name=nativefshsubService

#是否将自己作为客户端注册到注册中心：false-不注册
eureka.client.register-with-eureka=true
#服务地址
eureka.client.service-url.defaultZone= http://server1:8081/eureka/

　　3、RestTemplate 配置

package com.cfang.config;

import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

@Configuration
public class CommonConfiguration {

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

　　4、调用

package com.cfang.Controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@RestController
@RequestMapping("/test")
public class TestController {

    @Autowired
    private RestTemplate restTemplate;

    /**
     *    直接调用
     */
    @GetMapping("callHello")
    public String callHello() {
        return restTemplate.getForObject("http://server1:8701/user/hello", String.class);
    }

    /**
     *    通过 Eureka 调用
     */
    @GetMapping("callHello2")
    public String callHello2() {
        return restTemplate.getForObject("http://nativefshService/user/hello", String.class);
    }
}

　　5、创建启动类 NativefshsubServiceApplication

package com.cfang;

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

@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
@EnableDiscoveryClient
public class NativefshsubServiceApplication {

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

　　直接运行 main 方法启动。浏览器中输入 http://localhost:8702/test/callHello ，显示 hello world! 字符串则说明正常调用接口。

　　6、通过 Eureka 调用

　　上面的第 3 步配置 RestTemplate 中，去除注解 @LoadBalanced 的行注释。重启应用，浏览器中通过访问  http://localhost:8702/test/callHello2，显示  hello world！字符串，接口正常调用。

　　关于注解 @LoadBalanced ，后续文章中还会有说明使用。

五、总结

　　主要的介绍使用单机版的 Eureka 注册中心、服务的提供注册、服务的消费注册以及通过 Eureka 来管理注册的服务接口信息。后续中，将介绍 Eureka 的高可用搭建、Eureka 的安全认证以及常用的 Eureka 的配置项信息。

原文地址：https://www.cnblogs.com/eric-fang/p/11316463.html

时间： 2024-08-30 12:45:04

Eureka注册中心的相关文章

【码上微服务】- 环境搭建 - Eureka注册中心

一.前言 本章将讲述基于Spring Cloud的注册中心Eureka的简单工程搭建及Docker部署. 二.环境准备 操作系统:CentOS 7.2 项目管理:MAVEN(推荐使用阿里源中央仓库:http://maven.aliyun.com/nexus/content/repositories/central/) 开发IDE:IDEA 所用语言:JAVA 所用容器:Docker 三. Eureka注册中心项目搭建 JAVA工程创建(这里使用了IDEA) 相关的pom.xml <?xml ve

eureka注册中心单机

Spring Cloud 2.x系列之 eureka注册中心单机 一.简介 Spring Cloud Eureka是Spring Cloud Netflix项目下的服务治理模块.而Spring Cloud Netflix项目是Spring Cloud的子项目之一,主要内容是对Netflix公司一系列开源产品的包装,它为Spring Boot应用提供了自配置的Netflix OSS整合.通过一些简单的注解,开发者就可以快速的在应用中配置一下常用模块并构建庞大的分布式系统.它主要提供的模块包括:服务

eureka注册中心出现了一些莫名其妙的服务。

eureka注册中心出现了一些莫名其妙的服务.导致原来的路径没有找到 首先关闭服务器的自我保护.一旦断开就删掉微服务.防止有些已经停掉的服务仍然在注册中心里. 另外加上安全验证,防止一些体系之外的服务误打误撞地注册进来. 注册中心的pom文件引入 配置文件 加上一个配置类 然后所有的client都加上 运行起来 原文地址:https://www.cnblogs.com/zhanying999666/p/9967507.html

SpringCloud Eureka(注册中心集群)

多个注册中心,其实用不同的配置对应 不同的端口号注册就行了. 注册中心自己也是个服务,看看之前的单个注册中心是怎么样的呢? server: port: 8888 # 服务端口eureka: instance: hostname: localhost # 设置主机名 client: registerWithEureka: false # 是否向 Eureka 注册服务.该应用为服务注册中心,不需要自注册,设置为 false fetchRegistry: false # 是否检索服务.该应用为服务注

SpringCloud(一)Eureka注册中心

Eureka简介 Eureka作为注册中心,管理各种服务功能包括服务的注册.发现.熔断.负载.降级等 Eureka注册中心实例 Eureka Server 1.pom文件配置SpringBoot.SpringCloud的依赖: 2.启动类配置 @EnableEurekaServer 注解,表示注册中心: /** * SpringCloud是基于SpringBoot的,这是一个启动类的注解 */ @SpringBootApplication /** * 这是注册中心Eureka的注解 */ @En

springCloud Eureka注册中心原理及配置理解

Eureka 配置流程 原理:     服务提供方启动后将注册到 注册中心,提供IP, 名字,什么服务等信息, 服务调用方作为客户端注册到注册中心后,拉取注册中心的服务列表,在通过负载均衡调用对应的服务提供方. 注册中心可以建立集群,生成多台eureka,注册中心为了监测各个服务的心跳,将在每30S 向所注册的服务发起请求判断 服务是否挂掉,如果挂掉90S后将会将服务从注册中心剔除. 一个服务可以监测多台服务实例,从而可实现均很负载. 配置步骤:  一.加依赖 以下指POM文件 <!--注册中心

Eureka注册中心（上）

Eureka简介 Eureka是Netflix开发的服务发现框架,本身是一个基于REST的服务,主要用于定位运行在AWS域中的中间层服务,以达到负载均衡和中间层服务故障转移的目的.SpringCloud将它集成在其子项目spring-cloud-netflix中,以实现SpringCloud的服务发现功能. Eureka组件 Eureka包含两个组件:Eureka Server和Eureka Client. Eureka Server Eureka Server提供服务注册服务,各个节点启动后,

这个注册的 IP 网络都不通了，Eureka 注册中心竟然无法踢掉它！

本文导读: 微服务技术架构选型介绍 k8s 容器化部署架构方案 Eureka 注册中心问题场景 问题解决手段及原理剖析 阅读本文建议先了解: 注册中心基本原理 K8s(Kuberneters)基本概念 我们的微服务目前都是在服务器上部署的,也是基于 Docker 来部署的. 运维部门基于 K8s 自研了一套容器云管理平台,平台名称叫做 Ares,我们也开始准备将微服务迁移到这平台上,降低虚拟机或实体机服务器运维成本,提高服务器资源利用效率. Ares:阿瑞斯(战神) 希腊神话中为战争而生的神,奥

SpringCloud学习心得—1.2—Eureka注册中心的密码认证、高可用的设置

SpringCloud学习心得—1.2—Eureka注册中心的密码认证.高可用的设置 这是相关代码 链接 Eureka开启密码配置 添加依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-security</artifactId> </dependency> 向properties添加密码与用户名 spr