我使用Apache的FTPClient将文件上传到FTP服务器。
但是,即使在我们上传文件时FTP服务器不可用,storeFile()也会挂起。 storeFile()不会取消上传。
tcpdump跟踪:
22:04:29.584767 IP 10.84.78.2> 192.168.114.2:ICMP 10.84.78.2 TCP端口53751无法访问,长度142
有没有设置超时的方法?我已经尝试在connect()之后使用setSoTimeout(),在storeFile()之前使用setDataTimeout()。但是,此属性似乎与此问题无关。
FTP服务器不可用后执行的线程转储:
"Thread-1" prio=10 tid=0x00007f1a700f1800 nid=0x479b runnable [0x00007f1a76fea000]
java.lang.Thread.State: RUNNABLE
at java.net.SocketOutputStream.socketWrite0(Native Method)
at java.net.SocketOutputStream.socketWrite(Unknown Source)
at java.net.SocketOutputStream.write(Unknown Source)
at java.io.BufferedOutputStream.flushBuffer(Unknown Source)
at java.io.BufferedOutputStream.write(Unknown Source)
- locked <0x00000000bb026df8> (a java.io.BufferedOutputStream)
at org.apache.commons.net.io.ToNetASCIIOutputStream.write(ToNetASCIIOutputStream.java:75)
- locked <0x00000000bb028e20> (a org.apache.commons.net.io.ToNetASCIIOutputStream)
at org.apache.commons.net.io.Util.copyStream(Util.java:111)
at org.apache.commons.net.ftp.FTPClient._storeFile(FTPClient.java:653)
at org.apache.commons.net.ftp.FTPClient.__storeFile(FTPClient.java:624)
at org.apache.commons.net.ftp.FTPClient.storeFile(FTPClient.java:1976)
at ... (FTPClient.java:103)
at ... (Sender.java:67)
netstat -anpo输出:
netstat -anpo | grep 192
tcp6 0 0 10.84.78.2:9011 192.168.114.2:21 VERBUNDEN 19310/java aus (0.00/0/0)
tcp6 0 201480 10.84.78.2:33088 192.168.114.2:20 VERBUNDEN 19310/java ein (10,26/2/0)
最佳答案
我会尝试
ftpClient.setControlKeepAliveTimeout(300); // set timeout to 5 minutes
取自here
“在文件传输期间,数据连接正忙,但控制连接处于空闲状态。FTP服务器知道该控制连接正在使用中,因此不会由于缺乏活动而将其关闭,但是网络路由器很难知道这一点。控制连接和数据连接是相互关联的。某些路由器可能会将控制连接视为空闲,如果数据连接上的传输所花费的时间超过路由器允许的空闲时间,则断开控制连接。
一种解决方案是通过控制连接发送安全命令(即NOOP)以重置路由器的空闲计时器。启用如下:“
ftpClient.setControlKeepAliveTimeout(300); // set timeout to 5 minutes
这将导致文件上载/下载方法大约每5分钟发送一次NOOP。
The following public methods support this:"
retrieveFile(String, OutputStream)
appendFile(String, InputStream)
storeFile(String, InputStream)
storeUniqueFile(InputStream)
storeUniqueFileStream(String)