1。初始SpringCloud 微服务是一种架构方式,最终肯定需要技术架构去实施。 微服务的实现方式很多,但是最火的莫过于SpringCloud了。为什么?后台硬:作为Spring家族的一员,有整个Spring全家桶靠山,背景十分强大。技术强:Spring作为Java领域的前辈,可以说是功力深厚。有强力的技术团队支撑,一般人还真比不了群众基础好:可以说大多数程序员的成长都伴随着Spring框架,试问:现在有几家公司开发不用Spring?SpringCloud与Spring的各个框架无缝整合,对大家来说一切都是熟悉的配方,熟悉的味道。使用方便:相信大家都体会到了SpringBoot给我们开发带来的便利,而SpringCloud完全支持SpringBoot的开发,用很少的配置就能完成微服务框架的搭建 4。1。简介 SpringCloud是Spring旗下的项目之一,官网地址:http:projects。spring。iospringcloud Spring最擅长的就是集成,把世界上最好的框架拿过来,集成到自己的项目中。 SpringCloud也是一样,它将现在非常流行的一些技术整合到一起,实现了诸如:配置管理,服务发现,智能路由,负载均衡,熔断器,控制总线,集群状态等等功能。其主要涉及的组件包括: netflixEureka:注册中心Zuul:服务网关Ribbon:负载均衡Feign:服务调用Hystix:熔断器 下图所示的架构图,只是其中一部分。 2版本 SpringCloud的版本命名比较特殊,因为它不是一个组件,而是许多组件的集合,它的命名是以A到Z的为首字母的一些单词组成: 我们在项目中,会是以Finchley的版本。 其中包含的组件,也都有各自的版本,如下表: 接下来,我们就一一学习SpringCloud中的重要组件。 3创建一个微服务项目。 Spring脚手架创建工程 借助于Spring提供的快速搭建工具: 填写项目信息: 添加web依赖: 添加mybatis依赖: 填写项目位置: 生成的项目结构: 依赖也已经全部自动引入:lt;?xmlversion1。0encodingUTF8?4。0。0com。leyou。demouserservicedemoartifactId0。0。1SNAPSHOTjaruserservicedemoDemoprojectforSpringBootorg。springframework。bootspringbootstarterparentartifactId2。0。1。RELEASEproject。build。sourceEncodingUTF8project。build。sourceEncodingproject。reporting。outputEncodingUTF8project。reporting。outputEncodingjava。version1。8java。versionorg。springframework。bootspringbootstarterjdbcartifactIdorg。springframework。bootspringbootstarterwebartifactIdorg。mybatis。spring。bootmybatisspringbootstarterartifactId1。3。2mysqlmysqlconnectorjavaartifactIdruntimeorg。springframework。bootspringbootstartertestartifactIdtestorg。springframework。bootspringbootmavenpluginartifactId 当然,因为要使用通用mapper,所以我们需要手动加一条依赖:tk。mybatismapperspringbootstarterartifactId2。0。2编写代码。 添加一个对外查询的接口:RestControllerRequestMapping(user)publicclassUserController{AutowiredprivateUserServiceuserService;GetMapping({id})publicUserqueryById(PathVariable(id)Longid){returnthis。userService。queryById(id);}} Service:ServicepublicclassUserService{AutowiredprivateUserMapperuserMapper;publicUserqueryById(Longid){returnthis。userMapper。selectByPrimaryKey(id);}} mapper:MapperpublicinterfaceUserMapperextendstk。mybatis。mapper。common。Mapper{} 实体类Table(nametbuser)publicclassUserimplementsSerializable{privatestaticfinallongserialVersionUID1L;IdGeneratedValue(strategyGenerationType。IDENTITY)privateLongid;用户名privateStringuserName;密码privateStringpassword;姓名privateStringname;年龄privateIntegerage;性别,1男性,2女性privateIntegersex;出生日期privateDatebirthday;创建时间privateDatecreated;更新时间privateDateupdated;备注privateStringnote;省略getters和setters} 属性文件,这里我们采用了yaml语法,而不是properties:server:port:8081spring:datasource:url:jdbc:mysql:localhost:3306mydb01username:rootpassword:123hikari:maximumpoolsize:20minimumidle:10mybatis:typealiasespackage:com。leyou。userservice。pojo 项目结构 5。1。3。启动并测试: 启动项目,访问接口:http:localhost:8081user7 也就是通过上面的过程。我们的服务提供者已经创建好了。服务的调用者。 3。2。1。创建工程 与上面类似,这里不再赘述,需要注意的是,我们调用userservice的功能,因此不需要mybatis相关依赖了。 pom:lt;?xmlversion1。0encodingUTF8?4。0。0com。leyou。demouserconsumerdemoartifactId0。0。1SNAPSHOTjaruserconsumerdemoDemoprojectforSpringBootorg。springframework。bootspringbootstarterparentartifactId2。0。1。RELEASEproject。build。sourceEncodingUTF8project。build。sourceEncodingproject。reporting。outputEncodingUTF8project。reporting。outputEncodingjava。version1。8java。versionorg。springframework。bootspringbootstarterwebartifactIdcom。squareup。okhttp3okhttpartifactId3。9。0org。springframework。bootspringbootmavenpluginartifactId 5。2。2。编写代码 首先在启动类中注册RestTemplate:SpringBootApplicationpublicclassUserConsumerDemoApplication{BeanpublicRestTemplaterestTemplate(){这次我们使用了OkHttp客户端,只需要注入工厂即可returnnewRestTemplate(newOkHttp3ClientHttpRequestFactory());}publicstaticvoidmain(String〔〕args){SpringApplication。run(UserConsumerDemoApplication。class,args);}} 然后编写UserDao,注意,这里不是调用mapper查数据库,而是通过RestTemplate远程查询userservicedemo中的接口:ComponentpublicclassUserDao{AutowiredprivateRestTemplaterestTemplate;publicUserqueryUserById(Longid){Stringurlhttp:localhost:8081userid;returnthis。restTemplate。getForObject(url,User。class);}} 然后编写userservice,循环查询UserDAO信息:ServicepublicclassUserService{AutowiredprivateUserDaouserDao;publicListquerUserByIds(Listids){ListusersnewArrayList();for(Longid:ids){Useruserthis。userDao。queryUserById(id);users。add(user);}returnusers;}}pre 编写controller:RestControllerRequestMapping(consume)publicclassConsumerController{AutowiredprivateUserServiceuserService;GetMappingpublicListconsume(RequestParam(ids)Listids){returnthis。userService。queryUserByIds(ids);}}pre 5。2。3。启动测试: 因为我们没有配置端口,那么默认就是8080,我们访问:http:localhost:8080consume?ids6,7,8 一个简单的远程服务调用案例就实现了。 5。3。有没有问题? 简单回顾一下,刚才我们写了什么:useservicedemo:一个提供根据id查询用户的微服务consumerdemo:一个服务调用者,通过RestTemplate远程调用userservicedemo 流程如下: 存在什么问题?在consumer中,我们把url地址硬编码到了代码中,不方便后期维护consumer需要记忆userservice的地址,如果出现变更,可能得不到通知,地址将失效consumer不清楚userservice的状态,服务宕机也不知道userservice只有1台服务,不具备高可用性即便userservice形成集群,consumer还需自己实现负载均衡 其实上面说的问题,概括一下就是分布式服务必然要面临的问题:服务管理如何自动注册和发现如何实现状态监管如何实现动态路由服务如何实现负载均衡服务如何解决容灾问题服务如何实现统一配置 以上的问题,我们都将在SpringCloud中得到答案。 接下来将在我的讲解的微服务的5大组件中得到解决。 关于微服务的相关文章,我会一直更新下去。欢迎朋友转发和收藏。