C#实现Linux登录和文件传输（Routrek.granados和Renci.SshNet的ssh、scp封装）
2012-05-24 09:39
866 查看
资源链接：http://download.csdn.net/detail/w565911788/4325423
using System;
using Renci.SshNet;
using System.Threading;
using System.Diagnostics;
using System.Net;
using System.Net.Sockets;
using Routrek.Crypto;
using Routrek.SSHC;
using Routrek.SSHCV1;
using Routrek.SSHCV2;
using Routrek.Toolkit;
using Routrek.PKI;
using System.Text;
namespace WugSshLib
{
/// <summary>
/// ssh协议
/// </summary>
public class SshReader : ISSHConnectionEventReceiver, ISSHChannelEventReceiver
{
public SSHConnection _conn;
public SSHChannel _pf;
public bool _ready;
public string msg = "";
private SSHConnectionParameter f = new SSHConnectionParameter();
private string host, username, password;
private int port;
private Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
//private System.Timers.Timer timer;
public SshReader(string host, int port, string username, string password)
{
this.host = host;
this.port = port;
this.username = username;
this.password = password;
}
public SshReader()
{
// TODO: Complete member initialization
}
public void OpenConnect()
{
f.UserName = username;
f.Password = password;
f.Protocol = SSHProtocol.SSH2;
f.AuthenticationType = AuthenticationType.Password;
f.WindowSize = 0x1000;
s.Connect(new IPEndPoint(IPAddress.Parse(host), port));
_conn = SSHConnection.Connect(f, this, s);
this._pf = _conn.OpenShell(this);
SSHConnectionInfo ci = _conn.ConnectionInfo;
}
public void CloseConnect()
{
this.msg = "";
this._pf.Close();
this._conn.Close();
this.s.Close();
}
public void WaitString(string s,int time)
{
int count = 0;
Thread.Sleep(100);
while (true)
{
if (this.msg.IndexOf(s) > 0)
{
return;
}
if (count > 99999)
{
Thread.Sleep(time);
return;
}
count++;
//timer = new System.Timers.Timer(10);
//timer.Elapsed += new ElapsedEventHandler(timer_Elapsed);
//timer.Enabled = true;
}
}
//private void timer_Elapsed(object sender, ElapsedEventArgs e)
//{
// Thread.CurrentThread.IsBackground = false;
// timer.Enabled = false;
//}
public void clearMsg()
{
int start = this.msg.IndexOf("\n");
int end = this.msg.LastIndexOf("\r");
try
{
if (start >= 0 && start <= end)
{
this.msg = this.msg.Remove(end).Remove(0, start + 1);
//this.msg = this.msg.Remove(0, start + 1);
}
}
catch { }
}
public void InputCommand(string command)
{
this.msg = "";
byte[] data = (new UnicodeEncoding()).GetBytes(command + "\n");
this._pf.Transmit(data);
}
public void OnData(byte[] data, int offset, int length)
{
System.Console.Write(Encoding.ASCII.GetString(data, offset, length));
msg += Encoding.ASCII.GetString(data, offset, length);
}
public void OnDebugMessage(bool always_display, byte[] data)
{
Debug.WriteLine("DEBUG: " + Encoding.ASCII.GetString(data));
}
public void OnIgnoreMessage(byte[] data)
{
Debug.WriteLine("Ignore: " + Encoding.ASCII.GetString(data));
}
public void OnAuthenticationPrompt(string[] msg)
{
Debug.WriteLine("Auth Prompt " + msg[0]);
}
public void OnError(Exception error, string msg)
{
Debug.WriteLine("ERROR: " + msg);
}
public void OnChannelClosed()
{
Debug.WriteLine("Channel closed");
_conn.Disconnect("");
//_conn.AsyncReceive(this);
}
public void OnChannelEOF()
{
_pf.Close();
Debug.WriteLine("Channel EOF");
}
public void OnExtendedData(int type, byte[] data)
{
Debug.WriteLine("EXTENDED DATA");
}
public void OnConnectionClosed()
{
Debug.WriteLine("Connection closed");
}
public void OnUnknownMessage(byte type, byte[] data)
{
Debug.WriteLine("Unknown Message " + type);
}
public void OnChannelReady()
{
_ready = true;
}
public void OnChannelError(Exception error, string msg)
{
Debug.WriteLine("Channel ERROR: " + msg);
}
public void OnMiscPacket(byte type, byte[] data, int offset, int length)
{
}
public PortForwardingCheckResult CheckPortForwardingRequest(string host, int port, string originator_host, int originator_port)
{
PortForwardingCheckResult r = new PortForwardingCheckResult();
r.allowed = true;
r.channel = this;
return r;
}
public void EstablishPortforwarding(ISSHChannelEventReceiver rec, SSHChannel channel)
{
_pf = channel;
}
}
/// <summary>
/// 文件传输
/// </summary>
public class ScpClient_Ex
{
private string dir_upload;
private string file_upload;
private string upload_name;
private string dir_download;
private string file_download;
private string download_name;
private ScpClient scpClient;
public string msg;
public string Dir_Upload
{
set
{
this.dir_upload = value;
}
get
{
return this.dir_upload;
}
}
public string File_Upload
{
set
{
this.file_upload = value;
}
get
{
return this.file_upload;
}
}
public string Dir_Download
{
set
{
this.dir_download = value;
}
get
{
return this.dir_download;
}
}
public string File_Download
{
set
{
this.file_download = value;
}
get
{
return this.file_download;
}
}
public string Upload_Name
{
set
{
this.upload_name = value;
}
get
{
return this.upload_name;
}
}
public string Download_Name
{
set
{
this.download_name = value;
}
get
{
return this.download_name;
}
}
public ScpClient_Ex(string host, int port, string username, string password)
{
dir_upload = "";
file_upload = "";
dir_download = "";
file_download = "";
upload_name = "";
download_name = "";
scpClient = new ScpClient(host, port, username, password);
scpClient.BufferSize = 1024;
}
public void DownloadFile()
{
if (!download_name.Equals(""))
{
try
{
System.IO.FileInfo fi = new System.IO.FileInfo(file_download);
this.scpClient.Connect();
this.scpClient.Download(download_name, fi);
this.scpClient.Disconnect();
Thread.Sleep(100);
}
catch (Exception ex)
{
this.msg = "DownloadFile Error: " + ex.Message;
}
}
else
{
this.msg = "下载文件路径错误或者目标路径名不存在！";
}
}
//public void DownloadToDir()
//{
// if (!download_name.Equals("") && System.IO.Directory.Exists(dir_download))
// {
// try
// {
// System.IO.DirectoryInfo dir = new System.IO.DirectoryInfo(dir_download);
// this.scpClient.Connect();
// this.scpClient.Download(download_name, dir);
// this.scpClient.Disconnect();
// Thread.Sleep(100);
// }
// catch (Exception ex)
// {
// this.msg = "DownloadDirectory Error: " + ex.Message;
// }
// }
// else
// {
// this.msg = "下载目录路径错误或者目标路径名不存在！";
// }
//}
public void UploadFile()
{
if (!upload_name.Equals("") && System.IO.File.Exists(file_upload))
{
try
{
System.IO.FileInfo fi = new System.IO.FileInfo(file_upload);
this.scpClient.Connect();
this.scpClient.Upload(fi, upload_name);
this.scpClient.Disconnect();
Thread.Sleep(100);
}
catch (Exception ex)
{
this.msg = "UploadFile Error: " + ex.Message;
}
}
else
{
this.msg = "上传文件路径不存在或者目标文件名错误！";
}
}
public void UploadFromDir()
{
if (!upload_name.Equals("") && System.IO.Directory.Exists(dir_upload))
{
try
{
System.IO.DirectoryInfo dir = new System.IO.DirectoryInfo(dir_upload);
this.scpClient.Connect();
this.scpClient.Upload(dir, upload_name);
this.scpClient.Disconnect();
Thread.Sleep(100);
}
catch (Exception ex)
{
this.msg = "UploadDirectory Error: " + ex.Message;
}
}
else
{
this.msg = "上传目录路径不存在或者目标目录名错误！";
}
}
~ScpClient_Ex()
{
this.scpClient.Dispose();
}
}
}
using System;
using Renci.SshNet;
using System.Threading;
using System.Diagnostics;
using System.Net;
using System.Net.Sockets;
using Routrek.Crypto;
using Routrek.SSHC;
using Routrek.SSHCV1;
using Routrek.SSHCV2;
using Routrek.Toolkit;
using Routrek.PKI;
using System.Text;
namespace WugSshLib
{
/// <summary>
/// ssh协议
/// </summary>
public class SshReader : ISSHConnectionEventReceiver, ISSHChannelEventReceiver
{
public SSHConnection _conn;
public SSHChannel _pf;
public bool _ready;
public string msg = "";
private SSHConnectionParameter f = new SSHConnectionParameter();
private string host, username, password;
private int port;
private Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
//private System.Timers.Timer timer;
public SshReader(string host, int port, string username, string password)
{
this.host = host;
this.port = port;
this.username = username;
this.password = password;
}
public SshReader()
{
// TODO: Complete member initialization
}
public void OpenConnect()
{
f.UserName = username;
f.Password = password;
f.Protocol = SSHProtocol.SSH2;
f.AuthenticationType = AuthenticationType.Password;
f.WindowSize = 0x1000;
s.Connect(new IPEndPoint(IPAddress.Parse(host), port));
_conn = SSHConnection.Connect(f, this, s);
this._pf = _conn.OpenShell(this);
SSHConnectionInfo ci = _conn.ConnectionInfo;
}
public void CloseConnect()
{
this.msg = "";
this._pf.Close();
this._conn.Close();
this.s.Close();
}
public void WaitString(string s,int time)
{
int count = 0;
Thread.Sleep(100);
while (true)
{
if (this.msg.IndexOf(s) > 0)
{
return;
}
if (count > 99999)
{
Thread.Sleep(time);
return;
}
count++;
//timer = new System.Timers.Timer(10);
//timer.Elapsed += new ElapsedEventHandler(timer_Elapsed);
//timer.Enabled = true;
}
}
//private void timer_Elapsed(object sender, ElapsedEventArgs e)
//{
// Thread.CurrentThread.IsBackground = false;
// timer.Enabled = false;
//}
public void clearMsg()
{
int start = this.msg.IndexOf("\n");
int end = this.msg.LastIndexOf("\r");
try
{
if (start >= 0 && start <= end)
{
this.msg = this.msg.Remove(end).Remove(0, start + 1);
//this.msg = this.msg.Remove(0, start + 1);
}
}
catch { }
}
public void InputCommand(string command)
{
this.msg = "";
byte[] data = (new UnicodeEncoding()).GetBytes(command + "\n");
this._pf.Transmit(data);
}
public void OnData(byte[] data, int offset, int length)
{
System.Console.Write(Encoding.ASCII.GetString(data, offset, length));
msg += Encoding.ASCII.GetString(data, offset, length);
}
public void OnDebugMessage(bool always_display, byte[] data)
{
Debug.WriteLine("DEBUG: " + Encoding.ASCII.GetString(data));
}
public void OnIgnoreMessage(byte[] data)
{
Debug.WriteLine("Ignore: " + Encoding.ASCII.GetString(data));
}
public void OnAuthenticationPrompt(string[] msg)
{
Debug.WriteLine("Auth Prompt " + msg[0]);
}
public void OnError(Exception error, string msg)
{
Debug.WriteLine("ERROR: " + msg);
}
public void OnChannelClosed()
{
Debug.WriteLine("Channel closed");
_conn.Disconnect("");
//_conn.AsyncReceive(this);
}
public void OnChannelEOF()
{
_pf.Close();
Debug.WriteLine("Channel EOF");
}
public void OnExtendedData(int type, byte[] data)
{
Debug.WriteLine("EXTENDED DATA");
}
public void OnConnectionClosed()
{
Debug.WriteLine("Connection closed");
}
public void OnUnknownMessage(byte type, byte[] data)
{
Debug.WriteLine("Unknown Message " + type);
}
public void OnChannelReady()
{
_ready = true;
}
public void OnChannelError(Exception error, string msg)
{
Debug.WriteLine("Channel ERROR: " + msg);
}
public void OnMiscPacket(byte type, byte[] data, int offset, int length)
{
}
public PortForwardingCheckResult CheckPortForwardingRequest(string host, int port, string originator_host, int originator_port)
{
PortForwardingCheckResult r = new PortForwardingCheckResult();
r.allowed = true;
r.channel = this;
return r;
}
public void EstablishPortforwarding(ISSHChannelEventReceiver rec, SSHChannel channel)
{
_pf = channel;
}
}
/// <summary>
/// 文件传输
/// </summary>
public class ScpClient_Ex
{
private string dir_upload;
private string file_upload;
private string upload_name;
private string dir_download;
private string file_download;
private string download_name;
private ScpClient scpClient;
public string msg;
public string Dir_Upload
{
set
{
this.dir_upload = value;
}
get
{
return this.dir_upload;
}
}
public string File_Upload
{
set
{
this.file_upload = value;
}
get
{
return this.file_upload;
}
}
public string Dir_Download
{
set
{
this.dir_download = value;
}
get
{
return this.dir_download;
}
}
public string File_Download
{
set
{
this.file_download = value;
}
get
{
return this.file_download;
}
}
public string Upload_Name
{
set
{
this.upload_name = value;
}
get
{
return this.upload_name;
}
}
public string Download_Name
{
set
{
this.download_name = value;
}
get
{
return this.download_name;
}
}
public ScpClient_Ex(string host, int port, string username, string password)
{
dir_upload = "";
file_upload = "";
dir_download = "";
file_download = "";
upload_name = "";
download_name = "";
scpClient = new ScpClient(host, port, username, password);
scpClient.BufferSize = 1024;
}
public void DownloadFile()
{
if (!download_name.Equals(""))
{
try
{
System.IO.FileInfo fi = new System.IO.FileInfo(file_download);
this.scpClient.Connect();
this.scpClient.Download(download_name, fi);
this.scpClient.Disconnect();
Thread.Sleep(100);
}
catch (Exception ex)
{
this.msg = "DownloadFile Error: " + ex.Message;
}
}
else
{
this.msg = "下载文件路径错误或者目标路径名不存在！";
}
}
//public void DownloadToDir()
//{
// if (!download_name.Equals("") && System.IO.Directory.Exists(dir_download))
// {
// try
// {
// System.IO.DirectoryInfo dir = new System.IO.DirectoryInfo(dir_download);
// this.scpClient.Connect();
// this.scpClient.Download(download_name, dir);
// this.scpClient.Disconnect();
// Thread.Sleep(100);
// }
// catch (Exception ex)
// {
// this.msg = "DownloadDirectory Error: " + ex.Message;
// }
// }
// else
// {
// this.msg = "下载目录路径错误或者目标路径名不存在！";
// }
//}
public void UploadFile()
{
if (!upload_name.Equals("") && System.IO.File.Exists(file_upload))
{
try
{
System.IO.FileInfo fi = new System.IO.FileInfo(file_upload);
this.scpClient.Connect();
this.scpClient.Upload(fi, upload_name);
this.scpClient.Disconnect();
Thread.Sleep(100);
}
catch (Exception ex)
{
this.msg = "UploadFile Error: " + ex.Message;
}
}
else
{
this.msg = "上传文件路径不存在或者目标文件名错误！";
}
}
public void UploadFromDir()
{
if (!upload_name.Equals("") && System.IO.Directory.Exists(dir_upload))
{
try
{
System.IO.DirectoryInfo dir = new System.IO.DirectoryInfo(dir_upload);
this.scpClient.Connect();
this.scpClient.Upload(dir, upload_name);
this.scpClient.Disconnect();
Thread.Sleep(100);
}
catch (Exception ex)
{
this.msg = "UploadDirectory Error: " + ex.Message;
}
}
else
{
this.msg = "上传目录路径不存在或者目标目录名错误！";
}
}
~ScpClient_Ex()
{
this.scpClient.Dispose();
}
}
}
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- Linux多台服务器间SSH免密码登录配置及利用scp 两个服务器文件传输和crontab定时任务的设置
- C# 通过 Renci.SshNet 实现SFTP数据传输
- C# 通过 Renci.SshNet 实现SFTP数据传输
- linux主机间实现ssh/scp/rsync免密码登录
- 定制微型linux实现启用虚拟终端基于帐号密码登录、提供ssh服务，提供Web服务
- 安装、设置和使用SSH Secure shell 实现windows 登录linux
- Linux实现SSH无密码登录
- Linux使用ssh公钥实现免密码登录实例
- 用python的控件wx实现了windows通过ssh登录linux(学习一)
- 电脑（Linux/Windows）使用SSH远程登录安卓（Android）手机实现无线传输和管理文件（图文详解）
- 详解Linux下SSH远程文件传输命令scp
- ssh-keygen+ssh-copy-id 在linux下实现ssh无密码登录访问
- Windows使用SSH Secure Shell实现免密码登录Linux的方法以及使用scp2命令免密码下载文件
- linux内网SSH，SCP登录其他服务器Add correct host key in /root/.ssh/known_hosts to get rid of this message
- ssh实现Linux主机间的远程文件传输
- asp.net c#采集需要登录页面的实现原理及代码
- 详解Linux下SSH远程文件传输命令scp
- 黑马程序员 C#学习笔记③ ADO.NET实现登录案例
- 详解Linux下SSH远程文件传输命令scp
- linux下ssh远程登录/scp远程复制文件/rsync远程同步命令的自动登录