本次分享主要介绍了爱油科技基于Docker和Spring Cloud将整体业务微服务化的一些实践经验,主要包括:
对于单体应用来说,优点很多,例如:
然而随着业务复杂性的上升,业务规模的扩大,缺点也显现出来,例如:
因此微服务技术作为一项对分布式服务治理的架构模式,逐渐被大家认识了。
实施微服务,首先对我们的架构进行了拆分:按行分层,按列分业务
在我们的微服务体系中,所有的服务被划分为了三个层次:
实践中我们主要关注业务服务层和接入层,对于没有足够运维力量的我们,基础设施使用云服务是省事省力的选择。
业务服务层我们给他起名叫作Epic,接入层我们起名Rune,建立之初便订立了如下原则:
业务逻辑层我们主要使用使用Java,接入层我们主要使用PHP或Node。后来随着团队的成长,逐步将接入层全部迁移至Node。
爱油科技作为一家成品油行业的初创型公司,需要面对非常复杂的业务场景,而且随着业务的发展,变化的可能性非常高。所以在微服务架构设计之初,我们就期望我们的微服务体系能:
目前常见的微服务相关框架:
这些常见的框架中,Dubbo几乎是唯一能被称作全栈微服务框架的“框架”,它包含了微服务所需的几乎所有内容,而DubboX作为它的增强,增加了REST支持。
它优点很多,例如:
不过遗憾的是:
Motan是微博平台微服务框架,承载了微博平台千亿次调用业务。
优点是:
不过:
Apache Thrift、gRPC等虽然优秀,并不能算作微服务框架,自身并不包括服务发现等必要特性。
如果说微服务少不了Java,那么一定少不了Spring,如果说少不了Spring,那么微服务“官配”Spring Cloud当然是值得斟酌的选择。
Spring Cloud优点:
当然它有很多不足之处,例如:
根据我们的目标,我们最终选择了Spring Cloud作为我们的微服务框架,原因有4点:
Apache Thrift
和 gRPC
自研,投入产出比很差; Motan
还没有发布。 因此Spring Cloud成为了理性的选择。
Spring Cloud是一个集成框架,将开源社区中的框架集成到Spring体系下,几个重要的家族项目:
spring-boot
,一改Java应用程序运行难、部署难,甚至无需Web容器,只依赖JRE即可 spring-cloud-netflix
,集成Netflix优秀的组件Eureka、Hystrix、Ribbon、Zuul,提供服务发现、限流、客户端负载均衡和API网关等特性支持 spring-cloud-config
,微服务配置管理 spring-cloud-consul
,集成Consul支持 当然,SpringCloud下子项目非常多,这里就不一一列出介绍了。
Spring Cloud Netflix提供了Eureka服务注册的集成支持,不过没选它是因为:
Docker作为支撑平台的重要技术之一,Consul几乎也是我们的必选服务。因此我们觉得一事不烦二主,理所应当的Consul成为我们的服务注册中心。
Consul的优势:
也就是说,Consul可以一次性解决我们对服务注册发现、配置管理的需求,而且长期来看也更适合跟不同平台的系统,包括和Docker调度系统进行整合。
最初打算自己开发一个Consul和Spring Cloud整合的组件,不过幸运的是,我们做出这个决定的时候, spring-cloud-consul
刚刚发布了,我们可以拿来即用,这节约了很多的工作量。
因此借助Consul和 spring-cloud-consul
,我们实现了
srping-cloud-consul
的项目可以自动注册服务,也可以通过HTTP接口手动注册,Docker容器也可以自动注册 当然也踩到了一些坑:
spring-cloud-consul
服务注册时不能正确选判本地ip地址。对于我们的环境来说,无论是在服务器上,还是Docker容器里,都有多个网络接口同时存在,而 spring-cloud-consul
在注册服务时,需要先选判本地服务的IP地址,判断逻辑是以第一个非本地地址为准,常常错判。因此在容器中我们利用entrypoint脚本获取再通过环境变量强制指定。
#!/usr/bin/env bash set -e # If service runs as Rancher service, auto set advertise ip address # from Rancher metadata service. if [ -n "$RUN_IN_RANCHER" ]; then echo "Waiting for ip address..." # Waiting for ip address sleep 5 RANCHER_MS_BASE=http://rancher-metadata/2015-12-19 PRIMARY_IP=`curl -sSL $RANCHER_MS_BASE/self/container/primary_ip` SERVICE_INDEX=`curl -sSL $RANCHER_MS_BASE/self/container/service_index` if [ -n "$PRIMARY_IP" ]; then exportSPRING_CLOUD_CONSUL_DISCOVERY_HOSTNAME=$PRIMARY_IP fi echo "Starting service #${SERVICE_INDEX-1} at $PRIMARY_IP." fi exec "$@"
我们的容器运行在Rancher中,所以可以利用Rancher的metadata服务来获取容器的IP地址,再通过 SPRING_CLOUD_CONSUL_DISCOVERY_HOSTNAME
环境变量来设置服务发现的注册地址。基于其他容器调度平台也会很相似。
为了方便开发人员使用,微服务框架应当简单容易使用。对于很多微服务框架和RPC框架来说,都提供了很好的机制。在Spring Cloud中通过 OpenFeign
实现微服务之间的快速集成:
服务方声明一个Restful的服务接口,和普通的Spring MVC控制器几乎别无二致:
@RestController @RequestMapping("/users") public class UserResource { @RequestMapping(value = "{id}", method = RequestMethod.GET, produces = "application/json") public UserRepresentationfindOne(@PathVariable("id") String id) { Useruser = this.userRepository.findByUserId(new UserId(id)); if (user == null || user.getDeleted()) { throw new NotFoundException("指定ID的用户不存在或者已被删除。"); } return new UserRepresentation(user); } }
客户方使用一个微服务接口,只需要定义一个接口:
@FeignClient("epic-member-microservice") public interface UserClient { @Override @RequestMapping(value = "/users/{id}", method = RequestMethod.GET, produces = "application/json") UserfindOne(@PathVariable("id") String id); }
在需要使用 UserClient
的Bean中,直接注入 UserClient
类型即可。事实上, UserClient
和相关VO类,可以直接作为公共接口封装在公共项目中,供任意需要使用的微服务引用,服务方Restful Controller直接实现这一接口即可。
OpenFeign
提供了这种简单的方式来使用Restful服务,这大大降低了进行接口调用的复杂程度。
对于错误的处理,我们使用HTTP状态码作为错误标识,并做了如下规定:
对于服务器端,只需要在一个异常类上添加注解,即可指定该异常的HTTP响应状态码,例如:
@ResponseStatus(HttpStatus.NOT_FOUND) public class NotFoundException extends RuntimeException { public NotFoundException() { super("查找的资源不存在或者已被删除。"); } public NotFoundException(String message) { super(message); } public NotFoundException(String message, Throwablecause) { super(message, cause); } }
对于客户端我们实现了自己的 FeignClientExceptionErrorDecoder
来将请求异常转换为对于的异常类,示例如下:
@Component public class FeignClientExceptionErrorDecoder implements ErrorDecoder { private final ErrorDecoderdelegate = new ErrorDecoder.Default(); @Override public Exceptiondecode(String methodKey, Responseresponse) { // Only decode 4xx errors. if (response.status() >= 500) { return delegate.decode(methodKey, response); } // Response content type must be json if (response.headers().getOrDefault("Content-Type", Lists.newArrayList()).stream() .filter(s -> s.toLowerCase().contains("json")).count() > 0) { try { String body = Util.toString(response.body().asReader()); // 转换并返回异常对象 ... } catch (IOExceptionex) { throw new RuntimeException("Failed to process response body.", ex); } } return delegate.decode(methodKey, response); } }
需要注意的是, decode
方法返回的4xx状态码异常应当是 HystrixBadRequestException
的子类对象,原因在于,我们把4xx异常视作业务异常,而不是由于故障导致的异常,所以不应当被Hystrix计算为失败请求,并引发断路器动作,这一点 非常重要 。
在 UserClient.findOne
方法的调用代码中,即可直接捕获相应的异常了:
try { Useruser = this.userClient.findOne(new UserId(id)); } catch(NotFoundExceptionex) { ... }
通过 OpenFeign
,我们大大降低了Restful接口进行服务集成的难度,几乎做到了无额外工作量的服务集成。
微服务架构下,由于调用需要跨系统进行远程操作,各微服务独立运维,所以在设计架构时还必须考虑伸缩性和容错性,具体地说主要包括以下几点要求:
spring-cloud-netflix
和相关组件为我们提供了很好的解决方案:
下面主要介绍一下,各个组件在进行服务质量保证中是如何发挥作用的。
Consul中注册了一致性的可用的服务列表,并通过健康检查保证这些实例都是存活的,服务注册和检查的过程如下:
spring-cloud-consul
通过Consul接口发起服务注册,将服务的 /health
作为健康检查端点; /health
,检查当前微服务是否为 UP
状态; /health
将会收集微服务内各个仪表收集上来的状态数据,主要包括数据库、消息队列是否连通等; 这样能够保证Consul中列出的所有微服务状态都是健康可用的,各个微服务会监视微服务实例列表,自动同步更新他们。
Hystrix提供了断路器模式的实现,主要在三个方面可以说明:
图片来自Hystrix项目文档
首先Hystrix提供了降级方法,断路器开启时,操作请求会快速失败不再向后投递,直接调用fallback方法来返回操作;当操作失败、被拒或者超时后,也会直接调用fallback方法返回操作。这可以保证在系统过载时,能有后备方案来返回一个操作,或者优雅的提示错误信息。断路器的存在能让故障业务被隔离,防止过载的流量涌入打死后端数据库等。
然后是基于请求数据统计的断路开关,在Hystrix中维护一个请求统计了列表(默认最多10条),列表中的每一项是一个桶。每个桶记录了在这个桶的时间范围内(默认是1秒),请求的成功数、失败数、超时数、被拒数。其中当失败请求的比例高于某一值时,将会触发断路器工作。
最后是不同的请求命令( HystrixCommand
)可以使用彼此隔离的资源池,不会发生相互的挤占。在Hystrix中提供了两种隔离机制,包括线程池和信号量。线程池模式下,通过线程池的大小来限制同时占用资源的请求命令数目;信号量模式下通过控制进入临界区的操作数目来达到限流的目的。
这里包括了Hystrix的一些重要参数的配置项:
参数 | 说明 |
---|---|
circuitBreaker.requestVolumeThreshold | 至少在一个统计窗口内有多少个请求后,才执行断路器的开关,默认20 |
circuitBreaker.sleepWindowInMilliseconds | 断路器触发后多久后才进行下一次判定,默认5000毫秒 |
circuitBreaker.errorThresholdPercentage | 一个统计窗口内百分之多少的请求失败才触发熔断,默认是50% |
execution.isolation.strategy | 运行隔离策略,支持 Thread , Semaphore ,前者通过线程池来控制同时运行的命令,后者通过信号来控制,默认是 Thread |
execution.isolation.thread.interruptOnTimeout | 命令执行的超时时间,默认1000毫秒 |
coreSize | 线程池大小,默认10 |
keepAliveTimeMinutes | 线程存活时间,默认为1分钟 |
maxQueueSize | 最大队列长度,-1使用SynchronousQueue,默认-1。 |
queueSizeRejectionThreshold | 允许队列堆积的最大数量 |
Ribbon使用Consul提供的服务实例列表,可以通过服务名选取一个后端服务实例连接,并保证后端流量均匀分布。 spring-cloud-netflix
整合了OpenFeign、Hystrix和Ribbon的负载均衡器,整个调用过程如下(返回值路径已经省略):
在这个过程中,各个组件扮演的角色如下:
Feign负责提供客户端接口收调用,把发起请求操作(包括编码、解码和请求数据)封装成一个Hystrix命令,这个命令包裹的请求对象,会被Ribbon的负载均衡器处理,按照负载均衡策略选择一个主机,然后交给请求对象绑定的HTTP客户端对象发请求,响应成功或者不成功的结果,返回给Hystrix。
spring-cloud-netflix
中默认使用了Ribbon的 ZoneAwareLoadBalancer
负载均衡器,它的负载均衡策略的核心指标是平均活跃请求数(Average Active Requests)。 ZoneAwareLoadBalancer
会拉取所有当前可用的服务器列表,然后将目前由于种种原因(比如网络异常)响应过慢的实例暂时从可用服务实例列表中移除,这样的机制可以保证故障实例被隔离,以免继续向其发送流量导致集群状态进一步恶化。不过由于目前 spring-cloud-consul
还不支持通过consul来指定服务实例的所在区,我们正在努力将这一功能完善。除了选区策略外,Ribbon中还提供了其他的负载均衡器,也可以自定义合适的负载均衡器。
关于区域的支持,我提交的PR已经Merge到spring-cloud-consul项目中,预计下个版本将会包含这项特性。
总的来看, spring-cloud-netflix
和Ribbon中提供了基本的负载均衡策略,对于我们来说已经足够用了。但实践中,如果需要进行灰度发布或者需要进行流量压测,目前来看还很难直接实现。而这些特性在Dubbo则开箱即用。
Zuul为使用Java语言的接入层服务提供API网关服务,既可以根据配置反向代理指定的接口,也可以根据服务发现自动配置。Zuul提供了类似于iptables的处理机制,来帮助我们实现验证权鉴、日志等,请求工作流如下所示:
图片来自Zuul官方文档。
使用Zuul进行反向代理时,同样会走与OpenFeign类似的请求过程,确保API的调用过程也能通过Hystrix、Ribbon提供的降级、控流机制。
Hystrix会统计每个请求操作的情况来帮助控制断路器,这些数据是可以暴露出来供监控系统热点。Hystrix Dashboard可以将当前接口调用的情况以图形形式展示出来:
图片来自Hystrix Dashboard官方示例
Hystrix Dashboard既可以集成在其他项目中,也可以独立运行。我们直接使用Docker启动一个Hystrix Dashboard服务即可:
dockerrun --rm -ti -p 7979:7979 kennedyoliveira/hystrix-dashboard
为了实现能对整个微服务集群的接口调用情况汇总,可以使用 spring-cloud-netflix-turbine
来将整个集群的调用情况汇集起来,供Hystrix Dashboard展示。
微服务的日志直接输出到标准输出/标准错误中,再由Docker通过syslog日志驱动将日志写入至节点机器机的rsyslog中。rsyslog在本地暂存并转发至日志中心节点的Logstash中,既归档存储,又通过ElasticSearch进行索引,日志可以通过Kibana展示报表。
在rsyslog的日志收集时,需要将容器信息和镜像信息加入到tag中,通过Docker启动参数来进行配置:
--log-driversyslog --log-opttag="{{.ImageName}}/{{.Name}}/{{.ID}}"
不过rsyslog默认只允许tag不超过32个字符,这显然是不够用的,所以我们自定义了日志模板:
template (name="LongTagForwardFormat" type="string" string="<%PRI%>%TIMESTAMP:::date-rfc3339% %HOSTNAME% %syslogtag%%msg:::sp-if-no-1st-sp%%msg%")
在实际的使用过程中发现,当主机内存负载比较高时,rsyslog会发生日志无法收集的情况,报日志数据文件损坏。后来在Redhat官方找到了相关的问题,确认是rsyslog中的一个Bug导致的,当开启日志压缩时会出现这个问题,我们选择暂时把它禁用掉。
领域驱动设计能够很大程度上帮助我们享用微服务带来的优势,所以我们使用领域驱动设计(DDD)的方法来构建微服务,因为微服务架构和DDD有一种天然的契合。把所有业务划分成若干个子领域,有强内在关联关系的领域(界限上下文)应当被放在一起作为一个微服务。最后形成了界限上下文-工作团队-微服务一一对应的关系:
在设计单个微服务(Epic层的微服务)时,我们这样做:
这给我们带来了显著的好处:
从单体应用迁移到微服务架构时,不得不面临的问题之一就是事务。在单体应用时代,所有业务共享同一个数据库,一次请求操作可放置在同一个数据库事务中;在微服务架构下,这件事变得非常困难。然而事务问题不可避免,非常关键。
解决事务问题时,最先想到的解决方法通常是分布式事务。分布式事务在传统系统中应用的比较广泛,主要基于两阶段提交的方式实现。然而分布式事务在微服务架构中可行性并不高,主要基于这些考虑:
根据CAP理论,分布式系统不可兼得一致性、可用性、分区容错性(可靠性)三者,对于微服务架构来讲,我们通常会保证可用性、容错性,牺牲一部分一致性,追求最终一致性。所以对于微服务架构来说,使用分布式事务来解决事务问题无论是从成本还是收益上来看,都不划算。
对微服务系统来说解决事务问题,CQRS+Event Sourcing是更好的选择。
CQRS是命令和查询职责分离的缩写。CQRS的核心观点是,把操作分为修改状态的命令(Command),和返回数据的查询(Query),前者对应于“写”的操作,不能返回数据,后者对应于“读”的操作,不造成任何影响,由此领域模型被一分为二,分而治之。
Event Sourcing通常被翻译成事件溯源,简单的来说就是某一对象的当前状态,是由一系列的事件叠加后产生的,存储这些事件即可通过重放获得对象在任一时间节点上的状态。
通过CQRS+Event Sourcing,我们很容易获得最终一致性,例如对于一个跨系统的交易过程而言:
PlaceOrderEvent
,订单状态 PENDING
; PaidEvent
; PaidEvent
,将订单标记为 CREATED
; InsufficientEvent
,交易微服务消费将订单标记为 CANCELED
。 我们只要保证领域事件能被持久化,那么即使出现网络延迟或部分系统失效,我们也能保证最终一致性。
实践上,我们利用Spring从4.2版本开始支持的自定义应用事件机制将本地事务和事件投递结合起来进行:
到目前为止我们已经有数十个微服务运行于线上了,微服务数目甚至多过了团队人数。如果没有DevOps支持,运维这些微服务将是一场灾难。
我们使用Docker镜像作为微服务交付的标准件:
由于时间所限,这里就不展开赘述了。
基于 spring-cloud-consul
的配置管理仍然需要完善,对于大规模应用的环境中,配置的版本控制、灰度、回滚等非常重要。SpringCloud提供了一个核,但是具体的使用还要结合场景、需求和环境等,再做一些工作。
对于非JVM语言的微服务和基于SpringCloud的微服务如何协同治理,这一问题仍然值得探索。包括像与Docker编排平台,特别是与Mesos协同进行伸缩的服务治理,还需要更多的实践来支持。
Q:你们是部署在公有云,还是托管机房。
A:我们部署在阿里云上,使用了很多阿里云服务作为基础设施,这一点是为了节约运维成本。
Q:怎么解决服务过多依赖问题,开发也会有麻烦,因为要开发一个功能,为了把服务跑起来,可能要跑很多服务。
A:在我们的实际开发过程中,也遇到了这个问题。主要的是通过部署几个不同的仿真环境,一组开发者可以共用这组环境。本地开发也很简单,只需要把consul指向到这个集群的consul上即可。
Q:你们微服务业务调用最深有几层?restful接口调用链的效率如何?比单体结构慢多少?
A:一般不超过3层,这是领域驱动设计给我们带来的优势,单个服务几乎自己就能完成职责范围内的任务,没有出现RPC灾难,一个业务我们也不倾向于拆分成若干个远程操作进行。
Q:你好 我们单位从6月份 开始实施 微服务化(O2O业务),使用的是dubbo,使用事务型消息来做最终一致性,请问CQRS+Event Sourcing相对于事务型消息队列来处理一致性问题 有什么优势么。
A:其实CQRS+Event Sourcing是一种观念的转变,落地还是需要靠存储和消息队列,优势在于可以消除系统中的锁点,性能会更好。
Q:有没有考虑过用kubernetes来实现微服务治理?
A:考虑过,但是我们团队规模有限,很难快速落地。
Q:其他语言有没有接入spring cloud config?例如PHP和node? 开发人员对微服务进行开发时,是用dockercompose吧服务都起起来,还是要接入公共的rancher?
A:我们没有使用spring-cloud-config,目前有接入层的node服务在使用consul下发配置。开发时本机跑自己的服务,连Rancher环境的Consul。
Q:关于领域事件,如果本地事务提交后,下游的服务报错,是否只能在业务层面再发起一个补偿的事件,让本地事务达到最终一致性呢?
A:如果下游服务报错,那么事件不会被消费。会以退避重试的方式重发事件。
Q:分享很棒,请问你们的docker的部署是基于原生的docker和swarm,还是kubernetes来做的?
A:谢谢,我们使用Rancher来管理集群。没选Kubernetes的原因是因为团队资源有限,Swarm最初试过,调度不够完善。后来Docker 1.12以后的Swarmkit应该是更好的选择。
Q:微服务开发测试用例相比于单体应用是不是更复杂一些?你们是怎样保证测试覆盖率的?
A:事实上对于单元测试来讲,反而更容易进行了。因为系统拆分之后,把原来很难测试的一些节点给疏通了。
Q:你好请教一下,当微服务之间的依赖关系比较多,且层次比较深时,服务的启动,停止,以及升级之间的关系如何处理?
A:目前还几乎没出现过需要彻底冷启动的情况。而且启动服务时并不需要依赖服务也启动,只需要发生业务时,依赖服务启动即可。