linux环境：java.net.SocketException: Broken pipe (Write failed)

[MarvinYu]

java.net.SocketException: Broken pipe (Write failed)
at java.net.SocketOutputStream.socketWrite0(Native Method)
at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:109)
at java.net.SocketOutputStream.write(SocketOutputStream.java:153)
at sun.nio.cs.StreamEncoder.writeBytes(StreamEncoder.java:221)
at sun.nio.cs.StreamEncoder.implFlushBuffer(StreamEncoder.java:291)
at sun.nio.cs.StreamEncoder.implFlush(StreamEncoder.java:295)
at sun.nio.cs.StreamEncoder.flush(StreamEncoder.java:141)
at java.io.OutputStreamWriter.flush(OutputStreamWriter.java:229)
at java.io.BufferedWriter.flush(BufferedWriter.java:254)
at org.apache.commons.net.ftp.FTP.__send(FTP.java:545)
at org.apache.commons.net.ftp.FTP.sendCommand(FTP.java:519)
at org.apache.commons.net.ftp.FTP.sendCommand(FTP.java:648)
at org.apache.commons.net.ftp.FTP.cwd(FTP.java:868)
at org.apache.commons.net.ftp.FTPClient.changeWorkingDirectory(FTPClient.java:1167)
at com.yinghuo.contract.biz.core.util.ftp.FtpClientTemplate.uploadFile(FtpClientTemplate.java:56)

在linux 环境下容易出现session超时。需要保证keepAlive

[jayknoxqu]

抱歉现在才看到，能否提供更详细的信息，比如是否在多线程环境下，或者文件是否过大，ftp服务器的配置之类的。
我改动了下代码，增加了配置ftp.client.keepAliveTimeout=30，不知道是否能解决你出现的问题，源码为：
/**
* Set the time to wait between sending control connection keepalive messages
* when processing file upload or download.
*
* @param controlIdle the wait (in secs) between keepalive messages. Zero (or less) disables.
* @SInCE 3.0
* @see #setControlKeepAliveReplyTimeout(int)
*/
public void setControlKeepAliveTimeout(long controlIdle){
__controlKeepAliveTimeout = controlIdle * 1000;
}

[fortunelee]

not help

[MarvinYu]

谢谢，我重新尝试下；我配置了这个参数，没看你底层实现 @jayknoxqu

这是我的配置 ftpClient.setControlKeepAliveTimeout(ftpClientConfig.getControlKeepAliveTimeout());

应该是服务器端口被关闭了，目前没有其他办法。

[MarvinYu]

https://stackoverflow.com/questions/51730863/ftpclient-how-to-get-around-org-apache-commons-net-io-copystreamexception-ioexc 看了下，还没想到很好的办法 @jayknoxqu

[jayknoxqu]

你不会是sftp吧?

[MarvinYu]

你不会是sftp吧?

还真不是，就是普通的FTP。我不使用池化的方法还行，但是一起用池化的；就
at org.apache.commons.net.ftp.FTPClient.changeWorkingDirectory(FTPClient.java:1167)
最后看到底层还是那个流 flush 异常

[jayknoxqu]

"我不使用池化的方法还行，但是一起用池化的",能具体描述下么我这边没办法复现出来,是像测试类里那样使用么?

[MarvinYu]

"我不使用池化的方法还行，但是一起用池化的",能具体描述下么我这边没办法复现出来,是像测试类里那样使用么?

多线程一次性发送100张图片到FTP服务器，使用FTPClientPool就会出现了；如果是使用 new FTPClient不会出现这种情况

[jayknoxqu]

你能贴下代码么?
https://github.com/jayknoxqu/ftp-pool/blob/master/src/test/java/com/zhenjin/ftp/FtpClientPoolTest.java

[jayknoxqu]

FtpClientPool是标记为不弃用的;
正确使用连接池的方式是使用commons-pool2 提供的

GenericObjectPool<FTPClient> ftpClientPool=new GenericObjectPool<>(ftpClientFactory);

方法创建连接池

[MarvinYu]

你能贴下代码么?
https://github.com/jayknoxqu/ftp-pool/blob/master/src/test/java/com/zhenjin/ftp/FtpClientPoolTest.java

/**

• @author marvinYu

• 用于测试 ftpClientTemplate:uploadFile 在Linux环境下与windows下面是否有区别

• @Version : LinuxFTPUploadTestJob.java, v 0.1 2019-02-13 18:01 Exp $
  */
  @JobHandler(value = "linuxFTPUploadTestJob")
  @service
  public class LinuxFTPUploadTestJob extends AbstractJobHandler {
  @resource
  private FtpClientTemplate ftpClientTemplate;

  @OverRide
  public ReturnT doExecute(String s) throws Exception {
  int linuxFtpUploadSize = Integer.parseInt(SysConfigUtil
  .getSysConfigByType("linux_ftp_upload_size"));

   for (int i = 0; i < linuxFtpUploadSize; i++) {
       Runnable runnable = () -> {
           File file = new File(
               "/usr/local/test.properties");
           boolean uploadResult = ftpClientTemplate.uploadFile(file, "/upload");
           String threadName = Thread.currentThread().getName();
           System.out.println("Thread 1-" + threadName + ":" + uploadResult);
       };
       runnable.run();
       Thread testThread = new Thread(runnable);
  
       testThread.start();
   }
  
   return ReturnT.SUCCESS;
  

  }
  }

JobHandler（xxxJob调度） 在Linux环境下定时周期1分钟，就可以看到后台有该异常

[MarvinYu]

FtpClientPool是标记为不弃用的;
正确使用连接池的方式是使用commons-pool2 提供的

GenericObjectPool<FTPClient> ftpClientPool=new GenericObjectPool<>(ftpClientFactory);

方法创建连接池

这个没有问题，我看了common-pool的实现是一致的。

[MarvinYu]

@jayknoxqu

windows环境下，长期观察下。就可以看到这个
org.apache.commons.net.ftp.FTPConnectionClosedException: FTP response 421 received. Server closed connection.
at org.apache.commons.net.ftp.FTP.__getReply(FTP.java:388)
at org.apache.commons.net.ftp.FTP.__getReply(FTP.java:300)
at org.apache.commons.net.ftp.FTP.sendCommand(FTP.java:523)
at org.apache.commons.net.ftp.FTP.sendCommand(FTP.java:648)
at org.apache.commons.net.ftp.FTP.cwd(FTP.java:868)
at org.apache.commons.net.ftp.FTPClient.changeWorkingDirectory(FTPClient.java:1167)
at com.yinghuo.fundgateway.util.ftp.FtpClientTemplate.uploadFile(FtpClientTemplate.java:51)
at com.yinghuo.fundgateway.biz.task.job.temp.LinuxFTPUploadTestJob.lambda$doExecute$0(LinuxFTPUploadTestJob.java:41)
at java.lang.Thread.run(Thread.java:745)