使用Spring Cloud搭建的微服务示例

Spring Cloud是一个可以构建云应用的框架，使用该框架可以解决应用在迁移到分布式环境时所面临的众多问题。应用的微服务化目的是旨在简化开发、部署和维护的工作量，将应用程序分解可以帮助程序开发人员一次只专注于一个问题，同时在进行系统改进时不影响其它部分的运行。

另一方面，使用微服务时也带来了一些挑战：

  • 配置的外部化实现，配置改变是不需要重启服务。
  • 服务是如何发现的。
  • 服务在不同主机上进行部署，如何隐藏其复杂性。

在本示例中我们将建立5个微服务：配置服务、注册服务、网关服务、图书管理服务和评分服务。前三个是微服务应用所需要的服务，后两个可看做业务服务。这5个微服务可做为云应用开发的基础实现，以应对上述的挑战。

1 配置服务

开发云应用程序时会遇到一个问题，如何为我们的服务维护和分发配置。我们不可能为每个环境的程序进行配置，分散的配置会影响我们的服务水平，增加安全风险漏洞。为了解决这个问题,我们将所有的配置保存到一个Git仓库，并创建一个应用服务来管理我们所有的应用程序配置。这里将建立一个非常简单的实现。

1.1 创建

创建一个Spring Boot工程，在POM中增加一个依赖

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-config-server</artifactId>
</dependency>

1.2 主应用类

@SpringBootApplication
@EnableConfigServer
public class ConfigApplication {
    public static void main(String[] args) {
        SpringApplication.run(ConfigApplication.class, args);
    }
}

@EnableConfigServer注解 将我们的应用变为配置服务器。

1.3 配置

在src/main/resources目录下新建application.properties文件

spring.application.name=config
server.port=8081

#配置Git仓库位置
spring.cloud.config.server.git.uri=ssh://admin@localhost:29418/Test.git
#配置仓库路径下的相对搜索位置，可以配置多个
spring.cloud.config.server.git.searchPaths=application-config
#配置为true表示启动时就克隆配置缓存到本地。
spring.cloud.config.server.git.clone-on-start=true
#访问Git仓库的用户名
spring.cloud.config.server.git.username=admin
#访问Git仓库的用户密码
spring.cloud.config.server.git.password=admin

配置服务名和端口，一个Git仓库。本例中在本机搭建了一个Git仓库。
在Windows系统下搭建本地的Git服务器，可参看教程 http://blog.csdn.net/qwer971211/article/details/71156055

2 服务发现

现在我们有了配置服务，我们需要一种方法让所有的服务都能够找到彼此。我们将通过设置EUKA服务发现器来解决这个问题。由于我们的应用程序可以在任意IP/端口组合上运行，所以我们需要一个中央地址注册表，它可以用作应用程序地址查找。

当提供新的服务时，它将与服务发现器通信并注册其地址，以便其他人能够与其通信。这样，其他应用程序可以在请求时来使用这些信息。

2.1 创建

创建一个Spring Boot工程，在POM中增加依赖

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

2.2 主应用类

@SpringBootApplication
@EnableEurekaServer
public class DiscoveryApplication {
    public static void main(String[] args) {
        SpringApplication.run(DiscoveryApplication.class, args);
    }
}

@ EnablieUrkasever将使用Netflix Eurka配置这个服务器作为服务发现器。Spring Boot将自动检测类路径上的配置依赖性，并从配置服务器中查找配置。

2.3 配置

我们将创建2个properties文件。

在src/main/resources目录下新建bootstrap.properties文件。定义服务名和配置服务器地址。

spring.cloud.config.name=discovery
spring.cloud.config.uri=http://localhost:8081

在Git仓库里保存配置discovery.properties，应用将通过配置服务器来读取这些配置。

spring.application.name=discovery
server.port=8082

eureka.instance.hostname=localhost

eureka.client.serviceUrl.defaultZone=http://localhost:8082/eureka/
eureka.client.register-with-eureka=false
eureka.client.fetch-registry=false

文件名必须与spring.application.name参数相同。这里定义了Eureka服务注册器的一些参数。

2.4 将配置服务注册到服务注册器里

在配置服务的POM文件里添加依赖

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

同时在application.properties文件里增加下面这些配置

eureka.client.region = default
eureka.client.registryFetchIntervalSeconds = 5
eureka.client.serviceUrl.defaultZone=http://localhost:8082/eureka/

