spring cloud简介及spring cloud Eureka快速入门

最近重新梳理spring Cloud技术,从源码层次的角度来理解spring Cloud这门技术

单体架构

一个归档包包含了应用所有功能的应用程序, 我们通常称之为单体应用。
架构单体应用的架构风格, 我们称之为单体架构, 这是一种比较传统的架构风格。

单体架构.png

单体架构的缺陷在哪里呢?笔者从这些方面来谈谈

  • 代码重复问题 比如说用户服务和订单服务因为在一个项目下不同的包下,但是订单相关的服务需要用户服务的一些接口,直接查询用户相关的表直接查询,然后提供给自己的订单服务自己使用,这就造成了很多代码的重复,很多sql查询直接出现在订单服务的Dao和Service层,类似的情况,比如说支付服务也需要类似的用户数据等等。
  • 环境依赖问题 每个服务依赖的外部环境不一样,比如说订单服务依赖于kafka,商品服务依赖于es等等,但是在准备资源的时候可能上线商品服务,就忽略了订单服务的依赖环境的问题,比如说订单服务上线前要创建一些队列啥的,或者要初始化自己服务的一些数据,但是因为在单体应用中,这块可能因为商品服务相关服务发版,造成订单服务的问题等等
  • 扩容问题 每个服务的压力不一样,可能订单服务更快的达到瓶颈,需要扩容,但是用户服务在单体应用中的内存中维护了一些用户状态,不能进行扩容;还有就是只是你订单服务的扩容,为什么用户服务我也要承担相应的风险。
  • 可用性问题 一个模块的崩溃会造成整个服务的不可用,造成整个cpu 100%,出现oom,jvm内存溢出,整个系统的不可用。

还有比如说git冲突,功能冲突,每次迭代不同服务的模块,合并分支都要进行全部服务的回归测试等等,问题很多于是就出现了微服务架构。

什么是微服务架构

微服务架构源于Martin Fowler的一篇博文地址.

微服务架构就是为了解决单体应用架构的这些问题,服务之间的交互通过接口的方式来实现,每个服务独立运维部署,每个服务都有自己的环境,比如说有自己的数据库,有自己的缓存服务等等。

简陋版的微服务架构.png

项目微架构中所不可避免的问题,比如说分布式事务,认证授权,分布式作业等等问题。

spring cloud简介

spring cloud是一个基于spring boot实现的微服务架构开发工具。它为微服务架构中涉及的配置管理,服务治理,断路器,智能路由,微代理,控制总线,全局锁,决策竞选,分布式会话和集群状态管理等操作提供了一种简单的开发方式。spring Cloud版本是采用了伦敦地铁站的名字,根据字母表的顺序来对应版本时间顺序,比如最早的Release版本的Angel,第二个Release版本的Brixton.....

spring cloud Eureka

spring cloud Eureka是spring cloud Netfix微服务套件中的一部分,它基于Netfix Eureka做了二次封装,主要负责完成微服务架构中的服务治理功能。Spring cloud通过为Eureka增加了Spring boot风格的自动化配置,我们只需要通过简单引入依赖和注解配置就能让spring boot构建微服务应用轻松地与EUreka服务治理体系进行整合。

在最初开始构建微服务系统的时候可能服务并不多,我们可以通过一些静态配置来完成服务的调用。比如,有二个服务A和B,其中服务A需要调用B来完成业务操作,为了实现B的高可用,不论采用服务端负载均衡还是客户端负载均衡,都需要手工维护B的具体实例清单。但是随着业务的发展,系统功能的复杂性越来越高,相应的微服务也不断增加,我们的静态配置就会变得越来越难以维护。并且面对不断发展的业务,我们的集群规模,服务的位置,服务的命名都有可能发生变化,还是通过手工维护的方式,极其容易出现问题。

为了解决微服务架构中的服务实例维护问题,产生了大量的服务治理框架和产品。这些框架和产品的实现都围绕服务注册与服务发现机制来完成对微服务应用实例的自动化管理。如果我们使用过阿里的dubbo就知道,zookeeper也是实现服务注册与发现的一种策略。当然springcloud 也支持使用zookeeper进行服务治理。

快速入门

1、搭建工程
用最新版本的spring cloud,Edgware.SR3,搭建一个聚合工程,以便于idea开发,在父pom文件中定义springboot和springcloud的版本:

