文档章节

综合使用spring cloud技术实现微服务应用

逝去的回忆
 逝去的回忆
发布于 2017/02/17 17:45
字数 1811
阅读 11
收藏 1
点赞 0
评论 0

  在之前的章节,我们已经实现了配置服务器、注册服务器、微服务服务端,实现了服务注册与发现。这一章将实现微服务的客户端,以及联调、实现整个spring cloud框架核心应用。

  本文属于《7天学会spring cloud系列》之五,涉及到的项目包括:

  开源项目:http://git.oschina.net/zhou666/spring-cloud-7simple

  • cloud-config-server:配置服务器
  • cloud-eureka-server:eureka注册服务器
  • cloud-simple-service:一个使用mybatis的数据库应用,服务端
  • cloud-simple-ui:webui客户端

  我们先来看看如何实现webui客户端。在spring boot中,已经不推荐使用jsp,所以你如果使用jsp来实现webui端,将会很麻烦。这可能跟现在的开发主流偏重移动端有关,跟微服务有关,跟整个时代当前的技术需求有关。单纯以html来作为客户端,有很多好处,比如更利于使用高速缓存;使后台服务无状态话,更利于处理高并发;更利于页面作为服务,小服务组合成大服务等。

  我们首选来创建webui应用,参考git cloud-simple-ui工程:

   

         这个应用包括前端html页面,还包括一个后台controller浅层。这是一个前端应用,为什么要包括controller浅层?这是因为这个controller浅层是用来做服务组合的,因为一个页面可能涉及到调用多个服务,而这些服务又有可能涉及事务和并发问题,所以还是需要靠java来完成。当然,也可以单独编写一个api gateway来实现这一层,可以使用go、node.js语言等,也可以使用java/netty(主流还是java,因为开发部署效率高)。

       Controller层的WebApplication就是这个应用的入口,代码如下:

  @SpringBootApplication
  @EnableEurekaClient
  @EnableHystrix
  public class WebApplication {
         public static void main(String[] args) throws Exception {
               SpringApplication.run(WebApplication.class, args);
    }
  }

  这些注解大都在前面提到过用法:

  @SpringBootApplication相当于@Configuration、@EnableAutoConfiguration、@ComponentScan三个注解合用。

  @EnableEurekaClient配置本应用将使用服务注册和服务发现,注意:注册和发现用这一个注解。

  @EnableHystrix表示启用断路器,断路器依赖于服务注册和发现。

  Controller层的service包封装了服务接口访问,UserService类代码如下:

@Service
public class UserService {
              
   @Autowired
  RestTemplate restTemplate; 
   final String SERVICE_NAME="cloud-simple-service";        
   
   @HystrixCommand(fallbackMethod = "fallbackSearchAll")
  public List<User> searchAll() {
      return restTemplate.getForObject("http://"+SERVICE_NAME+"/user", List.class);
  }   

    private List<User> fallbackSearchAll() {
         System.out.println("HystrixCommand fallbackMethod handle!");
         List<User> ls = new ArrayList<User>();
         User user = new User();
         user.setUsername("TestHystrix");
         ls.add(user);
         return ls;

  }
}

  这里使用了断路器,就是@HystrixCommand注解。断路器的基本作用就是@HystrixCommand注解的方法失败后,系统将自动切换到fallbackMethod方法执行。断路器Hystrix具备回退机制、请求缓存和请求打包以及监控和配置等功能,在这里我们只是使用了它的核心功能:回退机制,使用该功能允许你快速失败并迅速恢复或者回退并优雅降级。

  这里使用restTemplate进行服务调用,因为使用了服务注册和发现,所以我们只需要传入服务名称SERVICE_NAME作为url的根路径,如此restTemplate就会去EurekaServer查找服务名称所代表的服务并调用。而这个服务名称就是在服务提供端cloud-simple-service中spring.application.name所配置的名字,这个名字在服务启动时连同它的IP和端口号都注册到了EurekaServer。

  封装好服务调用后,你只需要在Controller类里面注入这个服务即可:

@RestController
public class UserController {       

       @Autowired
       UserService userService;    
  
       @RequestMapping(value="/users")
       public ResponseEntity<List<User>> readUserInfo(){
              List<User> users=userService.searchAll();         
              return new ResponseEntity<List<User>>(users,HttpStatus.OK);
       }
}

  至此这个webui应用的java端就开发完了,我们再来看页面模块。

  可以看到,页面文件都放在resources\static目录下面,这是spring boot默认的页面文件主文件夹,你如果在里面放一个index.html,那么直接访问根路径http://localhost:8080/会直接定位到这个页面。所以这个static就相当于传统web项目里面的webapp文件夹。

  在这里包括两个页面index.html和user-page.html,用户访问首页时将会加载user-page.html子页面。

  首页index.html页面核心代码如下:

<html ng-app="users">
 <head></head>
 <body>
       &nbsp;&nbsp;&nbsp;     
  <script src="js/app.js"></script>         
  <div ng-view="" class="container">
      
  </div>         页面user-page.html代码如下:   
  <div>
      
   <ul ng-controller="userCtr">
     &nbsp;   
    <li ng-repeat="item in userList">   {{item.username}}&nbsp;&nbsp;&nbsp;   </li>   
   </ul>   
  </div>
 </body>
