在本文中将使用Spring Cloud编程分布式应用程序 - 出租车管理应用程序 。 在上一篇文章中,演示了如何创建Config-Server应用程序,该应用程序管理其他服务的配置信息。
参见上一篇文章:
在本示例中,我们将创建一个“About Company”应用程序。 它独立于“乘客管理”和“司机管理”应用程序。 对于一家大型出租车公司,例如:Uber,访问其网站的用户数量巨大,最好有一个应用程序将该公司与其他功能分开引入。
“About Company”应用程序将使用独立的数据库。 将在Config-Server上管理数据库配置信息。 在微服务架构中,该应用程序不仅仅是公司介绍网站,它可以是为其他应用程序提供信息的服务,例如,提供热线信息,反馈电子邮件等。简而言之,它是微服务系统的一部分。
注意:本节内容的主要目的是讨论和实践“应用程序如何在Config-Server上管理其配置信息”的示例。
1. 创建Spring Boot项目
首先打开Eclipse,点击:File -> Project -> Others -> Spring Starter Project,并填写相关信息。如下所示 -
选择相应功能,如下所示 -
项目创建完成 -
JDBC Driver (MySQL, PostGres,..)依赖配置(自动生成)内容如下 -
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>org.postgresql</groupId>
<artifactId>postgresql</artifactId>
<scope>runtime</scope>
</dependency>
<!-- SQL Server - Mssql-Jdbc driver -->
<dependency>
<groupId>com.microsoft.sqlserver</groupId>
<artifactId>mssql-jdbc</artifactId>
<scope>runtime</scope>
</dependency>
<!-- Oracle Driver -->
<dependency>
<groupId>com.oracle</groupId>
<artifactId>ojdbc6</artifactId>
<version>11.2.0.3</version>
</dependency>
文件:pom.xml 的内容如下 -
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.1.1.RELEASE</version>
<relativePath /> <!-- lookup parent from repository -->
</parent>
<groupId>com.yiibai</groupId>
<artifactId>ConfigClientAboutCompany</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>ConfigClientAboutCompany</name>
<description>ConfigClientAboutCompany project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
<spring-cloud.version>Greenwich.RC2</spring-cloud.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-config</artifactId>
</dependency>
<dependency>
<groupId>com.microsoft.sqlserver</groupId>
<artifactId>mssql-jdbc</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>org.postgresql</groupId>
<artifactId>postgresql</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>${spring-cloud.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
<repositories>
<repository>
<id>spring-milestones</id>
<name>Spring Milestones</name>
<url>https://repo.spring.io/milestone</url>
</repository>
</repositories>
</project>
文件:ConfigClientAboutCompanyApplication.java 的内容如下 -
package com.yiibai.aboutcompany;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class ConfigClientAboutCompanyApplication {
public static void main(String[] args) {
SpringApplication.run(ConfigClientAboutCompanyApplication.class, args);
}
}
2. 配置Spring Cloud Config客户端
该应用程序需要读取存储在Config-Server上的配置; 因此,需要告诉它有关Config-Server的信息。 此信息在bootstrap.properties(或bootstrap.yml)文件上配置。 在应用程序启动期间,应用程序就会使用此文件。
接下来添加两个配置文件 -
文件:bootstrap.properties -
# Read file on Config-Server:
# app-about-company.properties or app-about-company.yml
spring.application.name=app-about-company
# This is the default:
spring.cloud.config.uri=http://localhost:8888
management.security.enabled=false
配置以便此应用程序在端口8877
上运行,如下所示 -
文件:application.properties -
server.port=7788
此应用程序的配置文件(请参阅GitHub):
浏览此文件,内容如下 -
3. 创建控制器
首先创建一个名:com.yiibai.aboutcompany.controller,并在这个包下创建一个控制器:MainController.java,如下所示 -
MainController.java 的代码如下所示 -
package com.yiibai.aboutcompany.controller;
import javax.sql.DataSource;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.context.ApplicationContext;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
@RefreshScope
@RestController
public class MainController {
//
@Value("${text.copyright: Default Copyright}")
private String copyright;
@Value("${spring.datasource.driver-class-name}")
private String driverClassName;
@Value("${spring.datasource.url}")
private String url;
@Value("${spring.datasource.username}")
private String userName;
@Value("${spring.datasource.password}")
private String password;
@Autowired
private DataSource dataSource;
@Autowired
ApplicationContext applicationContext;
@RequestMapping("/showConfig")
@ResponseBody
public String showConfig() {
String configInfo = "Copy Right: " + copyright //
+ "<br/>spring.datasource.driver-class-name=" + driverClassName //
+ "<br/>spring.datasource.url=" + url //
+ "<br/>spring.datasource.username=" + userName //
+ "<br/>spring.datasource.password=" + password;
return configInfo;
}
@RequestMapping("/pingDataSource")
@ResponseBody
public String pingDataSource() {
try {
// 获取配置的数据源
return this.dataSource.toString();
} catch (Exception e) {
e.printStackTrace();
return "Error: " + e.getMessage();
}
}
}
@RefreshScope 说明 -
任何由@RefreshScope
注释的Spring Bean都将在运行时刷新,任何使用它们的组件都将在下一个方法调用中获得一个新实例,完全初始化并注入所有依赖项。
4. 运行应用程序
首先,需要运行Config-Server应用程序(上一篇教程中创建)。 此应用程序将在端口8888上运行。
在浏览器中打开以下URL测试它:
之后,运行ConfigClientAboutCompany 应用程序,该应用程序将在端口7788
上运行:
使用以下URL测试它: