Apollo在Java中的使用

   本节主要讲解在普通的 Java 项目和 Spring Boot 中如何使用 Apollo。

 普通 Java 项目中使用
加入 Apollo Client 的 Maven 依赖,代码如下所示。

<dependency><groupId>com.ctrip.framework.apollo</groupId><artifactId>apollo-client</artifactId><version>1.1.0</version>
</dependency>

使用 API 的方式来获取配置,具体代码如下所示。

public class App {public static void main(String[] args) {Config config = ConfigService.getAppConfig();String key = "username";String defaultValue = "张三";String username = config.getProperty(key, defaultValue);System.out.println("username=" + username);}
}

通过 ConfigService 得到 Config 对象,config.getProperty() 方法可以传入你想获取的配置 Key,defaultValue 是当配置中心找不到配置的时候返回的默认值,避免空指针异常。

运行上面这段代码,输出的结果是默认值“张三”。因为我们还没有指定 Apollo 需要的一些必要信息,这些信息包括 Meta Server、AppId 和 Environment。Cluster 可以不用指定,用默认即可。

1.Meta Server 配置
Apollo 支持应用在不同的环境中有不同的配置,所以需要运行提供给 Apollo 客户端当前环境的 Apollo Meta Server 信息。
在默认情况下,meta server 和 config service 是部署在同一个 JVM 进程里的,所以 meta server 的地址就是 config service 的地址。

目前我们用的快速启动包只有一个 DEV 环境,config service 的地址是 http://localhost:8080,这个已经在启动脚本 demo.sh 中定义好了。

为了能够让示例代码在各位读者的电脑上也能直接运行,我们将配置定在 classpath:/META-INF/app.properties 中。内容为 apollo.meta=http://localhost:8080。

2.APPid 配置
APPid 是应用的身份信息,是从服务端获取配置的一个重要信息。同样 APPid 的配置方式也有多种,我们采用跟 Meta Server 一样的方式,配置在 classpath:/META-INF/app.properties 中。内容为 app.id=SampleApp。
SampleApp 在 Portal 的项目主页面中有展示,如果是你自己新建的项目,那么就是你自定义的 AppId。

3.Environment 配置
Environment 跟项目本身没有关系,一个项目可以部署在不同的环境中,代码不需要改变,需要变化的只是配置值而已。所以 Environment 的配置不能配置在项目中,最常用的有如下两种配置方式。
1)通过 Java System Property
可以通过 Java 的 System Property env 来指定环境。
在 Java 程序启动脚本中,可以指定 -Denv=YOUR-ENVIRONMENT。
如果是运行 jar 文件,需要注意格式为 java-Denv=YOUR-ENVIRONMENT-jar xxx.jar。
注意 key 为全小写。
2)通过配置文件
最后一个推荐的方式是通过配置文件来指定 env=YOUR-ENVIRONMENT。
对于 Mac/Linux,文件位置为 /opt/settings/server.properties。
对于 Windows,文件位置为 C:\opt\settings\server.properties。

server.properties 内容为 env=DEV。

同样的,为了能够让示例代码能够更方便地在各位读者的电脑上运行,我们就用 ava System Property 的方式来指定 Environment,要么在 IDE 的启动参数中指定,要么就在 main 方法的第一行通过代码指定(仅供开发演示用,不能用于生产环境)。具体代码所示。
 

public static void main(String[] args) {System.setProperty("env", "DEV");// ....
}

所有配置完成之后,我们再次运行前面的示例代码,可以看到输出的内容就是我们自己配置的值。4.监听配置变化事件
在某些场景下,当配置发生变化的时候,我们需要进行一些特殊的处理。比如,数据库连接串变化后需要重建连接等,就可以使用 API 提供的监听机制。具体代码如下所示。

config.addChangeListener(new ConfigChangeListener() {public void onChange(ConfigChangeEvent changeEvent) {System.out.println("发生修改数据的命名空间是:" + changeEvent.getNamespace());for (String key : changeEvent.changedKeys()) {ConfigChange change = changeEvent.getChange(key);System.out.println(String.format("发现修改 - 配置key: %s, 原来的值: %s, 修改后的值: %s, 操作类型: %s", change.getPropertyName(),change.getOldValue(), change.getNewValue(), change.getChangeType()));}}
});

当我们在 Portal 中进行修改配置时,就会触发监听事件,输出结果为:

发生修改数据的命名空间是:application
发现修改 - 配置key: username, 原来的值: zhangsan, 修改后的值: zhangsan1, 操作类型: MODIFIED

 Spring Boot 中使用
首先准备一个 Spring Boot 项目,加入 Apollo Client 的 Maven 依赖,具体代码如下所示:

<dependency><groupId>com.ctrip.framework.apollo</groupId><artifactId>apollo-client</artifactId><version>1.1.0</version>
</dependency>

 然后配置 Apollo 的信息,配置放在 application.properties 中:

app.id=SampleApp
apollo.meta=http://localhost:8080
apollo.bootstrap.enabled=true
apollo.bootstrap.namespaces=application

其中,

