FTP读取文件及防止防火墙自动挂起设置

 1 /**
 2      * ftp取天气网信息，参数为ftp地址、账号、密码
 3      * @param ip
 4      * @param port
 5      * @param user
 6      * @param pswd
 7      * @param path  文件路径
 8      * @return
 9      */
10     public List<JsonWeatherInfo> getHttpXMLByFTP(String ip,int port,String user,String pswd,String path){
11         
12         FTPClient ftpClient = new FTPClient();
13          try {
14            // 连接
15            ftpClient.connect(ip, port) ;
16            // 登录
17            ftpClient.login(user, pswd);
18            if (path != null && path.length() > 0) {
19             // 跳转到指定目录
20             ftpClient.changeWorkingDirectory(path);
21            }
22         }catch (SocketException e) {
23               e.printStackTrace();
24         }catch (IOException e) {
25               e.printStackTrace();
26          }    
27         //设置FTPClient为被动传输模式即可解决线程挂起问题,防火墙问题
28         ftpClient.enterLocalPassiveMode();  
29         
30         logger.info("【连接成功，进行取值】");
31         //根据当前时间，得到需要取的文件名称
32         String dateStr = DateUtil.getFormatDate(DateUtil.getNowDate(),"yyyyMMdd HH:mm:ss");
33         String ymd = dateStr.substring(0, 8);
34         String hhmm = dateStr.substring(9, 15).replace(":", "");
35         int hhmmi = Integer.parseInt(hhmm) ;
36         String zsymd = ymd ;
37         int zshhmmi = hhmmi ;
38         
39         String hzStr = "800" ;
40         if(hhmmi<805){
41             //早上8点5分前，取上一天的
42             ymd =  DateUtil.getLastDay("yyyyMMdd HH:mm:ss").substring(0, 8);
43             hzStr = "2000";
44         }else if (hhmmi<1205){
45             //取早8点的
46             hzStr = "0800";
47         }else if (hhmmi<1715){
48             //取中午12点的
49             hzStr = "1200";
50         }else if(hhmmi <=2400){
51             //取下午17点10后的
52             hzStr = "2000";
53         }
54         
55         String zsf = "07" ;
56         if(zshhmmi<705){
57         //取前天的指数
58             zsymd = DateUtil.getLastDay("yyyyMMdd HH:mm:ss").substring(0, 8);
59             zsf = "17" ;
60         }else if(zshhmmi<1705){
61             zsf = "07" ;
62         }else if(zshhmmi<=2400){
63             zsf = "17" ;
64         }
65         
66         //文件名称
67         String weatherFName = "gn_360_"+ymd+hzStr+".txt" ;
68         String ziwaixianFName = zsymd+zsf+"ziwaixian.txt" ;
69         String chuanyiFName = zsymd+zsf+"chuanyi.txt" ;
70         String xicheFName = zsymd+zsf+"xiche.txt" ;
71         String ganmaoFName = zsymd+zsf+"ganmao.txt" ;
72         String yundongFName = zsymd+zsf+"yundong.txt" ;
73         
74         logger.info("【文件名：】"+weatherFName+"##"+ziwaixianFName+"##"+chuanyiFName+"##"+xicheFName+"##"+ganmaoFName+"##"+yundongFName+"##");
75         
76         String weatherContent = getStrFromFTP(ftpClient,weatherFName) ;
77         String ziwaixianContent = getStrFromFTP(ftpClient,ziwaixianFName) ;
78         String chuanyiContent = getStrFromFTP(ftpClient,chuanyiFName) ;
79         String xicheContent = getStrFromFTP(ftpClient,xicheFName) ;
80         String ganmaoContent = getStrFromFTP(ftpClient,ganmaoFName) ;
81         String yundongContent = getStrFromFTP(ftpClient,yundongFName) ;
82         
83         //将指数指标存储到Map中，key=天气城市id，value=提供了几天的数据，每天区分以#区分，几天不确定
84         logger.info("【取值成功，进行转化到MAP】");
85         HashMap ziwaixianMap = covertZBContentToMap(ziwaixianContent);
86         HashMap chuanyiMap = covertZBContentToMap(chuanyiContent);
87         HashMap xicheMap = covertZBContentToMap(xicheContent);
88         HashMap ganmaoMap = covertZBContentToMap(ganmaoContent);
89         HashMap yundongMap = covertZBContentToMap(yundongContent);
90         
91         logger.info("【取值成功，进行逻辑处理】");
92 }

 1     /*
 2      * 获取ftp上指定文件的内容
 3      */
 4     private String getStrFromFTP(FTPClient ftpClient,String fileName){
 5         logger.info("进入取值方法:"+ftpClient.toString()+"fileName:"+fileName);
 6         
 7         InputStream ins = null;
 8           StringBuilder builder = null;
 9           try {
10                // 从服务器上读取指定的文件
11               logger.info("进入取值方法try");
12               //设置FTPClient为被动传输模式即可解决线程挂起问题,防火墙问题
13                 ftpClient.enterLocalPassiveMode();  
14                 // 设置以二进制形式传输
15                 ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
16                ins = ftpClient.retrieveFileStream(fileName);
17                BufferedReader reader = new BufferedReader(new InputStreamReader(ins, "gbk"));
18                logger.info("进入取值方法try2");
19                String line;
20                builder = new StringBuilder(150);
21                while ((line = reader.readLine()) != null) {
22                 System.out.println(line);
23                 logger.info("line:"+line);
24                 builder.append(line).append("==");
25                }
26                reader.close();
27                if (ins != null) {
28                 ins.close();
29                }
30                // 主动调用一次getReply()把接下来的226消费掉. 这样做是可以解决这个返回null问题
31                logger.info("进入取值方法Reply前");
32                ftpClient.getReply();
33                logger.info("进入取值方法Reply后");
34           } catch (Exception e) {
35               logger.info("【ftp上指定文件的内容出错，文件名为：】"+fileName);
36                e.printStackTrace();
37           }
38           logger.info("取值方法完毕，内容："+builder.toString());
39           return builder.toString();
40     }
41     
42     /*
43      * 指标数组转化到Map，key=城市id,value=提供了几天的数据，每天区分以#区分，几天不确定
44      */
45     private HashMap covertZBContentToMap(String content){
46         HashMap map = new HashMap();
47         String[] ContentArr = content.split("==") ; 
48         for(int i=0;i<ContentArr.length;i++){
49             String[] vauleArr = ContentArr[i].split("\\|\\|") ;
50             String key = vauleArr[1].trim() ;
51             if(map.containsKey(key)){
52                 //如果已存储了key,则表示多天的数据， 则把数据拼接，连接符#
53                 String temp = (String)map.get(key) + "#" + ContentArr[i] ;
54                 map.remove(key);
55                 map.put(key, temp) ;
56             }else{
57                 map.put(key, ContentArr[i]) ;
58             }
59         }
60         logger.info("map长度:"+map.size());
61         return map ; 
62     }