1，使用classpath读取资源文件
1）文件在/src/properties/api_version.txt下，当build以及war之后，会放入classpath下。
image.png
classpath是指向jar包的位置。也就是JDK的lib目录
java.library.path是非java类包的位置如（dll,so）
2）如果通过项目的相对路径寻找文件，当脱离IDE环境之后，就无法找到文件。
如src/properties/api_version.txtimage.pngimage.png
3）基于classpath，使用Class.getResource或者ClassLoader.getResource读取文件。
image.png
ClassLoader的getResource方法。
image.png
4）如果name 是以 "/" 开头，则会从classpath根下寻找。
如果非"/" 开头，会添加prefix至根路径，因为classloader.getResource(String name)是从classpath根开始查找。add a package name prefix
image.png
name = resolveName(name);//构造成从根路径开始的path
cl.getResource(name);//调用classLoader的getResource方法。
2，分布式项目使用版本号来检测
1）当使用负载均衡和nginx的upstream功能时，会有多个tomcat实例。但是每个项目的版本是否同步？
2）使用gradle或者其他工具打war包的时候，将版本号写入war包中需要注意task的顺序。image.png
eg:Gradle war
//XXXX war.dependsOn writeVersionTask
processResources.dependsOn writeVersionTask// 不能使用war.dependsOn，会先执行processResources，再执行writeVersionTask。
task writeVersionTask(){
doFirst{
println '开始写入版本号到文件'
}
doLast{
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd_HH:mm:ss")
def now = new Date()
def path = "./src/properties/api_version.txt"
String versionStr = "V_" + sdf.format(now)
File versionFile = new File(path)
versionFile.withOutputStream{ os ->
os << versionStr
println '写入版本号到文件成功\t' + path
}
}
}
2）项目中提供访问版本号的接口
@Controller
public class ApiVersionController {
private static final Logger logger = LoggerFactory.getLogger(ApiVersionController.class);
@RequestMapping(value = "/api/version")
@ResponseBody
public String getApiVersion(HttpServletRequest request){
String versionName = "/properties/api_version.txt";
String fileClasspath = ApiVersionController.class.getResource(versionName).getFile();
String result;
File versionFile = new File(fileClasspath);
try {
result = FileUtils.readFileToString(versionFile);
} catch (Throwable t){
logger.info(t.getMessage(), t);
result = t.getMessage();
}
return result;
}
}
3）使用nginx的upstream_check_module，来获取所有upstream的状态，返回html页面
upstream backend_server{
server 172.17.2.14:8080 weight=1;
server 172.17.2.15:8080 weight=1;
server 172.17.2.16:8080 weight=1;
keepalive 32;
check interval=3000 rise=2 fall=3 timeout=1000 type=http;
check_http_send "HEAD / HTTP/1.0\r\n\r\n";
check_http_expect_alive http_2xx;
}
location /nstatus {
check_status;
}
4）使用jsoup解析html页面获取所有的ip:port列表
@org.junit.Test
public void testJsoup() throws Exception {
List<String> ipAndPorts = Lists.newArrayList();
File file = new File("/Users/hzq/status.html");
Document doc = Jsoup.parse(file, "utf-8");//jsoup可以直接解析网页
//Document doc = Jsoup.connect("http://172.17.1.1/upstream/status").get();
Elements tables = doc.getElementsByTag("table");
for (Element table : tables) {
Elements trs = table.getElementsByTag("tr");
for(Element tr : trs){
Elements tds = tr.getElementsByTag("td");
for(int i = 0; i < tds.size(); i++){
Element td = tds.get(i);
if(td.text().equalsIgnoreCase("backend_server")){
if((i + 1) < tds.size()){
ipAndPorts.add(tds.get(i + 1).text());
}
}
}
}
}
for(String s : ipAndPorts){
System.out.println(s);
}
}
5）通过拿到的ipAndPorts，遍历获取所有tomcat中war实例的版本号。
for(String ipAndPort : ipAndPorts){
try {
String version = Jsoup.connect(ipAndPort + path).data(map).ignoreContentType(true).post().text();
resultMap.put(ipAndPort, version);
} catch (Throwable t){
resultMap.put(ipAndPort, t.getMessage());
logger.info(t.getMessage(), t);
}
}