pom.xml文件:

    <modules>
        <module>eureka-server</module>
        <module>serviceA</module>
        <module>serviceB</module>
    </modules>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.13.RELEASE</version>
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Edgware.SR3</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

2、定义eureka-server服务:

pom.xml

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

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

服务启动类,加上@EnableEurekaServer注解:

@SpringBootApplication
@EnableEurekaServer
public class EurekaServer {

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

}

定义的配置文件application.yml:

server:
  port: 8761
eureka:
  client:
    registerWithEureka: false
    fetchRegistry: false

启动服务:

2018-08-12 16:34:25.924  INFO 5454 --- [           main] c.n.eureka.cluster.PeerEurekaNodes       : Replica node URL:  http://localhost:8761/eureka/
2018-08-12 16:34:25.934  INFO 5454 --- [           main] c.n.e.registry.AbstractInstanceRegistry  : Finished initializing remote region registries. All known remote regions: []
2018-08-12 16:34:25.935  INFO 5454 --- [           main] c.n.eureka.DefaultEurekaServerContext    : Initialized
2018-08-12 16:34:25.953  WARN 5454 --- [           main] arterDeprecationWarningAutoConfiguration : spring-cloud-starter-eureka is deprecated as of Spring Cloud Netflix 1.4.0, please migrate to spring-cloud-starter-netflix-eureka
2018-08-12 16:34:25.956  WARN 5454 --- [           main] arterDeprecationWarningAutoConfiguration : spring-cloud-starter-eureka-server is deprecated as of Spring Cloud Netflix 1.4.0, please migrate to spring-cloud-starter-netflix-eureka-server
2018-08-12 16:34:26.118  INFO 5454 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Registering beans for JMX exposure on startup
2018-08-12 16:34:26.131  INFO 5454 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Bean with name 'configurationPropertiesRebinder' has been autodetected for JMX exposure
2018-08-12 16:34:26.132  INFO 5454 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Bean with name 'refreshEndpoint' has been autodetected for JMX exposure
2018-08-12 16:34:26.132  INFO 5454 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Bean with name 'environmentManager' has been autodetected for JMX exposure
2018-08-12 16:34:26.133  INFO 5454 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Bean with name 'serviceRegistryEndpoint' has been autodetected for JMX exposure
2018-08-12 16:34:26.134  INFO 5454 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Bean with name 'refreshScope' has been autodetected for JMX exposure
2018-08-12 16:34:26.137  INFO 5454 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Located managed bean 'environmentManager': registering with JMX server as MBean [org.springframework.cloud.context.environment:name=environmentManager,type=EnvironmentManager]
2018-08-12 16:34:26.150  INFO 5454 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Located managed bean 'serviceRegistryEndpoint': registering with JMX server as MBean [org.springframework.cloud.client.serviceregistry.endpoint:name=serviceRegistryEndpoint,type=ServiceRegistryEndpoint]
2018-08-12 16:34:26.157  INFO 5454 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Located managed bean 'refreshScope': registering with JMX server as MBean [org.springframework.cloud.context.scope.refresh:name=refreshScope,type=RefreshScope]
2018-08-12 16:34:26.169  INFO 5454 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Located managed bean 'configurationPropertiesRebinder': registering with JMX server as MBean [org.springframework.cloud.context.properties:name=configurationPropertiesRebinder,context=408613cc,type=ConfigurationPropertiesRebinder]
2018-08-12 16:34:26.175  INFO 5454 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Located managed bean 'refreshEndpoint': registering with JMX server as MBean [org.springframework.cloud.endpoint:name=refreshEndpoint,type=RefreshEndpoint]
2018-08-12 16:34:26.189  INFO 5454 --- [           main] o.s.c.support.DefaultLifecycleProcessor  : Starting beans in phase 0
2018-08-12 16:34:26.189  INFO 5454 --- [           main] o.s.c.n.e.s.EurekaServiceRegistry        : Registering application unknown with eureka with status UP
2018-08-12 16:34:26.235  INFO 5454 --- [      Thread-26] o.s.c.n.e.server.EurekaServerBootstrap   : Setting the eureka configuration..
2018-08-12 16:34:26.235  INFO 5454 --- [      Thread-26] o.s.c.n.e.server.EurekaServerBootstrap   : Eureka data center value eureka.datacenter is not set, defaulting to default
2018-08-12 16:34:26.236  INFO 5454 --- [      Thread-26] o.s.c.n.e.server.EurekaServerBootstrap   : Eureka environment value eureka.environment is not set, defaulting to test
2018-08-12 16:34:26.248  INFO 5454 --- [      Thread-26] o.s.c.n.e.server.EurekaServerBootstrap   : isAws returned false
2018-08-12 16:34:26.248  INFO 5454 --- [      Thread-26] o.s.c.n.e.server.EurekaServerBootstrap   : Initialized server context
2018-08-12 16:34:26.248  INFO 5454 --- [      Thread-26] c.n.e.r.PeerAwareInstanceRegistryImpl    : Got 1 instances from neighboring DS node
2018-08-12 16:34:26.248  INFO 5454 --- [      Thread-26] c.n.e.r.PeerAwareInstanceRegistryImpl    : Renew threshold is: 1
2018-08-12 16:34:26.248  INFO 5454 --- [      Thread-26] c.n.e.r.PeerAwareInstanceRegistryImpl    : Changing status to UP
2018-08-12 16:34:26.254  INFO 5454 --- [      Thread-26] e.s.EurekaServerInitializerConfiguration : Started Eureka Server
2018-08-12 16:34:26.298  INFO 5454 --- [           main] s.b.c.e.t.TomcatEmbeddedServletContainer : Tomcat started on port(s): 8761 (http)
2018-08-12 16:34:26.298  INFO 5454 --- [           main] .s.c.n.e.s.EurekaAutoServiceRegistration : Updating port to 8761
2018-08-12 16:34:26.303  INFO 5454 --- [           main] com.zhihao.miao.eureka.EurekaServer      : Started EurekaServer in 7.094 seconds (JVM running for 8.472)

