vlambda博客
学习文章列表

我们将创建一些微服务来组成solution，然后我们将解决方案分解成小块，即微服务。为此，我们将使用限界上下文模式 是 < strong>领域驱动设计（DDD）。

让我们看一下下面的 图，以了解我们将构建什么：

这是对我们将在这几章中所做的事情的总结；我们已经为每个微服务定义了基本功能。

现在，我们来看看组件；让我们进入下一节。

以下图说明了整个解决方案，我们将在以下章节中实施：

正如我们所看到的，有不同种类的组件。一些组件将通过 网关 向最终用户（在我们的例子中是我们的客户）公开。公司用户将使用一个类别来注册航班，例如，这些微服务也将在 Gateway 上公开。

除了 Gateway 服务外，基础设施类别不会在 Internet 上公开。这些服务有助于解决方案基础架构，不应因为其中存在敏感数据而暴露。

有很多事情要做；让我们继续表演吧。

让我们用 Spring Initializr 创建我们的 project。转到 Spring Initializr (https://start.spring.io/) 并按照图片说明进行操作：

点击Generate Project，然后我们就可以在IDE上打开项目了。

我们将 Git 存储库用作 property 源，然后我们需要创建一个存储库来保存这些文件。但是，在此之前，让我们导航到 pom.xml 文件并查看一些有趣的东西。我们可以找到以下依赖：

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

它是一个配置服务器依赖项。它使我们能够在我们的应用程序中使用配置服务器。记住，我们需要把它放到 pom.xml 文件中来实现所需的Config Server。

package springfive.airline.configserver;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.config.server.EnableConfigServer;

@EnableConfigServer
@SpringBootApplication
public class ConfigServerApplication {

public static void main(String[] args) {
    SpringApplication.run(ConfigServerApplication.class, args);
}

}

server:
  port: 5000

spring:
  cloud:
    config:
      name: configserver
server:
        git:
          uri: https://github.com/PacktPublishing/Spring-5.0-By-Example
search-paths: config-files*

Running the Config Server

好工作;我们的 configuration 服务器可以使用了。然后让我们运行它。我们可以使用 JAR 文件，也可以通过 IDE，由您选择所需的方式。

我们可以使用 Java 命令行或 IDE 来运行它。我更喜欢使用 IDE，因为它使我们能够调试并进行一些代码更改。

运行。

输出应如下所示：

Tomcat 启动成功；我们的配置服务器已启动并正在运行。我们可以在我们的配置服务器中找到一些不同的端点。这些端点被公开以服务于 configuration 文件。

Spring Cloud Config Server 也支持配置文件，为不同的环境提供不同的配置很重要。

Config Server 支持的模式如下：

<application-name>-<profile>.<properties|yaml>

Copy

牢记这一点非常重要。此外，必须在我们的微服务中声明 application.name 属性，以识别应用程序。

我们可以在应用引导程序上找到 Spring Cloud Config Server 提供的端点。看一下日志：

记住配置服务器支持环境；因此，端点上有一种正则表达式。查看 "/{name}-{profiles}.yml" 端点。

Testing our Config Server

我们能够通过 REST API 测试我们的配置 Server。

让我们创建一个简单的 yaml 文件来创建测试；该文件应称为 dummy.yaml：

info:
  message: "Testing my Config Server"
status: "It worked"

Copy

将其推送到 GitHub——如果您使用的是 GitHub 书籍，则无需执行此步骤。然后，我们可以使用以下命令调用 Config Server API：

curl http://localhost:5000/dummy/default | jq

Copy

该命令在配置文件 default 中查找 dummy 配置； URL 是不言自明的。应显示以下输出：

我们的配置服务器是完全可操作的。现在，我们将使用 Netflix Eureka 配置我们的服务发现。

为了在我们的基础设施中启用服务发现，我们需要创建一个服务实例来充当服务发现。 Spring Cloud Eureka 服务器使我们能够完成这项任务。让我们创建我们的项目。进入Spring Initializr并填写信息，如以下截图所示：

查看所需的依赖项。 Eureka 服务器是允许我们启动服务发现服务器的依赖项。

让我们在 IDE 上打开项目并开始配置它。我们将在下一节中执行此操作。

在开始配置之前，我们将创建 main 类。此类将启动 Spring Boot 应用程序。 Eureka 服务器嵌入在应用程序中。这是一个非常标准的 Spring Boot 应用程序，只有一个注解。

main 应用程序类应如下所示：

package springfive.airline.eureka;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

@EnableEurekaServer
@SpringBootApplication
public class EurekaApplication {

public static void main(String[] args) {
    SpringApplication.run(EurekaApplication.class, args);
}

}

@EnableEurekaServer 注解将启动我们的嵌入式Eureka服务器应用程序并使其准备好使用。它还将在我们的应用程序中启用服务注册表。

我们的 Eureka 服务器需要使用前面部分中配置的 Spring Cloud Server 进行配置。然后，我们需要将 application.yaml 从我们的项目中移除，以便正确使用配置服务器。而不是 application.yaml, 我们需要放置 bootstrap.yaml 并在其上放置 Config Server 地址。

然后，我们需要：

让我们从 discovery.yaml 文件开始。该文件应如下所示：

server:
  port: 8761

eureka:
  instance:
    hostname: localhost
    health-check-url-path: /actuator/health
    status-page-url-path: /actuator/info 
  client:
    registerWithEureka: false
    fetchRegistry: false
logging:
  level:
    com.netflix.discovery: 'ON'
    org.springframework.cloud: 'DEBUG'

有一些有趣的事情可以探索。我们使用 localhost 作为 hostname 因为我们在开发者机器上运行。关于 URL 健康检查和状态页面有几个配置 - 注意与服务器相关的配置。它们位于 eureka.instance YAML 节点下方。配置为health-check-url-path和status-page-url-path。我们也可以使用默认值，但是新的 Spring Boot Actuator 改变了这两个特性的 URL，所以我们需要正确配置它们。  

eureka.client YAML 节点是关于客户端配置的；在我们的例子中，我们将 registerWithEureka 设置为 false。我们不希望 Eureka 服务器也充当客户端。 fetchRegistry 配置也是如此，它是一个客户端配置，它会缓存 Eureka 注册中心的信息。

logging 节点是关于日志配置的。

太棒了——我们的 gateway.yaml 已经准备好了。

让我们在 Eureka 服务器项目类路径中创建我们的 bootstrap.yaml 文件。该文件应如下所示：

spring:
  application:
    name: discovery
cloud:
    config:
      uri: http://localhost:5000
label: master

Easy peasy – 我们已经配置了 spring.cloud.config。它指示配置服务器地址的 Spring。另外，我们配置了label，也就是我们使用 版本控制系统 (VCS) 作为存储库.

做得好。配置已准备就绪。是时候运行它了。让我们在下一节中进行。

Eureka server 可以使用了。我们将启动 Spring Boot 应用程序并将我们的 Eureka 服务器上线。我们可以使用 Java 命令行或 IDE 来运行它。我更喜欢使用 IDE，因为它使我们能够调试并进行一些代码更改。

运行！

我们应该在应用程序引导日志中看到以下行：

惊人的。查看日志的以下行：

2018-01-07 14:42:42.636  INFO 11191 --- [      Thread-32] e.s.EurekaServerInitializerConfiguration : Started Eureka Server

这意味着我们的 Eureka 服务器已经可以使用了。要查看解决方案，我们可以前往 Eureka 服务器主页。转到 http://localhost:8761/，会显示如下页面：

正如我们所见，还没有可用的服务实例。我们可以找到一些相关的信息比如服务器Uptime，当前数据中心 ，以及 当前时间。  General Info部分有一些信息，关于Eureka server 正在运行。

好工作。我们的服务发现服务正在运行。我们将很快使用这个基础设施。

在我们开始工作之前，我们需要配置一个Zipkin ser​​ver需要的服务。默认情况下，Zipkin ser​​ver 使用内存数据库，但不建议用于生产；通常，开发人员使用此功能来演示 Zipkin 功能。

我们将使用 MySQL 作为数据存储。 Zipkin 服务器还支持不同的来源，例如 Cassandra 和 Elasticsearch。

Spring Cloud Sleuth 支持同步和异步操作。同步操作通过 HTTP 协议进行，异步可以通过 RabbitMQ 或 Apache Kafka 完成。

要使用HTTP，即REST API，我们应该使用 @EnableZipkinServer，它将通过SpanStore<委托REST层的持久性/代码>接口。

我们将选择异步解决方案，因为它非常适合我们的项目，并且我们不希望跟踪收集器导致一些性能问题。异步解决方案使用 Spring Cloud Stream binder 来存储 Spans。我们选择 RabbitMQ 消息代理来执行此操作。它可以使用 @EnableZipkinStreamServer 注释来实现，这些注释将 Spring Sleuth 配置为使用流存储 Span。

让我们创建 docker-compose-min.yaml 来引导我们的 RabbitMQ 和 MySQL 容器。该文件应如下所示：

version: '3'
services:

  rabbitmq:
    hostname: rabbitmq
image: rabbitmq:3.7.0-management-alpine
ports:
- "5672:5672"
- "15672:15672"
networks:
- airline

mysql:
    hostname: mysql
image: mysql:5.7.21
ports:
- "3306:3306"
environment:
- MYSQL_ROOT_PASSWORD=root
      - MYSQL_DATABASE=zipkin
networks:
- airline

mongo:
    hostname: mongo
image: mongo
ports:
- "27017:27017"
networks:
- airline  

redis:
    hostname: redis
image: redis:3.2-alpine
ports:
- "6379:6379"
networks:
- airline

networks:
  airline:
    driver: bridge

这里没有什么特别的。我们已经声明了两个容器——RabbitMQ 和 MySQL——并暴露了主机上的端口。此外，我们还创建了 airline 网络；我们将使用这个网络来附加我们的基础设施微服务。

现在，我们可以创建我们的 Zipkin 服务器，我们将在下一节中进行。

我们将在 Spring Initializr 中创建我们的 Zipkin 面板 structure，然后我们需要按照说明进行操作：

太棒了——看看 Selected Dependencies部分，所有这些都是必需的。注意 Spring Boot 版本。我们选择 1.5.9，因为 Spring Boot 2 中不支持 Zipkin 服务器。这不是问题，因为我们不需要 Spring Boot 2 的特定功能。

点击 Generate Project按钮并等待下载完成。之后，在 IDE 中打开项目。

为了启用服务发现并将 Spans 存储在数据库中，我们需要将以下依赖项放入我们的 pom.xml 中：

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

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

<dependency>
 <groupId>mysql</groupId>
 <artifactId>mysql-connector-java</artifactId>
 <version>6.0.6</version>
</dependency>

第一个依赖项用于服务发现客户端，其他依赖项用于与 MySQL 的 JDBC 连接。它使我们的项目依赖项完全配置。 

让我们创建我们的 main 类来启动我们的 Zipkin 服务器。该类非常标准，但带有一些新注释：

package springfive.airline;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.sleuth.zipkin.stream.EnableZipkinStreamServer;

@SpringBootApplication
@EnableZipkinStreamServer
@EnableEurekaClient
public class ZipkinServerApplication {

public static void main(String[] args) {
  SpringApplication.run(ZipkinServerApplication.class, args);
}

}

@EnableEurekaClient 注解使应用程序能够连接到 Eureka 服务器。新注解@EnableZipkinStreamServer 指示框架与配置的代理连接以接收 Spans。请记住，它可以使用 Spring Cloud Stream Binder 来完成。

在本节中，我们创建了 main 类。在我们运行它之前，我们应该创建我们的两个配置文件。 bootstrap.yaml 在 src/main/resources 目录和 application.yaml< /code> 在我们的 GitHub 存储库中。它们将通过 Config Server 下载并由 Zipkin server 项目。

让我们从 bootstrap.yaml 开始：

spring:
  application:
    name: zipkin
cloud:
    config:
      uri: http://localhost:5000
label: master

没什么特别的，我们已经配置了我们的 Config Server 地址。

让我们跳到我们的 application.yaml：

server:
  port: 9999

spring:
  rabbitmq:
    port: 5672
    host: localhost
  datasource:
    schema: classpath:/mysql.sql
    url: jdbc:mysql://${MYSQL_HOST:localhost}/zipkin?autoReconnect=true
    driver-class-name: com.mysql.cj.jdbc.Driver
    username: root
    password: root
    initialize: true
    continue-on-error: true
  sleuth:
    enabled: false

zipkin:
  storage:
    type: mysql

logging:
  level:
    ROOT: INFO

eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/

这里有一些有趣的事情。在 spring.rabbitmq 节点中，我们已经配置了我们的 RabbitMQ 代理连接。它将用于接收 Spans。在 spring.datasource 中，我们已经配置了 MySQL 连接。 Zipkin 服务器将使用它来存储数据。此外，我们还配置了如何执行 DDL 脚本来创建 zipkin 数据库。

spring.sleuth 节点被配置为不产生任何 Span 因为它是服务器，而不是客户端应用程序，我们将不在 Zipkin 服务器上执行跟踪。

zipkin 节点已用于配置 Zipkin 服务器存储类型 MySQL，在我们的例子中。

让我们运行它！

我们已经正确配置了 Zipkin 服务器，所以现在我们可以正常运行它了。

我们可以运行主类 ZipkinServerApplication。运行以下输出后，我们可以使用 IDE 或 Java 命令行：

干得好——Zipkin 服务器现在正在运行。我们可以看一下索引页面，看看它长什么样。 

转到 Zipkin 页面； 该页面应类似于以下屏幕截图：

此外，我们可以检查 RabbitMQ 面板以找到 Zipkin 服务器创建的队列。转到 RabbitMQ 队列 (http://localhost:15672/#/queues) 部分，页面应如下所示：

查看队列，项目创建了 sleuth.sleuth 队列，做得很好。

Zipkin 服务器已准备就绪。目前，我们没有任何 Span，因为没有应用程序向 Zipkin 发送数据。我们将在下一章中这样做。

我们将使用 Spring Initializr 创建我们的 Spring Cloud Gateway 项目；我们需要手动添加一些依赖项。让我们进入 Spring Initializr页面并创建我们的项目：

有一个全新的依赖网关，它使我们能够使用 Spring Cloud Gateway。然后点击Generate Project 等待下载完成。

之后，我们需要添加一个 missing 依赖。网关需要缺少的依赖才能与 Eureka 服务器交互；依赖的名字是 spring-cloud-starter-netflix-eureka-client。然后，让我们添加对 pom.xml 的依赖，我们需要添加以下代码段：

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

太好了，我们的项目配置正确，可以与 Eureka 服务器一起使用。在下一节中，我们将配置项目以与 Config Server 一起使用。

这部分没有秘密。 Spring Cloud Gateway 的工作方式与常见的 Spring Boot 应用程序相同。有一个 main 类将 start 嵌入式服务器并启动 整个应用程序。

我们的 main 类应该是这样的：

package springfive.airline.gateway;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

@EnableEurekaClient
@SpringBootApplication
public class GatewayApplication {

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

}

正如我们所见，它是一个非常标准的 Spring Boot 应用程序，配置了 @EnableEurekaClient 以与 Eureka 服务器一起作为服务发现实现。

主项目 structure 已准备就绪。我们将在本节中创建项目配置。为此，我们需要执行以下步骤：

我们使用的是 Spring Cloud Config Server，因此需要在 GitHub 中创建新文件，因为 Config Server 会尝试在存储库中查找文件。在我们的例子中，我们使用 GitHub 作为存储库。

第二个任务是必要的，因为 bootstrap.yaml 文件是在应用程序完全准备好运行之前处理的。然后，在这个阶段，应用程序需要查找配置文件，为了实现这一点，应用程序需要知道 repository，在我们的例子中是 Config Server。记住 Config Server 的地址总是需要放在 bootstrap.yaml 上。

让我们创建我们的 gateway.yaml 文件——该文件应如下所示：

server:
  port: 8888
eureka:
  client:
    serviceUrl:
defaultZone: http://localhost:8761/eureka/
logging:
  level: debug

YAML 文件中的 eureka.client 节点负责配置 Eureka Client 的配置。我们需要配置我们的 Eureka 服务器地址实例。它应该指向正确的地址。

然后，我们需要在 Gateway 项目中创建 bootstrap.yaml 文件。该文件将指示 Spring Framework 在 Config Server 上查找配置文件，然后下载所需文件以完成应用程序引导。我们的文件应该是这样的：

spring:
  application:
      name: gateway
cloud:
    config:
      uri: http://localhost:5000
label: master

很简单。 application.name 是指示框架查找正确文件所必需的。通常，对于不同的应用程序和环境，也有许多配置文件。 

在 cloud.config 节点上，我们需要输入我们在前面部分中配置的 Spring Cloud Config Server 地址。

项目最终结构应如下所示：

看截图。类路径中没有 application.yaml。这给了我们几个优势；类路径项目中没有配置文件，这对我们管理微服务配置有很大帮助。

在下一节中，我们将运行它并解释整个应用程序引导过程。我们开始做吧。

项目已经配置好，现在是time运行它了。 我们可以使用Java命令行或者IDE。两种方式都没有区别。 

Config Server 和 Eureka Server 需要熬夜；网关项目必须正常工作。然后，我们就可以运行项目了。

运行项目并查看日志。我们可以看到一些有趣的东西，比如项目连接到 Config Server 并下载配置，然后它连接到 Eureka 服务器并自行注册。下图解释了应用程序引导流程：

让我们看看不同的流程是什么并理解它们：

太棒了，我们的网关应用程序连接到我们的基础设施服务。

我们的网关正在运行。现在，我们可以查看 Eureka 服务器页面来确认这些信息。

转到 http://localhost:8761/， 查看 当前在Eureka注册的实例 部分。我们应该看到网关应用程序，如以下屏幕截图所示：

出色的。它运作良好。网关应用注册成功，可以通过服务发现查找。我们的网关将连接到 Eureka 服务器以获取可用服务并将请求的调用分发到正确的服务。

做得好。现在，我们可以在网关中创建路由。我们将在下一章创建航空公司微服务时执行此操作。

我们的网关正在运行。在我们为我们的 Airline 应用程序开始真正的 routes 之前，让我们尝试使用一些假的 routes<一个 id="id326644720" class="indexterm"> 来测试 Spring Cloud Gateway 的行为。我们将使用 https://httpbin.org/ 站点，它可以帮助我们测试一些路线。

让我们创建一个带有@Configuration注解的类来提供routes 用于 Spring 容器。让我们创建一个名为 springfive.airline.gateway.infra.route的包，然后创建以下类：

package springfive.airline.gateway.infra.route;


import java.util.function.Function;
import org.springframework.cloud.gateway.route.RouteLocator;
import org.springframework.cloud.gateway.route.builder.PredicateSpec;
import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder;
import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder.Builder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class SampleRoute {

private Function<PredicateSpec, Builder> addCustomHeader = predicateSpec -> predicateSpec
      .path("/headers")
      .addRequestHeader("Book", "Spring 5.0 By Example")
      .uri("http://httpbin.org:80");

@Bean
public RouteLocator sample(RouteLocatorBuilder builder) {
return builder.routes()
        .route("custom-request-header", addCustomHeader)
        .route("add-query-param", r -> r.path("/get").addRequestParameter("book", "spring5.0")
            .uri("http://httpbin.org:80"))
        .route("response-headers", (r) -> r.path("/response-headers")
            .addResponseHeader("book","spring5.0")
            .uri("http://httpbin.org:80"))
        .route("combine-and-change", (r) -> r.path("/anything").and().header("access-key","AAA")
            .addResponseHeader("access-key","BBB")
            .uri("http://httpbin.org:80"))
        .build();
}

}

configure 路由有几种不同的类型；我们提取的第一个是名为 addCustomHeader, 的私有属性的函数，它将在custom-request-header<中使用/代码>路线。我们将使用 curl 来测试之前创建的一些路由。

我们将测试的第一个是 custom-request-header， route 被配置为路由到： http://httpbin.org:80 和路径将是 /headers。此服务将返回发送到服务器的请求标头。看一下addCustomHeader，我们已经将它配置为向请求添加自定义标头。它将以 Book 作为关键和 Spring 5.0 By Example， 作为值。让我们使用 curl 调用网关 URL：

curl http://localhost:8888/headers

输出应如下所示：

让我们分析一下输出。首先要看的是我们调用了 localhost 地址。 Request中的Host键显示 httpbin.org，表示Spring Cloud Gateway已经改变了地址。太棒了，但我们期待它。第二个是我们添加 Book 键的地方，宾果游戏，它在请求标头中。网关按预期工作，通过几行代码，我们做了一些有趣的事情。

让我们再做一个测试。我们将测试 combine-and-change，这个路由被配置为用Request /anything =“文字”>标题访问键：AAA ，因此命令行应为：

curl -v -H "access-key: AAA" http://localhost:8888/anything

正如我们所见，-v 参数 使 调用详细模式，它对于 debugging 目的很有用，并且 -H 表示请求标头。让我们看看输出：

惊人的。如果您查看 access-key 值，网关更改为请求值 BBB。干得好伙计们。有一些端点要测试，感觉 free 可以根据需要进行测试。