热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

【SpringCloud微服务实战学习系列】服务治理SpringCloudEureka

SpringCloudEureka是SpringCloudNetflix微服务中的一部分,它基于NetFlixSureka做了二次封装,主要负责完成微服务架构中的服务治理功能。服务

Spring Cloud Eureka是Spring Cloud Netflix微服务中的一部分,它基于NetFlix Sureka做了二次封装,主要负责完成微服务架构中的服务治理功能。

服务治理是微服务架构中最为核心和基础的模块。它主要用来实现各个微服务实例的自动化注册与发现。

为了解决微服务架构中的服务实例维护问题,产生了大量的服务治理框架和产品,这下框架和产品的实现都围绕着服务注册与服务发现机制来完成对微服务应用实例的自动化管理。

1、服务注册

在服务治理框架中,通常都会构建一个注册中心,每个服务单元向注册中心登记自己提供的服务,将主机与端口号、版本号、通信协议等一些附加信息告知注册中心,注册中心按服务名分类组织服务清单。比如,我们有两个提供服务A的进程分别用于192.168.0.100:8080和192.168.1.101:8080位置上,另外还有三个提供服务B的进程分别运行于192.168.0.100:9090、192.168.0.101:9090、192.168.0.102:9090位置上,当这些线程均启动、并向注册中心注册自己的服务之后,注册中会就会维护类型如下非服务清单。另外,服务注册中心还需要以心跳的方式去监测清单中的服务是否可用,若不可用需要从服务清单中剔除,达到排除故障服务的效果。

2、服务发现

由于在服务治理框架下运作,服务间的调用不再需要通过指定具体的实例地址来实现,而是通过向服务名发起请求调用实现,所以,服务调用方在调用服务提供方的时候,并不知道具体的服务实例位置。因此,调用方需要向服务注册中心咨询服务,并获取所有服务的实例清单,以实现对具体服务实例的访问。比如:现有服务C希望调用服务A,服务C就需要向注册中心发起咨询服务请求,服务注册中心就会将服务A的位置清单返回给服务C,如按上例服务A的情况。服务C便获得了服务A的两个可用位置192.168.0.100:8080和192.168.1.101:8080。当服务C要发起调用的时候便从该清单中以某种轮询策略取出一个位置来进行服务调用,这就是后续我们将要介绍的负载均衡,

二、Netflix Eureka

Spring Cloud Eureka,使用Netflix Eureka来实现服务注册与发现,它既包含 服务端组件,也包含了客户端组件,并且服务端与客户端组件均采用java编写,所以Eureka主要使用于通过java实现的分布式系统,或是与JVM兼容语言构建的系统,但是由于Eureka服务端的服务治理机制提供了完备的RESTful API,所以它也支持非java语言构建的微服务应用纳入Eureka的服务治理体系中来,只是在使用其他语言平台的时候需要租户来实现Eureka的客户端程序。

Eureka服务端,我们也称为服务注册中心,它通其他服务注册中心一样,支持高可用配置。它依托于强一致性提供良好的服务实例可用性,可以应对多种不同的故障场景。如果Eureka以集群模式部署,当集群中有分片出现故障时,那么Eureka就转入自我保护模式,它允许在分片故障期间继续提供服务的发行和注册,当故障分片回复运行时,集群中的其他分片会把他们的状态再次同步回来。以在AWS上的实践为例,Netflix推荐每个可用的区域运营一个Eureka服务端,通过它来形成集群。不同可用区域的服务注册中心通过异步模式互相复制格子的状态,这意味着在任何给定的时间点每个实例关于所有服务的状态是有细微差别的。

Eureka客户端。主要处理服务的注册与发现。客户端服务通过注册和参数配置的方式,嵌入在客户端应用程序的代码中,在应用程序运行时,Eureka客户端向注册中心注册自身提供的服务并周期性的发生心跳来更新它的服务租约。同时,它也能从服务端查询当前注册的服务消息并把他们缓存到本地并周期性的刷新服务状态。

 三、搭建服务注册中心

1、pom.xml

  1 "1.0" encoding="UTF-8"?>
  2 "http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4     4.0.0
  5 
  6     com.slp
  7     eureka-server
  8     0.0.1-SNAPSHOT
  9     jar
 10 
 11     eureka-server
 12     Demo project for Spring Boot
 13 
 14     
 15         org.springframework.boot
 16         spring-boot-starter-parent
 17         1.3.7.RELEASE
 18          
 19     
 20 
 21     
 22         UTF-8
 23         UTF-8
 24         1.8
 25     
 26 
 27     
 28         
 29             org.springframework.boot
 30             spring-boot-starter
 31         
 32         
 33             org.springframework.boot
 34             spring-boot-starter-web
 35         
 36         
 37             org.springframework.boot
 38             spring-boot-starter-test
 39             test
 40         
 41         
 42         
 43             org.springframework.cloud
 44             spring-cloud-starter-eureka-server
 45         
 46         
 47     
 48 
 49     
 50         
 51             
 52                 org.springframework.boot
 53                 spring-boot-maven-plugin
 54             
 55         
 56     
 57 
 58     
 59         
 60             spring-snapshots
 61             Spring Snapshots
 62             https://repo.spring.io/snapshot
 63             
 64                 true
 65             
 66         
 67         
 68             spring-milestones
 69             Spring Milestones
 70             https://repo.spring.io/milestone
 71             
 72                 false
 73             
 74         
 75     
 76 
 77     
 78         
 79             spring-snapshots
 80             Spring Snapshots
 81             https://repo.spring.io/snapshot
 82             
 83                 true
 84             
 85         
 86         
 87             spring-milestones
 88             Spring Milestones
 89             https://repo.spring.io/milestone
 90             
 91                 false
 92             
 93         
 94     
 95 
 96 
 97 
 98     
 99 
100         
101             org.springframework.cloud
102             spring-cloud-dependencies
103             Brixton.SR5
104             pom
105             import
106         
107     
108 
109 

2、通过@EnableEurekaServer注解启动一个服务注册中心提供给其他应用进行对话

 1 package com.slp.eurekaserver;
 2 
 3 import org.springframework.boot.SpringApplication;
 4 import org.springframework.boot.autoconfigure.SpringBootApplication;
 5 import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
 6 
 7 /**
 8  * 通过@EnableEurekaServer注解启动一个服务注册中心提供给其他应用进行注册
 9  */
10 @EnableEurekaServer
11 @SpringBootApplication
12 public class EurekaServerApplication {
13 
14     public static void main(String[] args) {
15         SpringApplication.run(EurekaServerApplication.class, args);
16     }
17 }

3、默认设置下,该服务注册中心会将自己作为客户端来尝试注册自己,所以先禁用它自己的注册行为

application.properties

server.port=1111
eureka.instance.hostname=localhost
eureka.client.register-with-eureka=false 
eureka.client.fetch-registry=false
eureka.client.serviceUrl.defaultZone=http://${eureka.instance.hostname}:${server.port}/eureka/
eureka.client.register-with-eureka:设置为false表示不向注册中心注册自己
eureka.client.fetch-registry:注册中的职责是维护服务实例,它不需要去检索服务,所以设置为false



 

4、访问http://localhost:1111

【SpringCloud微服务实战学习系列】服务治理Spring Cloud Eureka

现在Instance currently registed with Eureka还是空的,说明目前该注册中心还没有注册任何服务。

 四、注册服务提供者

在完成上述的服务中心注册之后,我们尝试加入之前的项目到服务治理体系中去。

1、pom.xml

 1 "1.0" encoding="UTF-8"?>
 2 "http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 3     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 4     4.0.0
 5 
 6     com.slp
 7     springBoot
 8     0.0.1-SNAPSHOT
 9     jar
10 
11     springBoot
12     Demo project for Spring Boot
13 
14     
15         
16         org.springframework.boot
17         spring-boot-starter-parent
18         1.3.7.RELEASE
19          
20     
21 
22     
23         UTF-8
24         UTF-8
25         1.8
26     
27 
28     
29         
30             
31             org.springframework.boot
32             spring-boot-starter-web
33         
34 
35         
36             
37             org.springframework.boot
38             spring-boot-starter-test
39             test
40         
41         
42             
43             org.springframework.boot
44             spring-boot-starter-actuator
45         
46         
47         
48             org.springframework.cloud
49             spring-cloud-starter-eureka
50         
51     
52 
53     
54 
55         
56 
57             
58                 org.springframework.cloud
59                 spring-cloud-dependencies
60                 Brixton.SR5
61                 pom
62                 import
63             
64         
65     
66     
67         
68             
69                 org.springframework.boot
70                 spring-boot-maven-plugin
71             
72         
73     
74 
75 
76 

2、HelloController.java

package com.slp.web;

import com.slp.service.UserService;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.stereotype.Controller;
import org.springframework.ui.ModelMap;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;



/**
 * @author sanglp
 * @create 2018-06-28 8:39
 * @desc 第一个 controller
 **/

@Controller
public class HelloController {
    private final Logger logger = Logger.getLogger(getClass());
    @Autowired
    private DiscoveryClient client;

    @RequestMapping(value = "helloindex",method = RequestMethod.GET)
    public  String helloindex(ModelMap map){
        ServiceInstance instance = client.getLocalServiceInstance();
        logger.info("/hello ,host:"+instance.getHost()+", service_id:"+instance.getServiceId());
       return "helloindex";
    }
}

3、Application.java

package com.slp;

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

/**
 * 在主类中通过加上@EnableDiscoveryClient注解,激活Eureka中的DiscoveryClient实现(自动化配置,创建DiscoveryClient接口针对Eureka客户端的EurekaDiscoveryClient实例)
 */
@EnableDiscoveryClient
@SpringBootApplication
public class Application {

    public static void main(String[] args) {
        //jar包包含Tomcat
        SpringApplication.run(Application.class, args);
    }
}

4、在application.properties配置文件中,通过spring.application.name属性来为服务命名,再通过eureka.client.serviceUrl.defaultZone属性来指定服务注册中心的地址

