热门标签 | 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


推荐阅读
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社区 版权所有