//FTP传输到数据库服务器 
    private boolean uploadServerByFtps(){ 
        boolean flag = true; 
        //获取客户端数据文件路径 
        String client_path = Pub.getPropertiesValue("analysis", "analysis.client.data.path"); 
        //获取数据库服务器上的存放数据文件路径 
        String server_path = Pub.getPropertiesValue("analysis", "analysis.server.data.path"); 
         
        String hostname = Pub.getPropertiesValue("analysis", "ftp.hostname"); 
        String ftpusername =  Pub.getPropertiesValue("analysis", "ftp.username"); 
        String ftppwd = Pub.getPropertiesValue("analysis", "ftp.pwd"); 
        int port = 21; 
        logger.info("ftp server infor:hostname:"+hostname+" ftpusername:"+ftpusername+" ftppwd:"+ftppwd+" port:"+port); 
         
        //遍历客户端数据文件路径下的txt文件，然后采用FTP上传 
        File client_dir = new File(client_path);   
        if(!client_dir.exists()){ 
            logger.info("The file directory on the host you want to read does not exist"); 
              return flag; 
        } 
        File client_files[] =  client_dir.listFiles(); 
        if(client_files.length == 0){ 
            logger.info("You want to read the file directory without any files"); 
              return flag; 
        } 
        //开始遍历文件 
        //创建ftp客户端 
        FTPClient ftpClient = new FTPClient(); 
        ftpClient.setControlEncoding("GBK"); 
        for(int i=0;i<client_files.length;i++){  
            String getfileName = client_files[i].getName(); 
            String getfileNamePath = client_files[i].getPath(); 
            //只对txt文件做处理 
            if((getfileName.substring(getfileName.lastIndexOf(".")).trim().equals(".txt"))){ 
                //todo:增加控制文件（已经传输过的文件）的传输 
                 
                 try { 
                    //链接ftp服务器 
                    ftpClient.connect(hostname, port); 
                    //登录ftp 
                    ftpClient.login(ftpusername, ftppwd); 
                    int reply = ftpClient.getReplyCode(); 
                    if (!FTPReply.isPositiveCompletion(reply)) { 
                        ftpClient.disconnect(); 
                        logger.info("Returns a 530 password username error or the current user does not have permission to close the FTP connection"); 
                        return false; 
                    } 
                    ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE); 
                    // ftpClient.makeDirectory("path");//在root目录下创建文件夹 
                    String server_file_name = server_path+ getfileName; 
                    logger.info("server_file_name>>>>>>: " + server_file_name); 
                    logger.info("getfileNamePath>>>>>>: " + getfileNamePath); 
                     
                    //读取源文件流（客户端文件） 
                    InputStream client_fileInput = new FileInputStream(getfileNamePath); 
                    //传送到服务端 
                    ftpClient.storeFile(server_file_name, client_fileInput);//文件你若是不指定就会上传到root目录下 
                    client_fileInput.close(); 
                    ftpClient.logout(); 
                    logger.info("ftp is success"); 
                } catch (SocketException e) { 
                    // TODO Auto-generated catch block 
                    logger.info("port problem: "+e.toString()); 
                    e.printStackTrace(); 
                } catch (IOException e) { 
                    // TODO Auto-generated catch block 
                    logger.info("IO problem: "+e.toString()); 
                    e.printStackTrace(); 
                } catch (Exception e) { 
                    logger.info("ftp problem: "+e.toString()); 
                    e.printStackTrace(); 
                }finally { 
                    if (ftpClient.isConnected()) { 
                        try { 
                            ftpClient.disconnect(); 
                        } catch (IOException ioe) { 
                            ioe.printStackTrace(); 
                            logger.info("IO problem: "+ioe.toString()); 
                        } 
                    } 
 
                } 
            } 
        } 
         
        return flag; 
    }