SpringBoot2.0整合携程Apollo配置中心

Apollo服务端共需要两个数据库：ApolloPortalDB和ApolloConfigDB，官网把数据库、表的创建和样例数据都分别准备了sql文件（在下载的 Quick Start 安装包的sql目录下），只需要导入数据库即可。

通过各种Mysql客户端（Navicat,DataGrip等）导入sql/apolloportaldb.sql即可
下面以MySQL原生客户端为例：

source /your_local_path/sql/apolloportaldb.sql

导入成功后，可以通过执行以下sql语句来验证：

select `Id`, `AppId`, `Name` from ApolloPortalDB.App;

通过各种Mysql客户端（Navicat,DataGrip等）导入sql/apolloconfigdb.sql即可
下面以MySQL原生客户端为例：

source /your_local_path/sql/apolloconfigdb.sql

导入成功后，可以通过执行以下sql语句来验证：

select `NamespaceId`, `Key`, `Value`, `Comment` from ApolloConfigDB.Item;

Apollo服务端需要知道如何连接到你前面创建的数据库，所以需要编辑demo.sh，修改ApolloPortalDB和ApolloConfigDB相关的数据库连接串信息。

#apollo config db info
apollo_config_db_url=jdbc:mysql://localhost:3306/ApolloConfigDB?characterEncoding=utf8
apollo_config_db_username=用户名
apollo_config_db_password=密码（如果没有密码，留空即可）

# apollo portal db info
apollo_portal_db_url=jdbc:mysql://localhost:3306/ApolloPortalDB?characterEncoding=utf8
apollo_portal_db_username=用户名
apollo_portal_db_password=密码（如果没有密码，留空即可）

Quick Start脚本会在本地启动3个服务，分别使用8070, 8080, 8090端口，请确保这3个端口当前没有被使用。例如，在Linux/Mac下，可以通过如下命令检查：

lsof -i:8080

在windows下，可以通过如下命令检查：

netstat -aon|findstr "8080"

在Quick Start目录下执行如下命令：

./demo.sh start

当看到如下输出后，就说明启动成功了！

==== starting service ====
Service logging file is ./service/apollo-service.log
Started [10768]
Waiting for config service startup.......
Config service started. You may visit http://localhost:8080 for service status now!
Waiting for admin service startup....
Admin service started
==== starting portal ====
Portal logging file is ./portal/apollo-portal.log
Started [10846]
Waiting for portal startup......
Portal started. You can visit http://localhost:8070 now!

如果启动遇到了异常，可以分别查看service和portal目录下的log文件排查问题。

注： 在启动apollo-configservice的过程中会在日志中输出eureka注册失败的信息，如com.sun.jersey.api.client.ClientHandlerException: java.net.ConnectException: Connection refused。需要注意的是，这个是预期的情况，因为apollo-configservice需要向Meta Server（它自己）注册服务，但是因为在启动过程中，自己还没起来，所以会报这个错。后面会进行重试的动作，所以等自己服务起来后就会注册正常了。

我们的客户端使用apollo需要新增相关的项目配置。

1. 点击新建项目
   

   • 应用ID：这个ID是应用的唯一标识
   • 应用名称：应用的名称，会展示在配置中心的首页上

   点击提交，创建完成
   

2. 新增配置信息
   点击新增配置，填写配置信息点击提交，此时配置还未生效。

3. 发布配置
   点击发布，配置立刻生效
   

4. 回滚
   如果配置做了修改之后，发现配置更改错误，这个时候可以使用回滚功能，回到上一个配置
   

我们客户端基于Spring Boot 2.0搭建，开发工具是InteIIij IDEA。新建一个项目，项目名称为apollo-client

1. 添加Apollo客户端依赖

   
        com.ctrip.framework.apollo
        apollo-client
        1.1.1
   
   

   目前最新版本为1.1.1
2. 添加配置信息

   # 应用ID(在Apollo服务端新增项目添加的应用ID)
   app.id=testclient
   # apollo-configservice地址
   apollo.meta=http://127.0.0.1:8080
   

3. 开启Apollo客户端
   在项目的启动类上添加@EnableApolloConfig注解
4. 新增一个测试接口

  @RequestMapping("/index")
  public String hello(){
    return "hello man";
  }

5. 启动服务测试
   在Apollo配置中心中，我们对该项目有一条配置server.port = 9000,启动服务，访问http://localhost:9000/index，返回hello man。证明，客户端是从服务端获取的配置。

在上一节，我们简单的搭建了客户端，成功的使用服务端配置。Apollo为我们提供的使用方式有很多种，下面只介绍Spring Boot 2.0环境下的使用方式。

Spring应用通常会使用Placeholder来注入配置，使用的格式形如${someKey:someDefaultValue}，如${timeout:100}。冒号前面的是key，冒号后面的是默认值（建议在实际使用时尽量给出默认值，以免由于key没有定义导致运行时错误）。Apollo从v0.10.0开始的版本支持placeholder在运行时自动更新。如果需要关闭placeholder在运行时自动更新功能，可以通过以下两种方式关闭：

