C# 通过 Renci.SshNet 实现SFTP数据传输

本文涉及的产品
数据传输服务 DTS,数据迁移 small 3个月
推荐场景:
MySQL数据库上云
数据传输服务 DTS,数据同步 1个月
简介: 新建一个工程,引用 Renci.SshNet.dll ,SFTP操作类如下:using System;using System.Collections;using System.

新建一个工程,引用 Renci.SshNet.dll ,SFTP操作类如下:

using System;
using System.Collections;
using System.IO;

using Renci.SshNet;

/************************描述 SFTP操作类******************************************
**创建者  : FYF
**创建时间: 2015-03-11
**描述    : SFTP操作类
**注意    : 所有远程目录或路径可包含工作目录(sftp.WorkingDirectory),此时路径以"/"开头;也可以不包含工作目录,此时路径不以"/"开头
** 履历   :No.         日期           修改人                 描述
*********************************************************************************/

namespace IF.Utility
{
    /// <summary>
    /// SFTP操作类
    /// </summary>
    public class SFTPOperation
    {
        #region 字段或属性
        private SftpClient sftp;
        /// <summary>
        /// SFTP连接状态
        /// </summary>
        public bool Connected { get { return sftp.IsConnected; } }
        #endregion

        #region 构造
        /// <summary>
        /// 构造
        /// </summary>
        /// <param name="ip">IP</param>
        /// <param name="port">端口</param>
        /// <param name="user">用户名</param>
        /// <param name="pwd">密码</param>
        public SFTPOperation(string ip, string port, string user, string pwd)
        {
            sftp = new SftpClient(ip, Int32.Parse(port), user, pwd);
        }
        #endregion

        #region 连接SFTP
        /// <summary>
        /// 连接SFTP
        /// </summary>
        /// <returns>true成功</returns>
        public bool Connect()
        {
            try
            {
                if (!Connected)
                {
                    sftp.Connect();
                }
                return true;
            }
            catch (Exception ex)
            {
                throw new Exception(string.Format("连接SFTP失败,原因:{0}", ex.Message));
            }
        }
        #endregion

        #region 断开SFTP
        /// <summary>
        /// 断开SFTP
        /// </summary> 
        public void Disconnect()
        {
            try
            {
                if (sftp != null && Connected)
                {
                    sftp.Disconnect();
                }
            }
            catch (Exception ex)
            {
                throw new Exception(string.Format("断开SFTP失败,原因:{0}", ex.Message));
            }
        }
        #endregion

        #region SFTP上传文件
        /// <summary>
        /// SFTP上传文件
        /// </summary>
        /// <param name="localPath">本地路径</param>
        /// <param name="remotePath">远程路径</param>
        public void Put(string localPath, string remotePath)
        {
            try
            {
                using (var file = File.OpenRead(localPath))
                {
                    Connect();
                    sftp.UploadFile(file, remotePath);
                    Disconnect();
                }
            }
            catch (Exception ex)
            {
                throw new Exception(string.Format("SFTP文件上传失败,原因:{0}", ex.Message));
            }
        }
        #endregion

        #region SFTP获取文件
        /// <summary>
        /// SFTP获取文件
        /// </summary>
        /// <param name="remotePath">远程路径</param>
        /// <param name="localPath">本地路径</param>
        public void Get(string remotePath, string localPath)
        {
            try
            {
                Connect();
                var byt = sftp.ReadAllBytes(remotePath);
                Disconnect();
                File.WriteAllBytes(localPath, byt);
            }
            catch (Exception ex)
            {
                throw new Exception(string.Format("SFTP文件获取失败,原因:{0}", ex.Message));
            }

        }
        #endregion

        #region 删除SFTP文件
        /// <summary>
        /// 删除SFTP文件 
        /// </summary>
        /// <param name="remoteFile">远程路径</param>
        public void Delete(string remoteFile)
        {
            try
            {
                Connect();
                sftp.Delete(remoteFile);
                Disconnect();
            }
            catch (Exception ex)
            {
                throw new Exception(string.Format("SFTP文件删除失败,原因:{0}", ex.Message));
            }
        }
        #endregion

        #region 获取SFTP文件列表
        /// <summary>
        /// 获取SFTP文件列表
        /// </summary>
        /// <param name="remotePath">远程目录</param>
        /// <param name="fileSuffix">文件后缀</param>
        /// <returns></returns>
        public ArrayList GetFileList(string remotePath, string fileSuffix)
        {
            try
            {
                Connect();
                var files = sftp.ListDirectory(remotePath);
                Disconnect();
                var objList = new ArrayList();
                foreach (var file in files)
                {
                    string name = file.Name;
                    if (name.Length > (fileSuffix.Length + 1) && fileSuffix == name.Substring(name.Length - fileSuffix.Length))
                    {
                        objList.Add(name);
                    }
                }
                return objList;
            }
            catch (Exception ex)
            {
                throw new Exception(string.Format("SFTP文件列表获取失败,原因:{0}", ex.Message));
            }
        }
        #endregion

