Spring Cloud微服务升级总结

一.应用系统的架构历史

[
Image tex](http://upload-images.jianshu.io/upload_images/2830896-7f1a6c86fcda9550.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
Image tex](http://upload-images.jianshu.io/upload_images/2830896-7f1a6c86fcda9550.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)

二.什么是微服务?

2.1 微服务概述

  • 起源:微服务的概念源于 2014 年 3 月 Martin Fowler 所写的一篇文章“Microservices”。文中内容提到:微服务架构是一种架构模式,它提倡将单一应用程序划分成一组小的服务,服务之间互相协调、互相配合,为用户提供最终价值。
  • 通信方式:每个服务运行在其独立的进程中,服务与服务间采用轻量级的通信机制互相沟通(通常是基于 HTTP 的 RESTful API)。
  • 微服务的常规定义:微服务是一种架构风格,一个大型复杂软件应用由一个或多个微服务组成。系统中的各个微服务可被独立部署,各个微服务之间是松耦合的。每个微服务仅关注于完成一件任务。
  • 把原来的一个完整的进程服务,拆分成两个或两个以上的进程服务,且互相之间存在调用关系,与原先单一的进程服务相比,就是“微服务”。(微服务是一个比较级的概念,而不是单一的概念)

2.2 微服务架构的优势

  • 可扩展性:在增加业务功能时,单一应用架构需要在原先架构的代码基础上做比较大的调整,而微服务架构只需要增加新的微服务节点,并调整与之有关联的微服务节点即可。在增加业务响应能力时,单一架构需要进行整体扩容,而微服务架构仅需要扩容响应能力不足的微服务节点。
  • 容错性:在系统发生故障时,单一应用架构需要进行整个系统的修复,涉及到代码的变更和应用的启停,而微服务架构仅仅需要针对有问题的服务进行代码的变更和服务的启停。其他服务可通过重试、熔断等机制实现应用层面的容错。
  • 技术选型灵活:微服务架构下,每个微服务节点可以根据完成需求功能的不同,自由选择最适合的技术栈,即使对单一的微服务节点进行重构,成本也非常低。
  • 开发运维效率更高:每个微服务节点都是一个单一进程,都专注于单一功能,并通过定义良好的接口清晰表述服务边界。由于体积小、复杂度低,每个微服务可由一个小规模团队或者个人完全掌控,易于保持高可维护性和开发效率。
  • Spring Cloud作为今年最流行的微服务开发框架,不是采用了Spring Cloud框架就实现了微服务架构,具备了微服务架构的优势。正确的理解是使用Spring Cloud框架开发微服务架构的系统,使系统具备微服务架构的优势(Spring Cloud就像工具,还需要“做”的过程)。

三.Spring Boot/Cloud

3.1 什么是Spring Boot?

Spring Boot框架是由Pivotal团队提供的全新框架,其设计目的是用来简化基于Spring应用的初始搭建以及开发过程。SpringBoot框架使用了特定的方式来进行应用系统的配置,从而使开发人 员不再需要耗费大量精力去定义模板化的配置文件。

3.2 什么是Spring Cloud?

Spring Cloud是一个基于Spring Boot实现的云应用开发工具,它为基于JVM的云应用开发中的配置管理、服务注册,服务发现、断路器、智能路由、微代理、控制总线、全局锁、决策竞选、分布式会话和集群状态管理等操作提供了一种简单的开发方式。

3.3 微服务,Spring Boot,Spring Cloud三者之间的关系

  • 思想:微服务是一种架构的理念,提出了微服务的设计原则,从理论为具体的技术落地提供了指导思想。
  • 脚手架:Spring Boot是一套快速配置脚手架,可以基于Spring Boot快速开发单个微服务。
  • 多个组件的集合:Spring Cloud是一个基于Spring Boot实现的服务治理工具包;Spring Boot专注于快速、方便集成的单个微服务个体;Spring Cloud关注全局的服务治理框架。

3.4 Everything is jar, Everything is http

Spring Boot通过@SpringBootApplication注解标识为Spring Boot应用程序。所有的应用都通过jar包方式编译,部署和运行.

@SpringBootApplication
public class Application {
       private static final Logger LOGGER = LoggerFactory.getLogger(Application.class);  
       public static void main(String[] args) {     
           SpringApplication.run(Application.class, args);       
           LOGGER.info(”启动成功!");
       }�
   }

每个Spring Boot的应用都可以通过内嵌web容器的方式提供http服务,仅仅需要在pom文件中依赖spring-boot-start-web即可,原则上微服务架构希望每个独立节点都提供http服务。

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

3.5 Spring boot Task 任务启动和定时任务

在Spring Boot需要启动任务时,只要继承CommandLineRunner接口实现其run方法即可。

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

在Spring Boot需要执行定时任务时,只需要在定时任务方法上增加@Scheduled(cron = “0 15 0 **?”)注解(支持标准cron表达式),并且在服务启动类上增加@EnableScheduling的注解即可。

@SpringBootApplication
@EnableScheduling
public class Application {
    private static final Logger LOGGER = LoggerFactory.getLogger(Application.class);    
    public static void main(String[] args) {        
        SpringApplication.run(Application.class, args);       
        LOGGER.info(”启动成功!");  
    }
}

// some class
@Scheduled(cron = "0 15 0 * * ?")
public void someTimeTask() {
  //
}
}

3.6 Spring boot Actuator 监控

Actuator是spring boot提供的对应用系统自身进行监控的组件,在引入spring-boot-start-web基础上引入spring-boot-starter-actuator即可。

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

[
Image tex](http://upload-images.jianshu.io/upload_images/2830896-d9936c91c8488913.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
Image tex](http://upload-images.jianshu.io/upload_images/2830896-d9936c91c8488913.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)

3.7 Spring cloud Config 配置中心

在我们实现微服务架构时,每个微服务节点都需要自身的相关配置数据项,当节点众多,维护就变得非常困难,因此需要建立一个中心配置服务。

Spring Cloud Config分为两部分。Spring Cloud Config server作为一个服务进程,Spring Cloud Config File为配置文件存放位置。

[
Image tex](http://upload-images.jianshu.io/upload_images/2830896-81ce721b577462c0.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
Image tex](http://upload-images.jianshu.io/upload_images/2830896-81ce721b577462c0.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)

[图片上传失败...(image-bfc9bd-1511489698023)]

3.8 Spring cloud Eureka 服务注册中心

服务注册的概念早在微服务架构之前就出现了,微服务架构更是把原先的单一应用节点拆分成非常多的微服务节点。互相之间的调用关系会非常复杂,Spring Cloud Eureka作为注册中心,

服务注册的概念早在微服务架构之前就出现了,微服务架构更是把原先的单一应用节点拆分成非常多的微服务节点。互相之间的调用关系会非常复杂,Spring Cloud Eureka作为注册中心,
所有的微服务都可以将自身注册到Spring Cloud Eureka进行统一的管理和访问(Eureka和Zookeeper不同,在AOP原则中选择了OP,更强调服务的有效性)

服务注册的概念早在微服务架构之前就出现了,微服务架构更是把原先的单一应用节点拆分成非常多的微服务节点。互相之间的调用关系会非常复杂,Spring Cloud Eureka作为注册中心,
所有的微服务都可以将自身注册到Spring Cloud Eureka进行统一的管理和访问(Eureka和Zookeeper不同,在AOP原则中选择了OP,更强调服务的有效性)

[
Image tex](http://upload-images.jianshu.io/upload_images/2830896-dc42d5c33edcb8ce.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
Image tex](http://upload-images.jianshu.io/upload_images/2830896-dc42d5c33edcb8ce.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)

[
Image tex](http://upload-images.jianshu.io/upload_images/2830896-b273d83f2293370b.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
Image tex](http://upload-images.jianshu.io/upload_images/2830896-b273d83f2293370b.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)

3.9 Spring cloud Zuul 服务端智能路由

当我们把所有的服务都注册到Eureka(服务注册中心)以后,就涉及到如何调用的问题。Spring Cloud Zuul是Spring Cloud提供的服务端代理组件,可以看做是网关,Zuul通过Eureka获取到可用的服务,通过映射配置,客户端通过访问Zuul来访问实际需要需要访问的服务。所有的服务通spring.application.name做标识,不同IP地址,相同spring.application.name就是一个服务集群。当我们增加一个相同spring.application.name的节点,Zuul通过和Eureka通信获取新增节点的信息实现智能路由,增加该类型服务的响应能力。

[
Image tex](http://upload-images.jianshu.io/upload_images/2830896-daf71f3a3e8c2587.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
Image tex](http://upload-images.jianshu.io/upload_images/2830896-daf71f3a3e8c2587.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)

3.10 Spring cloud Ribbon 客户端智能路由

与Spring Cloud Zuul的服务端代理相对应,Spring Cloud Ribbon提供了客户端代理。在服务端代理中,客户端并不需要知道最终是哪个微服务节点为之提供服务,而客户端代理获取实质提供服务的节点,并选择一个进行服务调用。Ribbon和Zuul相似,也是通过和Eureka(服务注册中心)进行通信来实现客户端智能路由。

3.11 Spring cloud Sleuth 分布式追踪

[
Image tex](http://upload-images.jianshu.io/upload_images/2830896-6b072bdd33cd6c91.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
Image tex](http://upload-images.jianshu.io/upload_images/2830896-6b072bdd33cd6c91.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)

2.12 Spring cloud Zipkin 调用链

[
Image tex](http://upload-images.jianshu.io/upload_images/2830896-89c49201ca222583.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
Image tex](http://upload-images.jianshu.io/upload_images/2830896-89c49201ca222583.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)

[
Image tex](http://upload-images.jianshu.io/upload_images/2830896-df819f7b462bdb64.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
Image tex](http://upload-images.jianshu.io/upload_images/2830896-df819f7b462bdb64.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)

3.13 Spring cloud Feign http客户端

Spring Cloud Feign是一种声明式、模板化的http客户端。 使用Spring Cloud Feign请求远程服务时能够像调用本地方法一样,让开发者感觉不到这是远程方法(Feign集成了Ribbon做负载均衡)。

1.把远程服务和本地服务做映射

@FeignClient(name = "rabbitmq-http", url = "${SKYTRAIN_RABBITMQ_HTTP}")�
   public interface TaskService {�    
       @RequestMapping(value = "/api/queues", method = RequestMethod.GET)�    
       public String query(@RequestHeader("Authorization") String token);�
   }
  1. 以调用本地服务的方式调用远程服务
@Autowired�
    private TaskService taskService;�
    private String queryRabbitmqStringInfo() {�    
        byte[] credentials = Base64�.encodeBase64((rabbitmqHttpUserName + ":" + rabbitmqHttpPassword).getBytes(StandardCharsets.UTF_8));�    
        String token = "Basic " + new String(credentials, StandardCharsets.UTF_8);�    
        return taskService.query(token);�
    }

3.13 Spring cloud Hystrix 断路器

[
Image tex](http://upload-images.jianshu.io/upload_images/2830896-d1f1a7703d5070ad.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
Image tex](http://upload-images.jianshu.io/upload_images/2830896-d1f1a7703d5070ad.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)

四 自研组件

4.1 我们开发的几个微服务组件—应用管理中心

应用管理中心可以对每个已经注册的微服务节点进行停止,编译,打包,部署,启动的完整的上线操作。

[
Image tex](http://upload-images.jianshu.io/upload_images/2830896-10c2e89fd80797a8.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
Image tex](http://upload-images.jianshu.io/upload_images/2830896-10c2e89fd80797a8.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)

4.2 我们开发的几个微服务组件—zookeeper数据查询中心

zookeeper数据查询中心根据zookeeper地址,端口,命令获取zookeeper数据信息。

[
Image tex](http://upload-images.jianshu.io/upload_images/2830896-ef75600ea443cb6e.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
Image tex](http://upload-images.jianshu.io/upload_images/2830896-ef75600ea443cb6e.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)

4.3 我们开发的几个微服务组件—微服务健康检测中心

健康检测中心周期性检查每个微服务的状态,当发现有微服务状态处于DOWN或连接超时时,触发报警

健康检测中心周期性检查每个微服务的状态,当发现有微服务状态处于DOWN或连接超时时,触发报警

[
Image tex](http://upload-images.jianshu.io/upload_images/2830896-a7020b76eb7ff6f7.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
Image tex](http://upload-images.jianshu.io/upload_images/2830896-a7020b76eb7ff6f7.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)

4.4 我们开发的几个微服务组件—定时任务查询中心

// 在BeanPostProcessor子类中拦截
   @Component
   public class SkytrainBeanPostProcessor implements BeanPostProcessor, Ordered {
       ***
       /**
        * Bean 实例化之后进行的处理
        */
       public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {
   
           beanPostProcessor.postProcessAfter(bean, beanName);
           return bean;
       }
   
   }
   
   // 拦截后获取定时任务注解
   public Object postProcessAfter(Object bean, String beanName) {
       Class<?> targetClass = AopUtils.getTargetClass(bean);
       Map<Method, Set<Scheduled>> annotatedMethods = MethodIntrospector.selectMethods(targetClass,
               new MethodIntrospector.MetadataLookup<Set<Scheduled>>() {

                   public Set<Scheduled> inspect(Method method) {

                       Set<Scheduled> scheduledMethods = AnnotatedElementUtils.getMergedRepeatableAnnotations(method,
                               Scheduled.class, Schedules.class);
                       return (!scheduledMethods.isEmpty() ? scheduledMethods : null);
                   }
               });
       if (!annotatedMethods.isEmpty()) {
           String className = targetClass.getName();
           for (Map.Entry<Method, Set<Scheduled>> entry : annotatedMethods.entrySet()) {
               Method method = entry.getKey();
               for (Scheduled scheduled : entry.getValue()) {
                   String key = className + ":" + method.getName();
                   String value = scheduled.toString();
                   taskInfos.put(key, value);
               }
           }
       }
       return null;
   }
   
   // 获取定时任务后注册
   public void taskRegister() {
       String nodeInfo = ipAddress + ":" + serverPort + ":";
       try {
           /**
            * 定时任务
            */
           Map<String, String> infos = taskInfos;
           for (Entry<String, String> item : infos.entrySet()) {
               String taskId = nodeInfo + item.getKey();
               String taskParameter = item.getValue();
               JSONObject info = new JSONObject();
               info.put("taskId", taskId);
               info.put("taskParameter", taskParameter);
               info.put("applicationName", applicationName);
               info.put("taskType", "schedule");
               LOGGER.info(info.toString());
               zooKeeperExecutor.createZKNode(SKYTRAIN_TASK_ZKNODE_PREFIX + taskId, info.toString());
           }
       }
       catch (Exception ex) {
           LOGGER.error("", ex);
       }
   }

4.5 微服务的分类

  • 微服务平台组件
  • 公共服务组件
  • 基础服务组件/业务服务组件

4.6 整体微服务架构图

[
Image tex](http://upload-images.jianshu.io/upload_images/2830896-27e0f7bdc9506df4.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
Image tex](http://upload-images.jianshu.io/upload_images/2830896-27e0f7bdc9506df4.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)

原文作者:宜信-技术研发中心-高级架构师-梁鑫

点我获取阿里云优惠券

我的官网


我的博客

我的官网http://guan2ye.com
我的CSDN地址http://blog.csdn.net/chenjianandiyi
我的简书地址http://www.jianshu.com/u/9b5d1921ce34
我的githubhttps://github.com/javanan
我的码云地址https://gitee.com/jamen/
阿里云优惠券https://promotion.aliyun.com/ntms/act/ambassador/sharetouser.html?userCode=vf2b5zld&utm_source=vf2b5zld

阿里云教程系列网站http://aliyun.guan2ye.com

1.png

我的开源项目spring boot 搭建的一个企业级快速开发脚手架

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

推荐阅读更多精彩内容