android ftp上传下载

柔光的暖阳◎ 2023-01-14 00:47 201阅读 0赞

new Thread(){ 
                @Override
                public void run() { 
                    try { 
                        FTPClient ftpClient = new FTPClient();
                        FileInputStream fis;
                        ftpClient.setConnectTimeout(3000);
                        if(p.getString("ip2","") == "" || p.getString("port2","") == ""){ 
                            handler.sendEmptyMessage(CodeList.DATA_PARSING_FAILURE_4);
                            return;
                        }
                        ftpClient.connect(p.getString("ip2",""), Integer.parseInt(p.getString("port2","")));
                        boolean isLogin = ftpClient.login(p.getString("ftpuser",""), p.getString("ftppwd",""));
                        int replyCode = ftpClient.getReplyCode();
                        ftpClient.enterLocalPassiveMode();
                        if (isLogin && FTPReply.isPositiveCompletion(replyCode)) { 
                            if(ftpClient.changeWorkingDirectory("/ypwj/"+ PowerBean.area_id+"/")){ 
    
                            }else{ 
                                ftpClient.makeDirectory("/ypwj/"+PowerBean.area_id+"/");
                                ftpClient.changeWorkingDirectory("/ypwj/"+PowerBean.area_id+"/");
                            }
    
    
                            File d = new File(path);
                            //ftpClient.setBufferSize(1024);
                            //ftpClient.setControlEncoding("UTF-8");
                           // ftpClient.setControlEncoding("GBK");
                            ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
                            ftpClient.enterLocalPassiveMode();
                            fis = new FileInputStream(d);
                            //fileName = "1111.mp3";
    
                            String fn = new String(fileName.getBytes("GBK"),"iso-8859-1");
                            ftpClient.storeFile(fn, fis);
                            Log.v("ccc","成功");
    
                            ftpClient.logout();
                            ftpClient.disconnect();
                            handler.sendEmptyMessage(CodeList.UPLOAD_SUCCESS);
                        }else{ 
                            handler.sendEmptyMessage(CodeList.DATA_PARSING_FAILURE_5);
                        }
    
                    } catch (IOException e) { 
                        handler.sendEmptyMessage(CodeList.DATA_PARSING_FAILURE_4);
                        e.printStackTrace();
                    }
                }
            }.start();

new Thread() { 
                    @Override
                    public void run() { 
                        try { 
                            FTPClient ftpClient = new FTPClient();
                            FileInputStream fis;
                            ftpClient.setConnectTimeout(3000);
                            if (p.getString("ip2", "") == "" || p.getString("port2", "") == "") { 
                                handler.sendEmptyMessage(CodeList.DATA_PARSING_FAILURE_4);
                                return;
                            }
                            ftpClient.connect(p.getString("ip2", ""), Integer.parseInt(p.getString("port2", "")));
                            boolean isLogin = ftpClient.login(p.getString("ftpuser", ""), p.getString("ftppwd", ""));
                            int replyCode = ftpClient.getReplyCode();
                            ftpClient.enterLocalPassiveMode();
                            if (isLogin && FTPReply.isPositiveCompletion(replyCode)) { 
                                String p = arr.get(fileCurrent).getPath();
    
                                ftpClient.changeWorkingDirectory(p.substring(0, p.lastIndexOf("/") + 1));
    // ftpClient.changeWorkingDirectory("/ypwj/");
                                ftpClient.setControlEncoding("GBK");
                                // 得到FTP当前目录下所有文件
                                FTPFile[] ftpFiles = ftpClient.listFiles();
                                // 循环遍历
                                boolean flag = false;
                                for (FTPFile ftpFile : ftpFiles) { 
    
                                    // 找到需要下载的文件
                                    if (ftpFile.getName().equals(arr.get(fileCurrent).getName())) { 
                                        ftpClient.enterLocalPassiveMode();
                                        // Log.v("ccc",arr.get(fileCurrent).getName());
                                        // 创建本地目录
                                        File f = new File(Environment.getExternalStorageDirectory(), "sounds");
                                        File d = new File(f, arr.get(fileCurrent).getName());
    
                                        // 创建输出流
                                        OutputStream outputStream = new FileOutputStream(d);
                                        // 下载单个文件
                                        flag = ftpClient.retrieveFile(new String(ftpFile.getName().getBytes("GB2312"), "ISO-8859-1"), outputStream);
                                        // 关闭文件流
                                        outputStream.close();
                                        flag = true;
                                        break;
                                    }
                                }
                                if (flag) { 
    
                                    handler.sendEmptyMessage(CodeList.FTP_DOWNLOAD_SUCCESS);
                                } else { 
                                    handler.sendEmptyMessage(CodeList.FTP_DOWNLOAD_ERROR);
                                }
                            } else { 
                                handler.sendEmptyMessage(CodeList.DATA_PARSING_FAILURE_5);
                            }
    
                        } catch (IOException e) { 
                            handler.sendEmptyMessage(CodeList.DATA_PARSING_FAILURE_4);
                            e.printStackTrace();
                        }
                    }
                }.start();