这样就将配置服务做为一个微服务注册到服务注册器里供其他应用来访问。

3 服务网关

现在，我们已经解决了服务配置和发现的问题，但客户端访问所有的应用服务仍然存在问题。如果我们把所有的东西都放在一个分布式系统中，那么我们将不得不管理复杂的CORS头来允许客户端的跨域请求。我们可以通过创建网关服务器来解决这个问题。它将充当一个反向代理接管从客户机到后端服务器的请求。

网关服务器在微服务体系结构中是一个很好的应用，因为它允许所有响应源于单个主机。这将消除对CORS的需求，并给我们一个方便的地方来处理常见的问题，如身份验证。

3.1 创建

创建一个Spring Boot工程，在POM中增加依赖

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-config</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-zuul</artifactId>
</dependency>

3.2 主应用类

@SpringBootApplication
@EnableZuulProxy
@EnableEurekaClient
public class GatewayApplication {
    public static void main(String[] args) {
        SpringApplication.run(GatewayApplication.class, args);
    }
}

3.3 配置

我们将创建2个properties文件。

在src/main/resources目录下新建bootstrap.properties文件。定义服务名和配置服务器地址。

spring.cloud.config.name=gateway
spring.cloud.config.discovery.service-id=config
spring.cloud.config.discovery.enabled=true
 
eureka.client.serviceUrl.defaultZone=http://localhost:8082/eureka/

在Git仓库里保存配置gateway.properties，应用将通过配置服务器来读取这些配置。

spring.application.name=gateway
server.port=8080

eureka.client.region = default
eureka.client.registryFetchIntervalSeconds = 5