</html>

  app.js页面代码如下:

angular.module('users', ['ngRoute']).config(function($routeProvider) {
	  $routeProvider.when('/', {
		       templateUrl: 'user-page.html',
		       controller: 'userCtr'
	}) 
}).controller('userCtr',
function($scope, $http) {
	  $http.get('users').success(function(data) {
		          //alert(data+"");
		       $scope.userList = data;  
	});  
});

  这里使用了angularJS库。Angular可以绑定模型数据到页面变量,在user-page.html看到的{{item.username}}就是它的绑定语法,这个语法根jsp或freemarker这些模板技术都类似,只不过Angular是用在客户端的,而前者是用在服务端的。

  至此这个webui应用就开发完了,改一下配置文件和pom文件就可以运行了。配置文件包括配置管理服务器地址,注册服务器地址等,在bootstrap.properties文件中:

  spring.cloud.config.uri=http://127.0.0.1:${config.port:8888}

  spring.cloud.config.name=cloud-config

  spring.cloud.config.profile=${config.profile:dev}

  eureka.client.serviceUrl.defaultZone=http\://localhost\:8761/eureka/

  spring.application.name=simple-ui-phone

  这些配置我们在上一章已经提到过了,这里不再解释。因为使用了断路器,所以相比上一章的cloud-simple-service项目,需要加入hystrix依赖,只有一个starter依赖:

  <dependency>
     <groupId>org.springframework.cloud</groupId>
     <artifactId>spring-cloud-starter-hystrix</artifactId>
  </dependency>

  Spring把事情做的如此简单,不管是服务注册还是断路器,连同注解加配置文件再加上依赖总共不超过十行代码。如此简单就可以使用一个分布式应用,也难怪国内外业内人员都高度重视这个框架,在简单和速度就是硬道理的今天,这个框架有着重要的意义。

   剩下最重要的事情就是进行部署了,我们以此使用命令启动这些服务及应用:

  1)  java -jar cloud-config-server-0.0.1.jar,启动配置服务器,固定绑定端口8888;

  2)  java -jar cloud-eureka-server-1.0.0.jar,启动注册服务器,固定绑定端口8671;

  3)  java -jar cloud-simple-service-1.0.0.jar --server.port=8081 >log8081.log,启动后台服务,绑定端口8081

  4)  java -jar cloud-simple-service-1.0.0.jar --server.port=8082 >log8082.log,启动后台服务,绑定端口8082

  5)  java -jar cloud-simple-ui-1.0.0.jar --server.port=8080 >log8080.log,启动前端ui应用,绑定端口8080

  运行http://localhost:8080/即可看到运行的结果。其中“>log8080.log”表示输出日志到文件。

  这里运行了两个cloud-simple-service实例,主要是为了演示ribbon负载均衡。默认情况下使用ribbon不需要再作任何配置,不过它依赖于注册服务器。当然也可以对ribbon进行一些自定义设置,比如配置它的超时时间、重试次数等。启用了负载均衡后,当我们关掉前端页面上次指向的服务时(从日志中看),比如我们刷新页面看到它调用的是8081服务,那么我们关掉这个服务。关掉后再刷新会发现执行了断路器,过几秒再刷新,它已经切换到了8082这台服务器,这说明负载均衡起作用了。

本文转载自:http://www.cnblogs.com/skyblog/p/5133796.html

共有 人打赏支持
逝去的回忆
粉丝 12
博文 132
码字总数 219842
作品 0
深圳
高级程序员
Spring Cloud-honghu Cloud分布式微服务云系统

简介 鸿鹄云Cloud是基于SpringCloud来封装的,是一系列框架的有序集合。利用Spring Boot的开发模式简化了分布式系统基础设施的开发,如服务发现、注册、配置中心、消息总线、负载均衡、断路器...

itcloud ⋅ 04/25 ⋅ 0

SpringCloud实战9-Stream消息驱动

官方定义 Spring Cloud Stream 是一个构建消息驱动微服务的框架。   应用程序通过 inputs 或者 outputs 来与 Spring Cloud Stream 中binder 交互,通过我们配置来 binding ,而 Spring Clo...

狂小白 ⋅ 05/29 ⋅ 0

Spring Cloud构建微服务架构服务注册与发现

Spring Cloud简介 Spring Cloud是一个基于Spring Boot实现的云应用开发工具,它为基于JVM的云应用开发中涉及的配置管理、服务发现、断路器、智能路由、微代理、控制总线、全局锁、决策竞选、...

明理萝 ⋅ 06/11 ⋅ 0

码云携手华为云微服务平台,有礼召集微服务示范项目

继华为云容器平台对接码云(详情)后,华为云的微服务平台也将接入码云,目前正在内测,计划本月内上线。 现在华为云和码云一起为微服务平台征集微服务示范项目。如果您的项目入选“示范项目...

码云Gitee ⋅ 04/23 ⋅ 15

双11同款!阿里云发布全局事务服务GTS:每秒处理10万笔事务