app.id:身份信息。
apollo.meta:Meta Server(Config Service)。
apollo.bootstrap.enabled:项目启动的 bootstrap 阶段,向 Spring 容器注入配置信息。
apollo.bootstrap.namespaces:注入命名空间。
环境同样在 main 方法中指定,代码如下所示。
 

@SpringBootApplication
public class App {public static void main(String[] args) {// 指定环境(仅供开发演示用, 不能用于生产环境))System.setProperty("env", "DEV");SpringApplication.run(App.class, args);}
}
  1. Placeholder 注入配置
    Placeholder 注入配置代码如下所示。
    /**
    * 用户名, 默认值为zhangsan
    */
    @Value("${username:zhangsan}")
    private String username;
    

  2. Java Config 使用方式
    Java Config 使用方式具体代码如下所示。
@Data
@Configuration
public class UserConfig {@Value("${username:zhangsan}")private String username;
}

 使用 Config 配置类注入具体代码如下所示:

@Autowired
private UserConfig userConfig;

3.ConfigurationProperties 使用方式
ConfigurationProperties 的使用方法具体代码如下所示。

@Data
@Configuration
@ConfigurationProperties(prefix = "redis.cache")
public class RedisConfig {private String host;
}

配置中心只需要增加 redis.cache.host 配置项即可实现注入,配置内容如下:

redis.cache.host = 192.168.1.1

ConfigurationProperties 方式有个缺点,当配置的值发生变化时不会自动刷新,而是需要手动实现刷新逻辑,笔者建议大家不要使用这种方式,比较繁琐。

如果有配置需要加统一前缀的方式可以用 Java Config 的方式代替。

4.Spring Annotation 支持
1)@ApolloConfig
用来自动注入 Apollo Config 对象,代码如下所示。
 

@ApolloConfig
private Config config;
@GetMapping("/config/getUserName3")
public String getUserName3() {return config.getProperty("username", "zhangsan");
}

2)@ApolloConfigChangeListener
用来自动注册 ConfigChangeListener,代码如下所示。

@ApolloConfigChangeListener
private void someOnChange(ConfigChangeEvent changeEvent) {if(changeEvent.isChanged("username")) {System.out.println("username发生修改了");}
}

3)@ApolloJsonValue
用来把配置的 JSON 字符串自动注入为对象。

定义一个实体类,代码如下所示。

@Data
public class Student {private int id;private String name;
}

对象注入,代码如下所示。

@ApolloJsonValue("${stus:[]}")
private List<Student> stus;

后台增加配置内容如下:

stus = [{"id":1,"name":"jason"}]

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/69063.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

kali 安装cpolar内网穿透实现 ssh 远程连接

文章目录 1. 启动kali ssh 服务2. kali 安装cpolar 内网穿透3. 配置kali ssh公网地址4. 远程连接5. 固定连接SSH公网地址6. SSH固定地址连接测试 简单几步通过cpolar 内网穿透软件实现ssh 远程连接kali! 1. 启动kali ssh 服务 默认新安装的kali系统会关闭ssh 连接服务,我们通…

【3】单着色器文件读取

Basic.shader文件&#xff0c;可以发现顶点着色器和片段着色器是写在一个文件里的&#xff0c;这里我们将他们读取出来&#xff0c;而不是上一篇使用string的方式。 #shader vertex #version 330 corelayout(location 0) in vec4 position;void main() {gl_Position positio…

TTransportException SASL authentication not complete

今天遇见了一个异常&#xff0c;但是发现是自己智障了 但还是记录一下 在close的时候先close了conn再close的statement导致报的这个错

概念解析 | 无线智能空口:打造下一代无线通讯网络的关键技术

注1:本文系“概念解析”系列之一,致力于简洁清晰地解释、辨析复杂而专业的概念。本次辨析的概念是:无线智能空口。 无线智能空口:打造下一代无线通讯网络的关键技术 前序 “空口"是无线通信中的一个专业术语,它主要用于描述无线通信设备与设备之间的通信接口。我们可…

Level-based Foraging 多智能体游戏仿真环境

游戏场景测试 参考链接&#xff1a; https://kgithub.com/semitable/lb-foraging

CNN详细讲解

CNN(Convolutional Neural Network) 本文主要来讲解卷积神经网络。所讲解的思路借鉴的是李宏毅老师的课程。 CNN&#xff0c;它是专门被用在影像上的。 Image Classification 我们从影像分类开始说起。 我们举例来说&#xff0c;它固定的输入大小是100*100的解析度&#x…

FastAPI 参数的作用

FastAPI是一个现代化的Python web框架&#xff0c;其参数具有重要的作用。在FastAPI中&#xff0c;参数被用于接收HTTP请求中的数据及其它相关信息。 FastAPI支持的参数类型包括&#xff1a; 查询参数&#xff08;query parameters&#xff09; 查询参数是指将参数附加到URL末…

《Python魔法大冒险》007 被困的精灵:数据类型的解救