zuul.routes.book-service.path=/book-service/**
zuul.routes.book-service.sensitive-headers=Set-Cookie,Authorization
hystrix.command.book-service.execution.isolation.thread.timeoutInMilliseconds=600000

zuul.routes.rating-service.path=/rating-service/**
zuul.routes.rating-service.sensitive-headers=Set-Cookie,Authorization
hystrix.command.rating-service.execution.isolation.thread.timeoutInMilliseconds=600000

zuul.routes.discovery.path=/discovery/**
zuul.routes.discovery.sensitive-headers=Set-Cookie,Authorization
zuul.routes.discovery.url=http://localhost:8082
hystrix.command.discovery.execution.isolation.thread.timeoutInMilliseconds=600000

Zuul.Router属性允许我们基于URL匹配器来路由某些请求。这里的配置告诉ZUUL将访问‘/book-service/**’中的任何请求路由到服务名为‘book-service’的应用程序。ZUUL将使用应用程序名称从服务发现器中查找主机，并将请求转发给该服务器。

4 图书服务

在微服务体系结构中，我们可以自由地做出大量的应用来满足商业目标。这里我们创建一个图书服务来处理应用程序中的相关操作。

4.1 创建

创建一个Spring Boot工程，在POM中增加依赖

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

4.2 主应用类

@SpringBootApplication
@EnableEurekaClient
@RestController
@RequestMapping("/books")
public class BookServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(BookServiceApplication.class, args);
    }
 
    private List<Book> bookList = Arrays.asList(
        new Book(1L, "Spring Cloud微服务实战", "翟永超"),
        new Book(2L, "Mastering Spring Cloud", "Piotr Mińkowski")
    );
 
    @GetMapping("")
    public List<Book> findAllBooks() {
        return bookList;
    }
 
    @GetMapping("/{bookId}")
    public Book findBook(@PathVariable Long bookId) {
        return bookList.stream().filter(b -> b.getId().equals(bookId)).findFirst().orElse(null);
    }
}

在主应用类里同时添加了REST controller，提供一些REST接口。
还有一个Book的POJO类

public class Book {
    private Long id;
    private String author;
    private String title;
 
    // standard getters and setters
}

4.3 配置

我们将创建2个properties文件。

在src/main/resources目录下新建bootstrap.properties文件。定义服务名和配置服务器地址。

spring.cloud.config.name=book-service
spring.cloud.config.discovery.service-id=config
spring.cloud.config.discovery.enabled=true
 
eureka.client.serviceUrl.defaultZone=http://localhost:8082/eureka/

在Git仓库里保存配置book-service.properties，应用将通过配置服务器来读取这些配置。

spring.application.name=book-service
server.port=8083

eureka.client.region = default
eureka.client.registryFetchIntervalSeconds = 5

4.4 运行

依次启动各个服务，在浏览器中访问http://localhost:8080/book-service/books 我们得到一个JSON对象，对象里包含了在controller里定义的2本书的信息。
需要注意的是我们并没有直接访问book service的8083端口，而是通过网关服务器的8080端口进行访问。

5 评分服务

类似于图书服务，处理应用程序中与评分相关的操作。

5.1 创建

创建一个Spring Boot工程，在POM中增加依赖

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

5.2 主应用类

@SpringBootApplication
@EnableEurekaClient
@RestController
@RequestMapping("/ratings")
public class RatingServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(RatingServiceApplication.class, args);
    }

    private List<Rating> ratingList = Arrays.asList(new Rating(1L, 1L, 2), new Rating(2L, 1L, 3), new Rating(3L, 2L, 4),
            new Rating(4L, 2L, 5));

    @GetMapping("")
    public List<Rating> findRatingsByBookId(@RequestParam Long bookId) {
        return bookId == null || bookId.equals(0L) ? Collections.emptyList()
                : ratingList.stream().filter(r -> r.getBookId().equals(bookId)).collect(Collectors.toList());
    }

    @GetMapping("/all")
    public List<Rating> findAllRatings() {
        return ratingList;
    }
}

在主应用类里同时添加了REST controller，提供一些REST接口。
还有一个Rating的POJO类

public class Rating {
    private Long id;
    private Long bookId;
    private int stars;
 
    //standard getters and setters
}

5.3 配置

我们将创建2个properties文件。

在src/main/resources目录下新建bootstrap.properties文件。定义服务名和配置服务器地址。

spring.cloud.config.name=rating-service
spring.cloud.config.discovery.service-id=config
spring.cloud.config.discovery.enabled=true

eureka.client.serviceUrl.defaultZone=http://localhost:8082/eureka/

在Git仓库里保存配置rating-service.properties，应用将通过配置服务器来读取这些配置。

spring.application.name=rating-service
server.port=8084

eureka.client.region = default
eureka.client.registryFetchIntervalSeconds = 5

5.4 运行

依次启动各个服务，在浏览器中访问 http://localhost:8080/rating-service/ratings/all 我们得到一个JSON对象，对象里包含了在controller里定义的评分信息。
需要注意的是我们并没有直接访问rating service的8084端口，而是通过网关服务器的8080端口进行访问。

6 总结

现在我们能够将Spring Cloud各个部分组合到一个微服务应用程序中。这构成了用来构建更复杂的应用程序的基础。

©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 215,245评论 6赞 497
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 91,749评论 3赞 391
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 160,960评论 0赞 350
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 57,575评论 1赞 288
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 66,668评论 6赞 388
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 50,670评论 1赞 294
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 39,664评论 3赞 415
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 38,422评论 0赞 270
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 44,864评论 1赞 307
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,178评论 2赞 331
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,340评论 1赞 344
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 35,015评论 5赞 340
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 40,646评论 3赞 323
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,265评论 0赞 21
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,494评论 1赞 268
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 47,261评论 2赞 368
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 44,206评论 2赞 352

推荐阅读更多精彩内容

  • Spring Cloud
    Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具（例如配置管理，服务发现，断路器，智...
    卡卡罗2017阅读 134,647评论 18赞 139
  • Spring boot参考指南
    Spring Boot 参考指南 介绍 转载自:https://www.gitbook.com/book/qbgb...
    毛宇鹏阅读 46,801评论 6赞 342
  • 基于Spring Cloud的微服务落地
    微服务架构模式的核心在于如何识别服务的边界，设计出合理的微服务。但如果要将微服务架构运用到生产项目上，并且能够发挥...
    程序员技术圈阅读 2,781评论 10赞 27
  • 一 . 树莓派A20 基本环境搭建 1
    1 基础环境搭建 我的实验环境： 1.1 准备基础文件包 1.交叉编译工具链：gcc-linaro-arm-lin...
    wit_yuan阅读 2,564评论 0赞 0
  • 亦然
    你说我不喜欢你了像从前一样，可是你不知道，你也亦然。恍如隔世，变得如此陌生，我许你一片叶子，不要以为如此廉价，它...
    管等等阅读 534评论 0赞 4