码迷,mamicode.com
首页 > Web开发 > 详细

jsch连接sftp后连接未释放掉问题排查

时间:2019-06-12 09:20:19      阅读:873      评论:0      收藏:0      [点我收藏+]

标签:开始   log   wap   用户名   max   时间   oca   class   deb   

项目中通过jsch中的sftp实现上传下载文件。代码上了服务器之后,内存飙升,逐渐把swap区也占满,通过top监控未发现占用内存的进程,通过查找sshd进程,发现服务器多了很多sftp的进程没有被关闭。

技术图片

刚开始以为是sftp公共方法设计的有问题,下面是部分代码片段

@Repository("SftpClient")
public class SftpClient {

    private Logger logger = LoggerFactory.getLogger(SftpClient.class);  
    private ThreadLocal<Session> sessionLocal = new ThreadLocal<Session>(); 
    private ThreadLocal<ChannelSftp> channelLocal = new ThreadLocal<ChannelSftp>();
    
    //初始化连接
    public SftpClient init() {
        try {
            String host = SFTP_HOST;
            int port = Integer.valueOf(SFTP_PORT);
            String userName = SFTP_USER_NAME;
            String password = SFTP_USER_PASSWORD;
            Integer timeout = Integer.valueOf(SFTP_TIMEOUT);
            Integer aliveMax = Integer.valueOf(SFTP_ALIVEMAX);
            // 创建JSch对象
            JSch jsch = new JSch();
            Session session = jsch.getSession(userName, host, port);
            // 根据用户名,主机ip,端口获取一个Session对象
            if (password != null) {
                // 设置密码
                session.setPassword(password);
            }
            // 为Session对象设置properties
            session.setConfig("StrictHostKeyChecking", "no");
            if (timeout != null) {
                // 设置timeout时间
                session.setTimeout(timeout);
            }
            if (aliveMax != null) {
                session.setServerAliveCountMax(aliveMax);
            }
            // 通过Session建立链接
            session.connect();
            // 打开SFTP通道
            ChannelSftp channel = (ChannelSftp) session.openChannel("sftp");
            // 建立SFTP通道的连接
            channel.connect();
            channelLocal.set(channel);
            sessionLocal.set(session);
            logger.debug("SSH Channel connected.session={},channel={}", session, channel);
        } catch (JSchException e) {
            throw new SystemException(ImageExceptionCode.FTP_SEND_ERROR);
        }
        return this;
    }

    //断开连接
    public void disconnect() {
        ChannelSftp channel = channelLocal.get();
        Session session = sessionLocal.get();
        //断开sftp连接
        if (channel != null) {
            channel.disconnect();
            logger.debug("SSH Channel disconnected.channel={}", channel);
        }
        //断开sftp连接之后,再断开session连接
        if (session != null) {
            session.disconnect();
            logger.debug("SSH session disconnected.session={}", session);
        }
        channelLocal.remove();
        sessionLocal.remove();
    }
}

 

jsch连接sftp后连接未释放掉问题排查

标签:开始   log   wap   用户名   max   时间   oca   class   deb   

原文地址:https://www.cnblogs.com/zjfjava/p/11007358.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!