1. 通过设置System Property apollo.autoUpdateInjectedSpringProperties，如启动时传入-Dapollo.autoUpdateInjectedSpringProperties=false
2. 通过设置META-INF/app.properties中的apollo.autoUpdateInjectedSpringProperties=false

1. 新建配置类JavaConfigBean如下：

   /**
    * Java Config方式
    *
    * @author simon
    * @create 2018-11-02 15:00
    **/
   @Configuration
   public class JavaConfigBean {
     @Value("${timeout:20}")
     private int timeout;
   
     public int getTimeout() {
       return timeout;
     }
   }
   

2. 新增访问端点

     //1.Java Config方式
     @Autowired
     JavaConfigBean javaConfigBean;
   
     @RequestMapping("/index1")
     public String hello1(){
       return javaConfigBean.getTimeout()+"";
     }
   

3. 测试
   浏览器访问http://127.0.0.1:8080/index1，正确返回配置的值

Spring Boot提供了@ConfigurationProperties把配置注入到bean对象中。Apollo也支持这种方式，下面的例子会把redis.cache.expireSeconds和redis.cache.commandTimeout分别注入到SampleRedisConfig的expireSeconds和commandTimeout字段中。

1. 新增配置类SampleRedisConfig如下：

   /**
    * ConfigurationProperties使用方式
    *
    * @author simon
    * @create 2018-11-02 9:30
    **/
   @Configuration
   @ConfigurationProperties(prefix = "redis.cache")
   public class SampleRedisConfig {
     private int expireSeconds;
     private int commandTimeout;
   
     public void setExpireSeconds(int expireSeconds) {
       this.expireSecOnds= expireSeconds;
     }
   
     public void setCommandTimeout(int commandTimeout) {
       this.commandTimeout = commandTimeout;
     }
   
     public int getExpireSeconds() {
       return expireSeconds;
     }
   
     public int getCommandTimeout() {
       return commandTimeout;
     }
   }
   

2. 新增访问端点

   //2. ConfigurationProperties使用方式
     @Autowired
     SampleRedisConfig sampleRedisConfig;
   
     @RequestMapping("/index2")
     public String hello2(){
       return sampleRedisConfig.getCommandTimeout()+"--"+sampleRedisConfig.getExpireSeconds();
     }
   

3. 测试
   浏览器访问http://127.0.0.1:8080/index2，正确返回配置的值

注： @ConfigurationProperties如果需要在Apollo配置变化时自动更新注入的值，需要配合使用EnvironmentChangeEvent或RefreshScope。这个我会在后续文章中详细描述。

Apollo同时还增加了几个新的Annotation来简化在Spring环境中的使用。

• @ApolloConfig用来自动注入Config对象
• @ApolloConfigChangeListener用来自动注册ConfigChangeListener
• @ApolloJsonValue用来把配置的json字符串自动注入为对象

1. 新增访问端点

   // 3. @ApolloConfig使用
     @ApolloConfig
     private Config config;
   
     @RequestMapping("/index3")
     public String hello3(){
       Set  propertyNames = config.getPropertyNames();
       propertyNames.forEach(key -> {
         System.err.println(key+"="+config.getIntProperty(key,0));
       });
       return propertyNames.toString();
     }
   

2. 测试
   浏览器访问http://127.0.0.1:8080/index3，正确打印配置的值

   redis.cache.commandTimeout=3000
   redis.cache.expireSecOnds=20
   server.port=800
   timeout=200
   

1. 新增以下代码

   @ApolloConfigChangeListener
     private void someOnChange(ConfigChangeEvent changeEvent) {
       //update injected value of batch if it is changed in Apollo
       if (changeEvent.isChanged("timeout")) {
         System.out.println(config.getIntProperty("timeout", 0));
       }
     }
   

2. 测试
   在Apollo服务端修改timeout配置的值为300，发布后，控制台打印300

1. 新增User如下：

   /**
    * 用户
    *
    * @author simon
    * @create 2018-11-02 16:41
    **/
   public class User {
     private String username;
     private String password;
   
     public String getUsername() {
       return username;
     }
   
     public void setUsername(String username) {
       this.username = username;
     }
   
     public String getPassword() {
       return password;
     }
   
     public void setPassword(String password) {
       this.password = password;
     }
   }
   

2. 服务端新增配置
   jsOnBeanProperty=[ { "username": "john", "password": "1234" }, { "username": "simon", "password": "222132" } ]
3. 客户端获取配置

   //4. @ApolloJsonValue使用
   @ApolloJsonValue("${jsonBeanProperty:[]}")
   private List anotherJsonBeans;
   
   @RequestMapping("/index4")
   public void hello4(){
     anotherJsonBeans.forEach(item -> {
       System.err.println(item.getUsername()+"--"+item.getPassword());
     });
   }
   

4. 测试
   浏览器访问http://127.0.0.1:8080/index4，正确打印配置的值