5月30日,阿里云宣布全局事务服务产品GTS正式商用,每秒可处理10万笔事务,将分布式事务这个“贵族技术”变为“平民技术 ”,可解决跨数据库、消息、服务的分布式环境下的事务一致性问题,让...

中间件小哥 ⋅ 05/30 ⋅ 0

SpringCloud实战7-Config分布式配置管理

分布式环境下的统一配置框架,已经有不少了,比如百度的disconf,阿里的diamand 官方文档对spring Cloud Config的描述如下:   Spring Cloud Config为分布式系统中的外部配置提供服务器和客...

狂小白 ⋅ 05/21 ⋅ 0

Spring Cloud构建微服务架构服务消费基础

使用LoadBalancerClient 在Spring Cloud Commons中提供了大量的与服务治理相关的抽象接口,包括、这里我们即将介绍的等。对于这些接口的定义我们在上一篇介绍服务注册与发现时已经说过,Spr...

itcloud ⋅ 06/13 ⋅ 0

【Spring Cloud】分布式必学springcloud(一)——简介和看法

一、前言 开篇之前,我想说,springcloud会完胜dubbo。 小编以前做分布式是用的webservice、dubbo。最近的项目中,开始使用了springcloud,springcloud包含了很多的组件,这些组件是dubbo没有...

kisscatforever ⋅ 04/16 ⋅ 0

SpringCloud实战8-Bus消息总线

好了现在我们接着上一篇的随笔,继续来讲。上一篇我们讲到,我们如果要去更新所有微服务的配置,在不重启的情况下去更新配置,只能依靠spring cloud config了,但是,是我们要一个服务一个服...

狂小白 ⋅ 05/23 ⋅ 0

史上最简单的SpringCloud教程 | 第四篇:断路器(Hystrix)

在微服务架构中,根据业务来拆分成一个个的服务,服务与服务之间可以相互调用(RPC),在Spring Cloud可以用RestTemplate+Ribbon和Feign来调用。为了保证其高可用,单个服务通常会集群部署。...

方宏春 ⋅ 04/14 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

zblog2.3版本的asp系统是否可以超越卢松松博客的流量[图]

最近访问zblog官网,发现zlbog-asp2.3版本已经进入测试阶段了,虽然正式版还没有发布,想必也不久了。那么作为aps纵横江湖十多年的今天,blog2.2版本应该已经成熟了,为什么还要发布这个2.3...

原创小博客 ⋅ 59分钟前 ⋅ 0

聊聊spring cloud的HystrixCircuitBreakerConfiguration

序 本文主要研究一下spring cloud的HystrixCircuitBreakerConfiguration HystrixCircuitBreakerConfiguration spring-cloud-netflix-core-2.0.0.RELEASE-sources.jar!/org/springframework/......

go4it ⋅ 今天 ⋅ 0

二分查找

二分查找,也称折半查找、二分搜索,是一种在有序数组中查找某一特定元素的搜索算法。搜素过程从数组的中间元素开始,如果中间元素正好是要查找的元素,则搜素过程结束;如果某一特定元素大于...

人觉非常君 ⋅ 今天 ⋅ 0

VS中使用X64汇编

需要注意的是,在X86项目中,可以使用__asm{}来嵌入汇编代码,但是在X64项目中,再也不能使用__asm{}来编写嵌入式汇编程序了,必须使用专门的.asm汇编文件来编写相应的汇编代码,然后在其它地...

simpower ⋅ 今天 ⋅ 0

ThreadPoolExecutor

ThreadPoolExecutor public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, ......

4rnold ⋅ 昨天 ⋅ 0

Java正无穷大、负无穷大以及NaN

问题来源:用Java代码写了一个计算公式,包含除法和对数和取反,在页面上出现了-infinity,不知道这是什么问题,网上找答案才明白意思是负的无穷大。 思考:为什么会出现这种情况呢?这是哪里...

young_chen ⋅ 昨天 ⋅ 0

前台对中文编码,后台解码

前台:encodeURI(sbzt) 后台:String param = URLDecoder.decode(sbzt,"UTF-8");

west_coast ⋅ 昨天 ⋅ 0

实验楼—MySQL基础课程-挑战3实验报告

按照文档要求创建数据库 sudo sercice mysql startwget http://labfile.oss.aliyuncs.com/courses/9/createdb2.sqlvim /home/shiyanlou/createdb2.sql#查看下数据库代码 代码创建了grade......

zhangjin7 ⋅ 昨天 ⋅ 0

一起读书《深入浅出nodejs》-node模块机制

node 模块机制 前言 说到node,就不免得提到JavaScript。JavaScript自诞生以来,经历了工具类库、组件库、前端框架、前端应用的变迁。通过无数开发人员的努力,JavaScript不断被类聚和抽象,...

小草先森 ⋅ 昨天 ⋅ 0

Java桌球小游戏

其实算不上一个游戏,就是两张图片,不停的重画,改变ball图片的位置。一个左右直线碰撞的,一个有角度碰撞的。 左右直线碰撞 package com.bjsxt.test;import javax.swing.*;import j...

森林之下 ⋅ 昨天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部