java 之 SFTP通信

客官°小女子只卖身不卖艺 2023-03-02 04:58 1阅读 0赞

## 1.pom文件依赖 ##

<dependency>
        <groupId>com.jcraft</groupId>
        <artifactId>jsch</artifactId>
        <version>0.1.55</version>
    </dependency>

## 2.代码封装类 ##

package com.common.sftp;
    
    
    import java.util.Map;
    import java.util.Properties;
    
    import com.jcraft.jsch.Channel;
    import com.jcraft.jsch.ChannelSftp;
    import com.jcraft.jsch.JSch;
    import com.jcraft.jsch.JSchException;
    import com.jcraft.jsch.Session;
    
    public class SFTPChannel { 
        Session session = null;
        Channel channel = null;
    
        public ChannelSftp getChannel(Map<String, String> sftpDetails, int timeout) throws JSchException { 
    
            String ftpHost = sftpDetails.get(SFTPConstants.SFTP_REQ_HOST);
            String port = sftpDetails.get(SFTPConstants.SFTP_REQ_PORT);
            String ftpUserName = sftpDetails.get(SFTPConstants.SFTP_REQ_USERNAME);
            String ftpPassword = sftpDetails.get(SFTPConstants.SFTP_REQ_PASSWORD);
    
            int ftpPort = SFTPConstants.SFTP_DEFAULT_PORT;
            if (port != null && !port.equals("")) { 
                ftpPort = Integer.valueOf(port);
            }
    
            JSch jsch = new JSch(); // 创建JSch对象
            session = jsch.getSession(ftpUserName, ftpHost, ftpPort); // 根据用户名，主机ip，端口获取一个Session对象
            System.out.println("Session created.");
            if (ftpPassword != null) { 
                session.setPassword(ftpPassword); // 设置密码
            }
            Properties config = new Properties();
            config.put("StrictHostKeyChecking", "no");
            session.setConfig(config); // 为Session对象设置properties
            session.setTimeout(timeout); // 设置timeout时间
            session.connect(); // 通过Session建立链接
            System.out.println("Session connected.");
    
            System.out.println("Opening Channel.");
            channel = session.openChannel("sftp"); // 打开SFTP通道
            channel.connect(); // 建立SFTP通道的连接
            System.out.println("Connected successfully to ftpHost = " + ftpHost + ",as ftpUserName = " + ftpUserName
                    + ", returning: " + channel);
            return (ChannelSftp) channel;
        }
    
        public void closeChannel() throws Exception { 
            if (channel != null) { 
                channel.disconnect();
            }
            if (session != null) { 
                session.disconnect();
            }
        }
    }

package com.common.sftp;
    
    public class SFTPConstants { 
        public static final String SFTP_REQ_HOST = "host";
        public static final String SFTP_REQ_PORT = "port";
        public static final String SFTP_REQ_USERNAME = "username";
        public static final String SFTP_REQ_PASSWORD = "password";
        public static final int SFTP_DEFAULT_PORT = 22;
        public static final String SFTP_REQ_LOC = "location";
    }

## Test ##

SFTPTest.java
    
    package com.longyg.sftp;
    
    import java.util.HashMap;
    import java.util.Map;
    
    import com.jcraft.jsch.ChannelSftp;
    
    public class SFTPTest { 
    
        public SFTPChannel getSFTPChannel() { 
            return new SFTPChannel();
        }
    
        /** * @param args * @throws Exception */
        public static void main(String[] args) throws Exception { 
            SFTPTest test = new SFTPTest();
    
            Map<String, String> sftpDetails = new HashMap<String, String>();
            // 设置主机ip，端口，用户名，密码
            sftpDetails.put(SFTPConstants.SFTP_REQ_HOST, "10.9.167.55");
            sftpDetails.put(SFTPConstants.SFTP_REQ_USERNAME, "root");
            sftpDetails.put(SFTPConstants.SFTP_REQ_PASSWORD, "arthur");
            sftpDetails.put(SFTPConstants.SFTP_REQ_PORT, "22");
            
            String src = "D:\\DevSoft\\HB-SnagIt1001.rar"; // 本地文件名
            String dst = "/home/omc/ylong/sftp/HB-SnagIt1001.rar"; // 目标文件名
                  
            SFTPChannel channel = test.getSFTPChannel();
            ChannelSftp chSftp = channel.getChannel(sftpDetails, 60000);
            
            /** * 代码段1 OutputStream out = chSftp.put(dst, ChannelSftp.OVERWRITE); // 使用OVERWRITE模式 byte[] buff = new byte[1024 * 256]; // 设定每次传输的数据块大小为256KB int read; if (out != null) { System.out.println("Start to read input stream"); InputStream is = new FileInputStream(src); do { read = is.read(buff, 0, buff.length); if (read > 0) { out.write(buff, 0, read); } out.flush(); } while (read >= 0); System.out.println("input stream read done."); } **/
            
            chSftp.put(src, dst, ChannelSftp.OVERWRITE); // 代码段2
            
            // chSftp.put(new FileInputStream(src), dst, ChannelSftp.OVERWRITE); // 代码段3
            
            chSftp.quit();
            channel.closeChannel();
        }
    }

参考文章：

[https://www.cnblogs.com/longyg/archive/2012/06/25/2556576.html][https_www.cnblogs.com_longyg_archive_2012_06_25_2556576.html]

[https_www.cnblogs.com_longyg_archive_2012_06_25_2556576.html]: https://www.cnblogs.com/longyg/archive/2012/06/25/2556576.html