//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;

    }