打开eureka管控台:

http://localhost:8761/

3、创建A服务(服务提供者)

创建服务提供者工程,其实微服务中没有严格意义上的服务提供者和服务消费者,只是针对于一次调用关系

pom.xml文件:

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


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

定义项目启动类,加上@EnableEurekaClient注解:

@SpringBootApplication
@EnableEurekaClient
public class ServiceAApplication {

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

}

定义一个接口:

@RestController
public class ServiceAController {

    @RequestMapping(value = "/sayHello/{name}",
            method = RequestMethod.GET)
    public String sayHello(@PathVariable("name") String name) {
        return "{'msg': 'hello, " + name + "'}";
    }

}

定义配置文件application.yml:

server:
  port: 8088
spring:
  application:
    name: ServiceA
eureka:
  instance:
    hostname: localhost
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka

4、定义服务消费者BService:

首先定义的pom文件,这边的ribbon跟负载均衡有关系:

    <artifactId>serviceB</artifactId>
    <packaging>jar</packaging>

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-ribbon</artifactId>
        </dependency>
    </dependencies>

然后定义项目启动类:

@SpringBootApplication
@EnableEurekaClient
public class ServiceBApplication {

    public static void main(String[] args) throws Exception{
        SpringApplication.run(ServiceBApplication.class, args);



    }

}

定义一个接口去调用服务A接口:

@RestController
@Configuration
public class ServiceBController {

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

    @RequestMapping(value = "/greeting/{name}", method = RequestMethod.GET)
    public String greeting(@PathVariable("name") String name) {
        RestTemplate restTemplate = getRestTemplate();
        return restTemplate.getForObject("http://ServiceA/sayHello/" + name, String.class);
    }

}

这边先剧透一下RestTemplate类跟负载均衡组件有关,相关的下面会去讲解:

@RestController
@Configuration
public class ServiceBController {

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

    @RequestMapping(value = "/greeting/{name}", method = RequestMethod.GET)
    public String greeting(@PathVariable("name") String name) {
        RestTemplate restTemplate = getRestTemplate();
        return restTemplate.getForObject("http://ServiceA/sayHello/" + name, String.class);
    }

}

配置文件application.xml:

server:
  port: 9090
spring:
  application:
    name: ServiceB
eureka:
  instance:
    hostname: localhost
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka

启动服务:

然后在浏览器里访问,http://localhost:9090/greeting/miaozhihao,就可以看到结果了

git地址

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 216,324评论 6 498
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,356评论 3 392
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 162,328评论 0 353
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,147评论 1 292
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,160评论 6 388
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,115评论 1 296
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,025评论 3 417
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,867评论 0 274
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,307评论 1 310
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,528评论 2 332
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,688评论 1 348
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,409评论 5 343
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,001评论 3 325
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,657评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,811评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,685评论 2 368
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,573评论 2 353

推荐阅读更多精彩内容