`

SpringCloud（三）： 服务注册与发现，服务注册中心—Eureka

eurekaspring cloudspring cloud eureka服务注册中心服务注册发现 
阅读更多

 

编写不易，转载请注明（http://shihlei.iteye.com/blog/2400190）！

 

 一 服务注册与发现

（1）概述

服务调用基本两端：

服务提供者（Service Provider）、服务消费者（Service Client）

调用方式：

（a）简单版：

直接调用

优点：

简单，快速完成

缺点：

服务消费者感知服务端IP、Port，任何这二者修改，都可能引起客户端都需要修改，极端可能需要重新发布上线。

不利于服务HA。



 

 

 

（b）反向代理版：

在中间增加反向代理，服务消费者依赖反向代理服务器，屏蔽服务提供者后端物理架构。

特点：

客户端，服务器端无入侵性

传统反向代理定位HA和负载均衡，不具备自动注册新服务，添加服务新机能力，可以通过扩展反向代理服务器解决。



 

 

（c）服务注册中心版：

服务注册到中心中，服务消费者从中心获取服务IP、Port，再进行请求。

特点：

将核心的服务注册发现能力，已独立中间件形式提供。其实和反向代理的解决方案差不多。

 

 

 

 

（2）服务注册中心定位 

解决：

服务物理设备变动（ip，端口变动），造成客户端需要修改的问题。

目前业界大部分使用基于Docker云架构，提供弹性扩展能力，服务提供者IP，Port无法在发布时就给定，引入服务注册中心，可以适应这种变化。

 

主要提供功能：

1）服务注册发现

2）心跳同步

3）负载均衡

 

二 服务注册中心：Eureka

（1）概述：

Eureka：Netflix公司开发的服务发现中间件，用于服务的负载均衡和服务故障转移 

SpringCloud 集成了EurekaSever，让我们通过简单配置即可启动

git：https://github.com/Netflix/eureka

wiki：https://github.com/Netflix/eureka/wiki

架构：

（2）基于SpringCloud搭建EurekaServer：

搭建过程重用了《 SpringCloud（一）： SpringBoot 创建简单的微服务》中的项目，项目环境可点击查看。

 

第一步：创建项目，添加依赖：见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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <artifactId>spring-cloud-eureka-server</artifactId>
    <packaging>jar</packaging>

    <name>spring-cloud-eureka-server</name>
    <description>Demo project for Spring Boot</description>

    <parent>
        <groupId>x.demo.springcloud</groupId>
        <artifactId>spring-cloud</artifactId>
        <version>1.0-SNAPSHOT</version>
        <relativePath>../../pom.xml</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>
    </properties>

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

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

 

第二步：创建SpringCloud启动类，添加@EnableEurekaServer

package x.demo.springcloud.eureka.server;

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

@SpringBootApplication
@EnableEurekaServer
public class SpringCloudEurekaServerApplication {

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

 

第三步：配置EurekaServer相关信息：application.yml

spring:
  profiles: Standalone
  application:
    name: eureka-server-standalone
server:
  port: 8761
eureka:
  # 每个EurekaServer 都包含一个EurekaClient，用于请求其他节同步
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka
    # 单机版不注册到Eureka
    registerWithEureka: false
    fetchRegistry: false
  instance:
    # 指定实例名称，默认：${spring.cloud.client.hostname}:${spring.application.name}:${spring.application.instance_id:${server.port}}}
    instance-id: ${spring.application.name}:${spring.application.instance_id:${server.port}}

 

第四步：访问查看是否成功

 

 

 

 

（3）Eureka Server集群搭建

Eureka Server 集群主要是各个实例通过EurekaClieint 注册到其他实例（对等体Pear）中，保证服务注册表冗余。

注意：由于要操作必须在所有对等体上生效，服务修改才生效，所以有时候会慢。

规划：启动三个实例，互相注册对等体

Peer1：5001

Peer2：5002

Peer3：5003

第一步：项目如上

第二步：修改application.yml指定各个Peer配置，主要是端口及对等体

特别注意：我将多个Profile写在同一个文件中，咋样yml中约定“---”标识一个Profile

---
#HA 版: 通过运行多个实例并请求他们相互注册, 通过defaultZone 注定本实例要注册到哪些其他的节点
spring:
  profiles: Peer1
  application:
    name: eureka-server
server:
  port: 50001
eureka:
  client:
    service-url:
      defaultZone: http://localhost:50002/eureka/,http://localhost:50003/eureka/
  instance:
    instance-id: ${spring.application.name}:${spring.application.instance_id:${server.port}}

---
spring:
  profiles: Peer2
  application:
    name: eureka-server
server:
  port: 50002
eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:50001/eureka/,http://localhost:50003/eureka/
  instance:
    instance-id: ${spring.application.name}:${spring.application.instance_id:${server.port}}

---
spring:
  profiles: Peer3
  application:
    name: eureka-server
server:
  port: 50003
eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:50001/eureka/,http://localhost:50002/eureka/
  instance:
    instance-id: ${spring.application.name}:${spring.application.instance_id:${server.port}}

 

第三步：配置启动，idea添加启动操作，以Peer1为例，Peer2，Peer3同

注：第一个Peer启动的时候注册对等体报错正常，因为其他对等体还没启动

异常：com.sun.jersey.api.client.ClientHandlerException: java.net.ConnectException: Connection refused


 

第四步：访问页面验证


 

 

三 服务提供者，服务消费者集成EurekaClient

 

重用前面的项目：见《 SpringCloud（一）： SpringBoot 创建简单的微服务》，《SpringCloud（二）：声明式RestClient—Feign》

1）spring-cloud-microservice：微服务项目，实现获取当前时间服务
2）spring-cloud-webfront：前端项目，根据业务调用各种微服务，这里只是获取时间。

 

（1）服务提供者

第一步：依赖

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <artifactId>spring-cloud-microservice</artifactId>
    <packaging>jar</packaging>

    <name>spring-cloud-microservice</name>
    <description>Demo project for Spring Boot</description>

    <parent>
        <groupId>x.demo.springcloud</groupId>
        <artifactId>spring-cloud</artifactId>
        <version>1.0-SNAPSHOT</version>
        <relativePath>../../pom.xml</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>
    </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-eureka</artifactId>
        </dependency>

        <!--监控数据-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

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

        <!-- utils -->
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-lang3</artifactId>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

 

第二步：application.yml 配置 EurekaClient，做服务注册

server:
  port: 10001

# 服务名称
spring:
  application:
    name: microservice-time
eureka:
  client:
    service-url:
      defaultZone: http://localhost:50001/eureka/,http://localhost:50002/eureka/,http://localhost:50003/eureka/
  instance:
    instance-id: ${spring.application.name}:${spring.application.instance_id:${server.port}}
    prefer-ip-address: true

 

第三步：启动集成@EnableDiscoveryClient (可以用@EnableEurekaClient 替代)

package x.demo.springcloud.microservice;

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


@SpringBootApplication
@EnableDiscoveryClient
public class SpringCloudServiceApplication {

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

 第四步：页面查看注册 

 

   

 

（2）服务消费者

第一步：依赖

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <artifactId>spring-cloud-webfront</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>spring-cloud-webfront</name>
    <description>Demo project for Spring Boot</description>

    <parent>
        <groupId>x.demo.springcloud</groupId>
        <artifactId>spring-cloud</artifactId>
        <version>1.0-SNAPSHOT</version>
        <relativePath>../../pom.xml</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>
    </properties>

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

        <!-- spring -->
        <!-- spring boot -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!--rest client-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-feign</artifactId>
        </dependency>

        <!-- utils -->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

 

第二步：application.yml 配置 EurekaClient，做服务发现

server:
  port: 20001
spring:
  application:
    name: webfront
eureka:
  client:
    service-url:
      defaultZone: http://localhost:50001/eureka/,http://localhost:50002/eureka/,http://localhost:50003/eureka/
  instance:
    instance-id: ${spring.application.name}:${spring.application.instance_id:${server.port}}
    prefer-ip-address: true

 

 第三步：基于Feign的服务Client

package x.demo.springcloud.webfront.service.impl.feign;

import org.springframework.cloud.netflix.feign.FeignClient;
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.RequestParam;
import x.demo.springcloud.webfront.service.impl.ProtocolResult;

//name为服务提供者应用名称
@FeignClient(name = "microservice-time")
public interface TimeV1MicroServiceDiscoveryClient {

    @RequestMapping(method = RequestMethod.GET, value = "/time/v1/now", consumes = MediaType.APPLICATION_JSON_VALUE)
    ProtocolResult<String> now(@RequestParam(name = "format", required = false) String format);
}

第四步：Service，Controller

package x.demo.springcloud.webfront.service;

public interface TimeService {
    /**
     * 获取当前时间
     * @return 当前时间，格式：yyyy-MM-dd HH:mm:ss
     */
    String now();
}

 

@Service("timeV1FeignImpl")
public class TimeV1FeignImpl implements TimeService {

    @Resource
    private TimeV1MicroServiceDiscoveryClient timeV1MicroServiceDiscoveryClient;

    /**
     * 获取当前时间
     *
     * @return 当前时间，格式：yyyy-MM-dd HH:mm:ss
     */
    @Override
    public String now() {
        ProtocolResult<String> result = timeV1MicroServiceDiscoveryClient.now(null);
        return result.getBody();
    }
}

  

package x.demo.springcloud.webfront.web;

import javax.annotation.Resource;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import x.demo.springcloud.webfront.service.TimeService;

@RestController
@RequestMapping("/time")
public class TimeController {

    @Resource(name = "timeV1FeignImpl")
    private TimeService timeService;

    @GetMapping("/now")
    public String now() {
        return timeService.now();
    }
}

 

 第五步：启动集成@EnableDiscoveryClient (可以用@EnableEurekaClient 替代)

package x.demo.springcloud.webfront;

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

@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
public class SpringCloudWebfrontApplication {

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

 

第六步：验证


 

 

四 参考

https://springcloud.cc/spring-cloud-dalston.html  

 

  • 大小: 10.1 KB
  • 大小: 10.5 KB
  • 大小: 23.8 KB
  • 大小: 46.2 KB
  • 大小: 166.1 KB
  • 大小: 87.7 KB
  • 大小: 231 KB
  • 大小: 179.2 KB
  • 大小: 172.2 KB
  • 大小: 25 KB
分享到：
| SpringCloud（二）：声明式RestClient—Fe ...
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    01Spring Cloud Eureka：服务注册与发现1

    "Spring Cloud Eureka：服务注册与发现" Spring Cloud Eureka是Spring Cloud Netflix子项目的核心组件之一，主要用于微服务架构中的服务治理。Eureka是服务注册与发现机制的实现，它允许微服务在注册中心注册自己...

    spring-cloud-eureka 服务注册及发现实例

    在这个实例中，我们将探讨如何利用 Spring Cloud Eureka 实现服务注册与发现，以及相关的配置和实践。 首先，Spring Boot 是一个快速开发框架，它简化了创建独立、生产级别的基于 Spring 的应用程序。版本 2.1.10....

    springcloud+注册中心eureka+配置中心demo

    总结，SpringCloud Eureka作为服务注册与发现中心，使得服务实例能够被其他服务发现和调用；而SpringCloud Config作为配置中心，实现了配置的集中管理和动态更新。在实际的Demo项目中，这两个组件的集成使得微服务...

    spring cloud eureka服务注册与发现

    Spring Cloud Eureka是Spring Cloud框架中的一个核心组件，主要用于实现微服务架构中的服务注册与发现功能。在微服务架构中，服务之间的通信依赖于服务发现机制，Eureka就是扮演这个角色，帮助各个微服务实例自动...

    spring cloud eureka 注册中心客户端

    Spring Cloud Eureka是Netflix开发的服务发现组件，它在微服务架构中扮演着核心角色，用于管理服务实例的注册与发现。Eureka客户端是Eureka生态系统的一部分，它允许微服务应用注册到Eureka服务器并获取其他服务的...

    spring cloud eureka（免费下载）

    Spring Cloud Eureka是Spring Cloud框架中的一个核心组件，主要用于实现微服务之间的服务发现和服务治理。在微服务架构中，每个服务可能都会独立部署和扩展，Eureka作为一个服务注册中心，帮助各个服务实例进行注册...

    SpringCloud-服务注册与实现-Eureka创建服务提供者示例源码.zip

    本项目"SpringCloud-服务注册与实现-Eureka创建服务提供者示例源码"将深入探讨如何构建一个基于Eureka的服务提供者。 首先，我们需要了解Eureka的基本概念。Eureka由两部分组成：Eureka Server（服务注册中心）和...

    springcloud eureka 服务注册中心

    **SpringCloud Eureka 服务注册中心** 在微服务架构中，服务发现是核心组件之一，它使得服务之间能够互相找到并进行通信。Spring Cloud Eureka 就是这样的一个服务注册与发现工具，它是 Netflix 提供的开源项目，是...

    Spring Cloud eureka服务注册DEMO

    我们将基于提供的"Spring Cloud Eureka服务注册DEMO"来理解其核心概念，并探索如何通过三个Spring Boot应用——服务注册模块、服务提供模块和服务发现与消费模块——实现服务注册与发现。 1. **Eureka概述**： ...

    springcloud eureka服务注册中心 最新版本2.x.x

    SpringCloud Eureka是微服务架构中的关键组件，它作为一个服务注册与发现的工具，使得服务之间的调用变得简单。在最新版本2.x.x中，Eureka提供了更稳定、高效的特性来支持大规模分布式系统的构建。 首先，让我们...

    SpringCloud学习之服务注册与发现

    `springCloud_01_client1`和`springCloud_01_client2`则是服务客户端的代码，每个客户端项目都需要引入Spring Cloud的Eureka客户端依赖，以实现服务注册和发现功能。在这些客户端项目中，开发者需要配置服务提供者的...

    10Spring Cloud Consul：服务治理与配置中心1

    2. 创建应用注册到 Consul：我们可以通过改造 user-service 和 ribbon-service 来演示下服务注册与发现的功能，主要是将应用原来的 Eureka 注册中心支持改为 Consul 注册中心支持。创建 consul-user-service 模块和 ...

    最简单的 SpringCloud 教程——服务的注册与发现（Eureka）

    在本教程中，我们将深入探讨SpringCloud的核心组件之一——Eureka，它是一个服务注册与发现的工具，使得微服务架构中的各个服务能够互相找到并进行通信。我们将通过两个主要步骤来学习如何使用Eureka：创建服务注册...

    SpringCloud——服务的注册与发现Eureka

    SpringCloud是中国开发者广泛使用的微服务框架之一，其中Eureka是其核心组件，主要负责服务的注册与发现。本文将深入探讨Eureka的工作原理、配置以及如何在实际项目中使用它来构建服务注册中心和实现服务提供者的...

    springcloud注册中心Eureka集群示例代码.zip

    服务提供者（如 springcloud-member 和 springcloud-order）向 Eureka 注册自己的服务，而服务消费者则可以通过 Eureka 获取到可用的服务实例列表进行调用。 1. **Eureka 集群搭建**： 在这个示例中，我们有 `...

    SpringCloud基础概念与入门+SpringCloud核心组件Eureka服务注册与发现等全套教程

    SpringCloud核心组件Eureka服务注册与发现 SpringCloud核心组件Ribbon负载均衡 SpringCloud核心组件Feign声明式服务调用 SpringCloud核心组件Hystrix断路器与容错机制 SpringCloud核心组件ZuulAPI网关 SpringCloud...

    SpringCloud+eureka+gateway.zip

    Eureka是SpringCloud中的服务注册与发现组件，它允许服务提供者注册自己的服务，并让服务消费者能够发现并调用这些服务。Eureka服务器作为服务注册中心，负责存储、检索服务实例的信息。服务提供者启动时向Eureka...

    springcloud之eureka注册服务与发现

    在Spring Cloud生态系统中，Eureka是核心组件之一，主要用于服务的注册与发现。Eureka的工作原理、使用方式以及源码分析对于理解微服务架构中的服务治理至关重要。下面将详细阐述Eureka的相关知识点。 1. **Eureka...

Magicbox
Global site tag (gtag.js) - Google Analytics