        #region 移动SFTP文件
        /// <summary>
        /// 移动SFTP文件
        /// </summary>
        /// <param name="oldRemotePath">旧远程路径</param>
        /// <param name="newRemotePath">新远程路径</param>
        public void Move(string oldRemotePath, string newRemotePath)
        {
            try
            {
                Connect();
                sftp.RenameFile(oldRemotePath, newRemotePath);
                Disconnect();
            }
            catch (Exception ex)
            {
                throw new Exception(string.Format("SFTP文件移动失败,原因:{0}", ex.Message));
            }
        }
        #endregion

    }

}
测试代码片段如下:

        private void btn_Start_Click(object sender, EventArgs e)
        {
            //var test = new SFTPOperation("172.28.103.9", "22", "sftp02", "sftp02");
            var test = new SFTPOperation("172.28.103.9", "22", "sftp01", "sftp01");
            // 上传文件
            test.Put("D:/Download/ResourceSharp/test.txt", "china/in/test.txt");
            //// 获取文件列表
            //var list = test.GetFileList("china/in", "zip");
            //foreach (var name in list)
            //{
            //    // 获取文件
            //    test.Get("china/in/" , "D:/Download/ResourceSharp/" + name);
            //    Console.WriteLine(name);
            //}
            //// 删除文件
            //test.Delete("china/in/aaa.txt");
            //// 移动文件
            //test.Move("china/in/test.txt", "china/test.txt");
            
        }

完整测试代码下载地址: C# 通过 Renci.SshNet 实现SFTP数据传输


原文地址:http://blog.csdn.net/iuhiqnehc/article/details/21074427

相关实践学习
RocketMQ一站式入门使用
从源码编译、部署broker、部署namesrv,使用java客户端首发消息等一站式入门RocketMQ。
Sqoop 企业级大数据迁移方案实战
Sqoop是一个用于在Hadoop和关系数据库服务器之间传输数据的工具。它用于从关系数据库(如MySQL,Oracle)导入数据到Hadoop HDFS,并从Hadoop文件系统导出到关系数据库。 本课程主要讲解了Sqoop的设计思想及原理、部署安装及配置、详细具体的使用方法技巧与实操案例、企业级任务管理等。结合日常工作实践,培养解决实际问题的能力。本课程由黑马程序员提供。
目录
相关文章
|
4月前
|
JSON API 数据格式
网络数据传输工具 - curl
【1月更文挑战第18天】
48 0
|
4月前
|
安全 大数据 网络安全
Sqoop安全性:确保安全的数据传输
Sqoop安全性:确保安全的数据传输
|
4月前
|
缓存 网络协议 算法
UDP的可靠传输
UDP的可靠传输
61 0
|
12月前
|
网络协议 数据安全/隐私保护
FTP的和SNMP中的数据传输(知识点总结)
FTP的和SNMP中的数据传输(知识点总结)
118 0
|
存储 运维 网络安全
RH236GlusterFS-数据传输加密(练习)
RH236GlusterFS-数据传输加密(练习)
105 0
RH236GlusterFS-数据传输加密(练习)
|
存储 网络安全
03-rsync传输模式(本地传输、远程方式传输、守护进程模式传输)
1.Rsync传输模式 rsync大致使用三种主要的数据传输方式 本地方式 远程方式 守护进程 1.1.rsync语法格式 本地传输 rsync [option] src dest 远程通道传输
291 0
03-rsync传输模式(本地传输、远程方式传输、守护进程模式传输)
|
网络安全
04-rsync传输与ssh传输的区别
rsync传输与ssh传输的区别
151 0
04-rsync传输与ssh传输的区别
|
算法 数据安全/隐私保护
数据传输加密方式总结
一般来说,HTTP数据交互过程中,数据都是以密文形式传输的,数据加密也就成了目前web中比较常见的部分 对称加密 采用单钥密码系统的加密方法,同一个密钥可以同时用作信息的加密和解密,这种加密方法称为对称加密,也称为单密钥加密。
2243 0
|
算法 网络协议 UED
镭速介绍关于高速数据传输!
高效快速的沟通一直是我们的必需品。随着互联网的速度越来越快,网络和分组协议需要升级。通信的骨干一直是TCP和UDP协议。由于每个数据包确认的开销,TCP因可靠和慢速通信而闻名。UDP是防火和遗忘协议,不保证可靠的数据包传输。
2570 0