Java基于classpath读取文件、分布式项目使用版本号

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.txt

image.png

image.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);
            }
        }