1

我正在使用 android 开发 sftp。我用来JSch在服务器和设备之间建立通道，但我遇到了问题：

首先，用户必须选择要下载的文件列表，并为每个文件intentService创建一个下载文件。然后我进行 md5 检查以了解下载是否正常，最后如果完整性正常，我必须从服务器中删除文件。

主要问题是我有一个错误：SftpException 4: 没有描述，我认为当我尝试从服务器删除文件时服务已关闭，因此通道已关闭，无法找到文件。

我还有其他活动监控所有下载+全球进展。但是我不能删除这个文件，因为 Network on MainThread... 所以我想我可以SftpChannel在一个单独的线程上创建它并将其提供给活动。但我该怎么做呢？我知道BroadcastIntents不能发送这些类型的数据......

所以要恢复：

DownloadSFTPService => IntentService : open the SftpChannel并下载文件，将数据发送到 RunningDownloadsActivity 以进行进度。

RunningDownloadsActivity => ListActivity : Monitor all the downloads + global receiving via BrodcastIntent updates from DownloadSftpService.

下载Sftp服务：

protected void onHandleIntent(Intent intent) {

    //initializations

    //Création de la session avec le serveur
    JSch jsch = new JSch();
    Session session = null;
    try {
        session = jsch.getSession(loginFtp, ipServer, GlobalEnum.DOWNLOAD.PORT);
        if(session == null)
        {
            Log.e("SSHError","Impossible d'instancier la session");
        }
        else
        {

            //Configuration de la connexion par mot de passe plutot que certificat
            java.util.Properties config = new java.util.Properties();
            config.put("StrictHostKeyChecking", "no");
            config.put("PreferredAuthentifications", "password");
            session.setConfig(config);

            //Récupération du mot de passe dans les préférences et ouverture de session avec le serveur
            session.setPassword(passwordFtp);
            session.connect();

            //Configuration du canal en mode sFTP et ouverture
            Channel channel = session.openChannel("sftp");
            sftpChannel = (ChannelSftp) channel;
            sftpChannel.connect();

            //Initialisation de la notification
            initialiseNotif();

            //Lancement du téléchargement des fichiers
            downloadFiles();

            //Clôture de la connexion
            sftpChannel.disconnect();

        }
    } catch (JSchException e) {
        Log.e("JschException", e.toString());
    } catch (SftpException e) {
        Log.e("SftpException", e.toString());
    }

}

    private void downloadFiles() throws SftpException
{
    Vector<ChannelSftp.LsEntry> file;

    //Pour chaque fichier
    for( String tempFileName : downloadList)
    {           
        if(fileExisting(tempFileName)) {
            //Récupération des infos fichier
            file = sftpChannel.ls(tempFileName);
            currentFileSize = file.get(0).getAttrs().getSize();
            currentFileName = file.get(0).getFilename();

            broadcastIntentRD.putExtra(GlobalEnum.DOWNLOAD.FILE_NAME, currentFileName);
            broadcastIntentRD.putExtra(GlobalEnum.DOWNLOAD.FILE_SIZE, currentFileSize);

            //Lancement du téléchargement 

            int lastDot = tempFileName.lastIndexOf(".");
            String baseFileName = null;
            if(tempFileName.endsWith("tar.gz"))
            {
                String temp = tempFileName.substring(0, lastDot);
                baseFileName = temp.substring(0, temp.lastIndexOf("."));
            } else {
                baseFileName = tempFileName.substring(0, lastDot );
            }

            try {
                sftpChannel.get(baseFileName + ".md5", Environment.getExternalStorageDirectory() + vamsillaPath + "/" + baseFileName + ".md5");
            } catch (SftpException e) {
                Log.v("Sftp", "md5 introuvable pour : " + currentFileName);
            }
            sftpChannel.get(file.get(0).getFilename(), Environment.getExternalStorageDirectory() + vamsillaPath + "/" + file.get(0).getFilename(),this);
        }

    }

运行下载活动：

public class DownloadReceiverRD extends BroadcastReceiver{


    @Override
    public void onReceive(Context context, Intent intent) {

        //BLABLA for notification and progressbar update

                    if(progress == fileSize){

                        //BLABLA for notification and progressbar closing


                        md5Sum(fileName);
                    }
                }
      private void md5Sum(String currentFileName) {
        VamsillaTools tools = new VamsillaTools(getApplicationContext());

        //Ouverture de la base de stockage des fichiers

        //Insertion du résultat dans la BDD
        int result = tools.checkMD5(currentFileName);
        db.insertFile(currentFileName, result);
        switch(result) {
            case -1 : Log.v("MD5", "Problème lors de la comparaison md5 : " + currentFileName); break;
            case 0 : Log.v("MD5", "Comparaison md5 fausse : " + currentFileName); break;
            case 1 : Log.v("MD5", "Succès de la comparaison md5 pour : " + currentFileName);

    /********
      SUPRESS THE FILE HERE WOULD BE PERFECT !!! 
    *********/

   break;
        }
    }
}

请原谅我的英语，我是法国人，你知道我们的外语有多好......

谢谢 ！

4

1 回答 1

0

可能已经晚了，但如果它可以帮助某人......我终于做了一个从 Thread 继承的类做网络 + 删除文件，当我们停止寻找困难的方法时，这很简单:)

于 2013-01-11T20:10:20.890 回答