1 spring.application.name=hello-service
2 eureka.client.serviceUrl.defaultZOne=http://localhost:1111/eureka/

5、启动注册服务提供者

注册提供者控制台:

1 2018-07-10 09:11:29.163  INFO 17484 --- [nfoReplicator-0] com.netflix.discovery.DiscoveryClient    : DiscoveryClient_HELLO-SERVICE/windows10.microdone.cn:hello-service - registration status: 204

注册中心控制台:

1 2018-07-10 09:11:29.154  INFO 18928 --- [io-1111-exec-10] c.n.e.registry.AbstractInstanceRegistry  : Registered instance HELLO-SERVICE/windows10.microdone.cn:hello-service with status UP (replication=false)

【SpringCloud微服务实战学习系列】服务治理Spring Cloud Eureka


推荐阅读
  • 服务网关与流量网关
    一、为什么需要服务网关1、什么是服务网关传统的单体架构中只需要开放一个服务给客户端调用,但是微服务架构中是将一个系统拆分成多个微服务,如果没有网关& ... [详细]
  • Activiti7流程定义开发笔记
    本文介绍了Activiti7流程定义的开发笔记,包括流程定义的概念、使用activiti-explorer和activiti-eclipse-designer进行建模的方式,以及生成流程图的方法。还介绍了流程定义部署的概念和步骤,包括将bpmn和png文件添加部署到activiti数据库中的方法,以及使用ZIP包进行部署的方式。同时还提到了activiti.cfg.xml文件的作用。 ... [详细]
  • Sleuth+zipkin链路追踪SpringCloud微服务的解决方案
    在庞大的微服务群中,随着业务扩展,微服务个数增多,系统调用链路复杂化。Sleuth+zipkin是解决SpringCloud微服务定位和追踪的方案。通过TraceId将不同服务调用的日志串联起来,实现请求链路跟踪。通过Feign调用和Request传递TraceId,将整个调用链路的服务日志归组合并,提供定位和追踪的功能。 ... [详细]
  • 云原生应用最佳开发实践之十二原则(12factor)
    目录简介一、基准代码二、依赖三、配置四、后端配置五、构建、发布、运行六、进程七、端口绑定八、并发九、易处理十、开发与线上环境等价十一、日志十二、进程管理当 ... [详细]
  • 熟练掌握Spring Cloud,终于成为Java工程师的面试门槛 ... [详细]
  • 开发笔记:(002)spring容器中bean初始化销毁时执行的方法及其3种实现方式
    篇首语:本文由编程笔记#小编为大家整理,主要介绍了(002)spring容器中bean初始化销毁时执行的方法及其3种实现方式相关的知识,希望对你有一定的参考价值。 ... [详细]
  • k8s+springboot+Eureka如何平滑上下线服务
    k8s+springboot+Eureka如何平滑上下线服务目录服务平滑上下线-k8s版本目录“上篇介绍了springboot+Euraka服务平滑上下线的方式,有部分小伙伴反馈k ... [详细]
  • ZooKeeper 学习
    前言相信大家对ZooKeeper应该不算陌生。但是你真的了解ZooKeeper是个什么东西吗?如果别人面试官让你给他讲讲ZooKeeper是个什么东西, ... [详细]
  • 本文讨论了Alink回归预测的不完善问题,指出目前主要针对Python做案例,对其他语言支持不足。同时介绍了pom.xml文件的基本结构和使用方法,以及Maven的相关知识。最后,对Alink回归预测的未来发展提出了期待。 ... [详细]
  • 一句话解决高并发的核心原则
    本文介绍了解决高并发的核心原则,即将用户访问请求尽量往前推,避免访问CDN、静态服务器、动态服务器、数据库和存储,从而实现高性能、高并发、高可扩展的网站架构。同时提到了Google的成功案例,以及适用于千万级别PV站和亿级PV网站的架构层次。 ... [详细]
  • Java如何导入和导出Excel文件的方法和步骤详解
    本文详细介绍了在SpringBoot中使用Java导入和导出Excel文件的方法和步骤,包括添加操作Excel的依赖、自定义注解等。文章还提供了示例代码,并将代码上传至GitHub供访问。 ... [详细]
  • [翻译]微服务设计模式5. 服务发现服务端服务发现
    服务之间需要互相调用,在单体架构中,服务之间的互相调用直接通过编程语言层面的方法调用就搞定了。在传统的分布式应用的部署中,服务地 ... [详细]
  • 14亿人的大项目,腾讯云数据库拿下!
    全国人 ... [详细]
  • DockerDataCenter系列(四)-离线安装UCP和DTR,Go语言社区,Golang程序员人脉社 ... [详细]
  • TiDB | TiDB在5A级物流企业核心系统的应用与实践
    TiDB在5A级物流企业核心系统的应用与实践前言一、业务背景科捷物流概况神州金库简介二、现状与挑战神州金库现有技术体系业务挑战应对方案三、TiDB解决方案测试迁移收益问题四、说在最 ... [详细]
author-avatar
516837745_d2d52c
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有