我正在开发一个小应用程序,允许从 Web 应用程序上传 FTP 文件...
发送操作运行良好,但我想能够取消正在进行中的文件存储。
我对线程不是很熟悉。我的第一次尝试是在取消线程中调用 ftp.abort(),但是abort方法只在 storeFile 方法完成时才被调用,就好像发送线程锁定了 ftp 对象一样。
因此,我更改了代码以中断发送线程,并在复制流监听器中对其进行检查。文件存储停止得如预期,但ftp.abort()调用会使应用程序挂起,它永远无法完成。
有什么建议吗?
谢谢, Philip 发送操作:
发送操作运行良好,但我想能够取消正在进行中的文件存储。
我对线程不是很熟悉。我的第一次尝试是在取消线程中调用 ftp.abort(),但是abort方法只在 storeFile 方法完成时才被调用,就好像发送线程锁定了 ftp 对象一样。
因此,我更改了代码以中断发送线程,并在复制流监听器中对其进行检查。文件存储停止得如预期,但ftp.abort()调用会使应用程序挂起,它永远无法完成。
有什么建议吗?
谢谢, Philip 发送操作:
botaoEnviar.setEnabled(false);
botaoCancelar.setEnabled(true);
textField.requestFocus();
threadEnvio = new Thread(new Runnable()
{
@Override
public void run()
{
FileInputStream fis = null;
try
{
if(arquivoSelecionado == null)
{
throw new IllegalArgumentException("Arquivo deve ser informado");
}
try
{
ftp = new FTPClient();
ftp.connect("192.168.1.243");
}
catch(Exception e)
{
throw new FtpConnectionException("Não foi possível conectar no servidor FTP", e);
}
if(!ftp.login("c001", "0AJF2J36"))
{
throw new IllegalArgumentException("Não foi possível autenticar no servidor FTP");
}
ftp.setFileType(FTPClient.BINARY_FILE_TYPE);
ftp.setCopyStreamListener(new CopyStreamAdapter()
{
@Override
public void bytesTransferred(long totalBytesTransferred, int bytesTransferred, long streamSize)
{
if(threadEnvio.isInterrupted())
{
try
{
ftp.abort();
}
catch(IOException ex)
{
handleException(ex);
}
}
else
{
int percent = (int) (totalBytesTransferred * 100 / arquivoSelecionado.length());
progressBar.setValue(percent);
}
}
});
fis = new FileInputStream(arquivoSelecionado);
if(ftp.storeFile(arquivoSelecionado.getName(), fis))
{
JOptionPane.showMessageDialog(null, "Arquivo enviado com suceso");
}
else
{
JOptionPane.showMessageDialog(null, "Não foi possível enviar o arquivo", "Erro", JOptionPane.ERROR_MESSAGE);
}
ftp.logout();
}
catch(Exception e)
{
handleException(e);
}
finally
{
if(fis != null)
{
try
{
fis.close();
}
catch(IOException ex)
{
handleException(ex);
}
}
if(ftp != null)
{
try
{
ftp.disconnect();
}
catch(IOException ex)
{
handleException(ex);
}
}
progressBar.setValue(0);
botaoEnviar.setEnabled(true);
botaoCancelar.setEnabled(false);
}
}
});
threadEnvio.start();
取消操作:
botaoCancelar.setEnabled(false);
new Thread(new Runnable()
{
@Override
public void run()
{
try
{
threadEnvio.interrupt();
}
catch(Exception ex)
{
handleException(ex);
}
finally
{
botaoCancelar.setEnabled(true);
}
}
}).start();