小鱼和魔法师深入魔法森林&#xff0c;树木之间流淌着神秘的光芒&#xff0c;每一片叶子都似乎在低语着古老的咒语。不久&#xff0c;他们来到了一个小湖旁&#xff0c;湖中央有一个小岛&#xff0c;岛上困着一个透明的泡泡&#xff0c;里面有一个悲伤的精灵。 小鱼看着那个精…

软件行业25年技术发展史

语言时代 -> 框架时代 -> 分布式架构时代 -> 微服务架构时代 25年开发、管理&#xff0c;11年教培&#xff08;教研总监&#xff09;技术总结&#xff1a; 1997年 VB 1999年 ASPCOM 2004年 C# / JAVA、j2ee、ejb、struts1hibernate 2008年 旧三大框架 Struts2Spr…

MySQL 是如何实现事务的四大特性的?

分析&回答 如果你不知道事务更不知道四大特性请先看看&#xff1a;说说什么是事务 原子性 语句要么都执行&#xff0c;要么都不执行&#xff0c;是事务最核心的特性&#xff0c;事务本身来说就是以原子性来定义的&#xff0c;实现主要是基于undo log undo log&#xff…

探索ClickHouse——安装和测试

我们在Ubuntu 20 Server版虚拟机上对ClickHouse进行探索。 安装 检测环境 grep -q sse4_2 /proc/cpuinfo && echo "SSE 4.2 supported" || echo "SSE 4.2 not supported"SSE 4.2 supported 可以看到我们的环境支持编译版本的。如果不支持的环境…

MyBatisPlus之DQL编程控制

&#x1f40c;个人主页&#xff1a; &#x1f40c; 叶落闲庭 &#x1f4a8;我的专栏&#xff1a;&#x1f4a8; c语言 数据结构 javaEE 操作系统 石可破也&#xff0c;而不可夺坚&#xff1b;丹可磨也&#xff0c;而不可夺赤。 MyBatisPlus之DQL编程控制 一、 条件查询方式&…

zabbix安装部署

前期准备&#xff1a;安装mysql数据库和nginx 一、下载zabbix rpm -Uvh https://repo.zabbix.com/zabbix/4.4/rhel/7/x86_64/zabbix-release-4.4-1.el7.noarch.rpm yum-config-manager --enable rhel-7-server-optional-rpms yum install epel-release numactl yum install…

【LeetCode-面试经典150题-day21】

目录 120.三角形最小路径和 64.最小路径和 63.不同路径Ⅱ 5.最长回文子串 120.三角形最小路径和 题意&#xff1a; 给定一个三角形 triangle &#xff0c;找出自顶向下的最小路径和。 每一步只能移动到下一行中相邻的结点上。相邻的结点 在这里指的是 下标 与 上一层结点下标…

JS 实现同时往数组多个位置插入值和删除值

1 start下标实现往固定地方插入数据 const aa [1, 2, 3, 4, 5, 6]; let bb [{ start: 5, list: [b1, b2, b3] },{ start: 0, list: [a1, a2] },{ start: 1, list: [c1, c2] },{ start: 1, list: [c11, c22] },{ start: 2, list: [d1, d2] },{ start: 3, deleteCount: 1 }, …

Python项目打包与部署(一):模块与包的概念与关系

当前各类Python教程鲜有涉及Python打包与部署技术&#xff0c;或者讲述过于表面化、片面化。 本人尝试从原理开始&#xff0c;结合实例&#xff0c;并给出标准操作步骤建议&#xff0c;为python编程爱好者提供一份较为详实的Python项目打包与部署参考教程。 本教程其它章节 Pyt…

SQL-存储过程、流程控制、游标

存储过程 存储过程概述 1.产生背景 开发过程总&#xff0c;经常会遇到重复使用某一功能的情况 2.解决办法 MySQL引人了存储过程(Stored Procedure)这一技术 3.存储过程 存储过程就是一条或多条SQL语句的集合存储过程可将一系列复杂操作封装成一个代码块&#xff0c;以便…

【【萌新的STM32的学习--非正点原子视频的中断设计思路】】

萌新的STM32学习–非正点原子视频的中断设计思路 我们分析而言 我们对于PA0 的设计就从此而来 对于边沿触发的选择我们已经有所了解了 我们下拉&#xff0c;但是当我们摁下开关的时候 从0到1 导通了 所以这个是下拉 上升沿触发 而对于KEY0 我们摁下是使得电路从原来悬空高阻态…

算法通关村第10关【黄金】| 归并排序

归并排序&#xff08;Merge Sort&#xff09;是一种常见的基于比较的排序算法&#xff0c;它的主要思想是分而治之&#xff08;Divide and Conquer&#xff09;。它的核心思想是将一个大的问题分解为小的子问题&#xff0c;解决子问题&#xff0c;然后将它们合并&#xff08;me…

开启EMQX的SSL模式及SSL证书生成流程

生成证书 首先&#xff1a;需要安装Openssl 以下是openssl命令 生成CA证书 1.openssl genrsa -out rootCA.key 2048 2.openssl req -x509 -new -nodes -key rootCA.key -sha256 -days 3650 -subj "/CCN/STShandong/Ljinan/Oyunding/OUplatform/CNrootCA" -out ro…