使用go语言的第三方包：github.com/pkg/sftp和golang.org/x/crypto/ssh实现文件和文件夹传输。

1、创建connect方法：

func connect(user, password, host string, port int) (*sftp.Client, error) {

var (

auth []ssh.AuthMethod

addr string

clientConfig *ssh.ClientConfig

sshClient *ssh.Client

sftpClient *sftp.Client

err error

)

// get auth method

auth = make([]ssh.AuthMethod, 0)

auth = append(auth, ssh.Password(password))

clientConfig = &ssh.ClientConfig{

User: user,

Auth: auth,

Timeout: 30 * time.Second,

HostKeyCallback: ssh.InsecureIgnoreHostKey(), //ssh.FixedHostKey(hostKey),

}

// connet to ssh

addr = fmt.Sprintf("%s:%d", host, port)

if sshClient, err = ssh.Dial("tcp", addr, clientConfig); err != nil {

return nil, err

}

// create sftp client

if sftpClient, err = sftp.NewClient(sshClient); err != nil {

return nil, err

}

return sftpClient, nil

}

2、上传文件

func uploadFile(sftpClient *sftp.Client, localFilePath string, remotePath string) {

srcFile, err := os.Open(localFilePath)

if err != nil {

fmt.Println("os.Open error : ", localFilePath)

log.Fatal(err)

}

defer srcFile.Close()

var remoteFileName = path.Base(localFilePath)

dstFile, err := sftpClient.Create(path.Join(remotePath, remoteFileName))

if err != nil {

fmt.Println("sftpClient.Create error : ", path.Join(remotePath, remoteFileName))

log.Fatal(err)

}

defer dstFile.Close()

ff, err := ioutil.ReadAll(srcFile)

if err != nil {

fmt.Println("ReadAll error : ", localFilePath)

log.Fatal(err)

}

dstFile.Write(ff)

fmt.Println(localFilePath + " copy file to remote server finished!")

}

3、上传文件夹

func uploadDirectory(sftpClient *sftp.Client, localPath string, remotePath string) {

localFiles, err := ioutil.ReadDir(localPath)

if err != nil {

log.Fatal("read dir list fail ", err)

}

for _, backupDir := range localFiles {

localFilePath := path.Join(localPath, backupDir.Name())

remoteFilePath := path.Join(remotePath, backupDir.Name())

if backupDir.IsDir() {

sftpClient.Mkdir(remoteFilePath)

uploadDirectory(sftpClient, localFilePath, remoteFilePath)

} else {

uploadFile(sftpClient, path.Join(localPath, backupDir.Name()), remotePath)

}

}

fmt.Println(localPath + " copy directory to remote server finished!")

}

4、上传测试

func DoBackup(host string, port int, userName string, password string, localPath string, remotePath string) {

var (

err error

sftpClient *sftp.Client

)

start := time.Now()

sftpClient, err = connect(userName, password, host, port)

if err != nil {

log.Fatal(err)

}

defer sftpClient.Close()

_, errStat := sftpClient.Stat(remotePath)

if errStat != nil {

log.Fatal(remotePath + " remote path not exists!")

}

backupDirs, err := ioutil.ReadDir(localPath)

if err != nil {

log.Fatal(localPath + " local path not exists!")

}

uploadDirectory(sftpClient, localPath, remotePath)

elapsed := time.Since(start)

fmt.Println("elapsed time : ", elapsed)

}

补充：go实现ssh远程机器并传输文件

核心依赖包：

golang.org/x/crypto/ssh

github.com/pkg/sftp

其中golang.org/x/crypto/ssh 可从github上下载，

ssh连接源码(这里是根据秘钥连接):

var keypath = "key/id_rsa"

//获取秘钥

func publicKey(path string) ssh.AuthMethod {

keypath, err := homedir.Expand(path)

if err != nil {

fmt.Println("获取秘钥路径失败", err)

}

key, err1 := ioutil.ReadFile(keypath)

if err1 != nil {

fmt.Println("读取秘钥失败", err1)

}

signer, err2 := ssh.ParsePrivateKey(key)

if err2 != nil {

fmt.Println("ssh 秘钥签名失败", err2)

}

return ssh.PublicKeys(signer)

}

//获取ssh连接

func GetSSHConect(ip, user string, port int) (*ssh.Client) {

con := &ssh.ClientConfig{

User: user,

Auth: []ssh.AuthMethod{publicKey(keypath)},

HostKeyCallback: func(hostname string, remote net.Addr, key ssh.PublicKey) error {

return nil

},

}

addr := fmt.Sprintf("%s:%d", ip, port)

client, err := ssh.Dial("tcp", addr, con)

if err != nil {

fmt.Println("Dail failed: ", err)

panic(err)

}

return client

}

// 远程执行脚本

func Exec_Task(ip, user, localpath, remotepath string) int {

port := 22

client := GetSSHConect(ip, user, port)

UploadFile(ip, user, localpath, remotepath, port)

session, err := client.NewSession()

if err != nil {

fmt.Println("创建会话失败", err)

panic(err)

}

defer session.Close()

remoteFileName := path.Base(localpath)

dstFile := path.Join(remotepath, remoteFileName)

err1 := session.Run(fmt.Sprintf("/usr/bin/sh %s", dstFile))

if err1 != nil {

fmt.Println("远程执行脚本失败", err1)

return 2

} else {

fmt.Println("远程执行脚本成功")

return 1

}

}

文件传输功能：

//获取ftp连接

func getftpclient(client *ssh.Client) (*sftp.Client) {

ftpclient, err := sftp.NewClient(client)

if err != nil {

fmt.Println("创建ftp客户端失败", err)

panic(err)

}

return ftpclient

}

//上传文件

func UploadFile(ip, user, localpath, remotepath string, port int) {

client := GetSSHConect(ip, user, port)

ftpclient := getftpclient(client)

defer ftpclient.Close()

remoteFileName := path.Base(localpath)

fmt.Println(localpath, remoteFileName)

srcFile, err := os.Open(localpath)

if err != nil {

fmt.Println("打开文件失败", err)

panic(err)

}

defer srcFile.Close()

dstFile, e := ftpclient.Create(path.Join(remotepath, remoteFileName))

if e != nil {

fmt.Println("创建文件失败", e)

panic(e)

}

defer dstFile.Close()

buffer := make([]byte, 1024)

for {

n, err := srcFile.Read(buffer)

if err != nil {

if err == io.EOF {

fmt.Println("已读取到文件末尾")

break

} else {

fmt.Println("读取文件出错", err)

panic(err)

}

}

dstFile.Write(buffer[:n])

//注意，由于文件大小不定，不可直接使用buffer，否则会在文件末尾重复写入，以填充1024的整数倍

}

fmt.Println("文件上传成功")

}

//文件下载

func DownLoad(ip, user, localpath, remotepath string, port int) {

client := GetSSHConect(ip, user, port)

ftpClient := getftpclient(client)

defer ftpClient.Close()

srcFile, err := ftpClient.Open(remotepath)

if err != nil {

fmt.Println("文件读取失败", err)

panic(err)

}

defer srcFile.Close()

localFilename := path.Base(remotepath)

dstFile, e := os.Create(path.Join(localpath, localFilename))

if e != nil {

fmt.Println("文件创建失败", e)

panic(e)

}

defer dstFile.Close()

if _, err1 := srcFile.WriteTo(dstFile); err1 != nil {

fmt.Println("文件写入失败", err1)

panic(err1)

}

fmt.Println("文件下载成功")

}

以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。如有错误或未考虑完全的地方，望不吝赐教。

最近用到SFTP上传文件查找了一些资料后自己做了一点总结,方便以后的查询

/**

* 将文件上传到服务器

*

* @param filePath

* 文件路径

* @param channelSftp

* channelSftp对象

* @return

*/

public static boolean uploadFile(String filePath, ChannelSftp channelSftp) {

OutputStream outstream = null;

InputStream instream = null;

boolean successFlag = false;

try {

File isfile = new File(filePath);

if (isfile.isFile()) {

outstream = channelSftp.put(isfile.getName());

File file = new File(filePath);

if (file.exists()) {

instream = new FileInputStream(file);

byte b[] = new byte[1024];

int n;

while ((n = instream.read(b)) != -1) {

outstream.write(b, 0, n);

}

outstream.flush();

}

successFlag = true;

}

} catch (Exception e) {

e.printStackTrace();

} finally {

try {

if (instream != null) {

instream.close();

}

if (outstream != null) {

outstream.close();

}

} catch (IOException e) {

e.printStackTrace();

}

}

return successFlag;

}

private static Session initJschSession()

throws JSchException {

int ftpPort = 0;

String ftpHost = "";

String port = "00"; //sftp的端口号

String ftpUserName = ""; //用户名

String ftpPassword = ""; //链接的密码

String privateKey = ""; //

String passphrase = "";

if (port != null && !port.equals("")) {

ftpPort = Integer.valueOf(port);

}

JSch jsch = new JSch(); // 创建JSch对象

if (StringUtils.isNotBlank(privateKey)

&& StringUtils.isNotBlank(passphrase)) {

jsch.addIdentity(privateKey, passphrase);

}

if (StringUtils.isNotBlank(privateKey)

&& StringUtils.isBlank(passphrase)) {

jsch.addIdentity(privateKey);

}

jsch.getSession(ftpUserName, ftpHost, ftpPort);

Session session = jsch.getSession(ftpUserName, ftpHost, ftpPort); // 根据用户名，主机ip，端口获取一个Session对象

if (StringUtils.isNotBlank(ftpPassword)) {

session.setPassword(ftpPassword); // 设置密码

}

return session;

}

/**

* 获取ChannelSftp链接

*

* @param timeout

* 超时时间

* @return 返回ChannelSftp对象

* @throws JSchException

*/

public static ChannelSftp getChannelSftp(Session session, int timeout)

throws JSchException {

Channel channel = null;

Properties config = new Properties();

config.put("StrictHostKeyChecking", "no");

session.setConfig(config); // 为Session对象设置properties

session.setTimeout(timeout); // 设置timeout时间

session.connect(); // 通过Session建立链接

channel = session.openChannel("sftp"); // 打开SFTP通道

channel.connect(); // 建立SFTP通道的连接

return (ChannelSftp) channel;

}

/**

* 断开sftp链接

*

* @param session

* 会话

* @param channel

* 通道

*/

public static void closeConnection(Channel channel, Session session) {

try {

if (session != null) {

session.disconnect(); //关闭session链接

}

if (channel != null) {

channel.disconnect(); //断开连接

}

} catch (Exception e) {

e.printStackTrace();

}

}

这里的用户名密码都是自己设置,这里的方法进行了简单的封装,方便使用

sftp上传到远程服务器

开发遇到一个需求,需要将图片通过sftp上传到远程服务器上,之前没用过这个功能,折腾了我好几天才搞定,下面记录下我的处理方法: $sftp = 'ssh2.sftp://';//连接sftp $con ...

WPF上传文件到服务器

利用WebClient 上传文件到服务器 创建一个空网站,创建一个UploadFile.aspx项, 服务器报500错误:检查文件保存路径是否存在,检查文件大小限制 protected void Pa ...

Android上传文件至服务器(上)

每一次都不能上首页,真悲催..管理员让我上一次首页? 很多时候我更愿意一个人写代码,与其在垃圾代码上改改改,我更愿意直接重构. 整洁的代码简单直接.整洁的代码如同优美的散文.整洁的代码从不隐藏设计者的 ...

android上传文件到服务器

package com.spring.sky.image.upload.network; import java.io.DataOutputStream; import java.io.File; i ...

SFTP 上传文件夹

使用sftp上传文件夹时若使用如下命令并不work: put /media/Research/GWAS_Class/* Desktop/ 此时,需要添加一个参数 -r, 另外在目标文件夹下面建立一个同 ...

Android端通过HttpURLConnection上传文件到服务器

Android端通过HttpURLConnection上传文件到服务器 一:实现原理 最近在做Android客户端的应用开发,涉及到要把图片上传到后台服务器中,自己选择了做Spring3 MVC HT ...

joomla安装插件报错：上传文件到服务器发生了一个错误。 过小的PHP文件上传尺寸

在安装joomla的AKeeba插件的时候报错如下:上传文件到服务器发生了一个错误. 过小的PHP文件上传尺寸.解决方法是修改php.ini文件,打开文件后搜索upload_max_filesize! ...

android -上传文件到服务器

android上传文件到服务器       重点:最好是设置好content-type这些参数的配置!     package com.spring.sky.image.upload.network; ...

用winscp从本地上传文件到服务器上出现复制文件到远端时错误。

用winscp从本地上传文件到服务器上出现复制文件到远端时错误. 错误码:4 服务器返回的错误消息:write failed 报错如下图所示: 分析过程: 1.刚开始以为是权限不够,后面上网查了一下是 ...

随机推荐

Android Studio快捷键

一.android studio 默认快捷键 刚开始接触一款开发软件,想必很想了解它的快捷方式,这会对你的编程起到很好的帮助,提高工作效率,接下来给你介绍下Android Studio一些常用的快 ...

mybatis 中的where标签

mybatis中的where标签可以去除 开头的 and 或者 or 但是放在后面的不行 失败的:

SSH-Hibernate+Struts2+Spring的股票项目整合

创建项目之前:我们需要导入我们需要的Hibernate和Struts2和Spring的相关架包.(博客自创,如有问题请留言博主,拒绝盗版,支持正版http://www.cnblogs.com/WuXu ...

使用Emmet(前身Zen Coding)加速Web前端开发

Emmet插件以前被称作为Zen Coding,是一个文本编辑器的插件,它可以帮助您快速编写HTML和CSS代码,从而加速Web前端开发.早在2009年,Sergey Chikuyonok写过一篇文章 ...

java jdbc 连接mysql 数据库

JDBC连接MySQL 加载及注册JDBC驱动程序 Class.forName("com.mysql.jdbc.Driver"); Class.forName("com. ...

Hadoop(六)之HDFS的存储原理(运行原理)

前言 其实说到HDFS的存储原理,无非就是读操作和写操作,那接下来我们详细的看一下HDFS是怎么实现读写操作的! 一.HDFS读取过程 1)客户端通过调用FileSystem对象的open()来读取希 ...

[la P5031&hdu P3726] Graph and Queries

[la P5031&hdu P3726] Graph and Queries Time Limit: 10000/5000 MS (Java/Others)    Memory Limit: ...

查看mysql的版本号

查看mysql的版本号 1.1 在命令行登录mysql,即可看到mysql的版本号 [root@heyong ~]# mysql -uroot -p Enter password: Welcome t ...

MySQL Transaction--MySQL与SQL Server在可重复读事务隔离级别上的差异

MySQL和SQL Server两种数据库在REPEATABLE-READ事务隔离级别实现方式不同,导致使用上也存在差异. 在MySQL中,默认使用REPEATABLE-READ事务隔离级别,MySQ ...

20155239 《网络对抗》Exp4 恶意代码分析

20155239 Exp4 恶意代码分析 使用schtasks指令监控系统运行 先在C盘目录下建立一个netstatlog.bat文件,用来将记录的联网结果格式化输出到nets ...

上传文件到远程服务器的命令 内容精选

换一换

将文件上传至Windows云服务器一般会采用MSTSC远程桌面连接的方式。本节为您介绍本地Windows计算机通过远程桌面连接，上传文件至Windows云服务器的操作方法。Windows云服务器可以访问公网。在本地Windows计算机上，单击“开始”，在出现的“搜索程序和文件”输入框中输入mstsc。弹出远程桌面连接对话框。弹出远程桌面连

将文件上传至Windows云服务器一般会采用MSTSC远程桌面连接的方式。本节为您介绍本地Windows计算机通过远程桌面连接，上传文件至Windows云服务器的操作方法。Windows云服务器可以访问公网。在本地Windows计算机上，单击“开始”，在出现的“搜索程序和文件”输入框中输入mstsc。弹出远程桌面连接对话框。弹出远程桌面连

上传文件到远程服务器的命令 相关内容

安装传输工具在本地主机和Windows云服务器上分别安装数据传输工具，将文件上传到云服务器。例如QQ.exe。在本地主机和Windows云服务器上分别安装数据传输工具，将文件上传到云服务器。例如QQ.exe。本地磁盘映射(推荐使用)使用远程桌面连接MSTSC方式进行数据传输。该方式不支持断点续传，可能存在传输中断的情况，因此不建议上传大文

本节操作以CentOS操作系统为例，介绍配置SFTP、使用SFTP上传或下载文件、文件夹的操作步骤。以root用户登录云服务器。执行以下命令查看ssh版本，OpenSSH版本大于等于4.8p1。ssh -V回显信息如下所示：# OpenSSH_7.4p1, OpenSSL 1.0.2k-fips 26 Jan 2017ssh -V回显信息

上传文件到远程服务器的命令 更多内容

怎样上传文件到Windows操作系统云服务器？安装传输工具在本地主机和Windows云服务器上分别安装数据传输工具，将文件上传到云服务器。例如QQ.exe。在本地主机和Windows云服务器上分别安装数据传输工具，将文件上传到云服务器。例如QQ.exe。本地磁盘映射(推荐使用)使用远程桌面连接MSTSC方式进行数据传输。该方式不支持断点续

本节操作介绍如何在Windows操作系统的本地主机上使用FTP上传文件到云服务器。已在待上传文件的云服务器中搭建 FTP 服务。如果您的云服务器为 Windows 操作系统，具体操作请参考 搭建FTP 站点(Windows)。如果您的云服务器为 Linux 操作系统，具体操作请参考 搭建FTP 站点(Linux)。在Windows本地主机

WinSCP工具可以实现在本地与远程计算机之间安全地复制文件。与使用FTP上传代码相比，通过 WinSCP 可以直接使用服务器账户密码访问服务器，无需在服务器端做任何配置。通常本地Windows计算机将文件上传至Linux服务器一般会采用WinSCP工具。本节为您介绍本地Windows计算机使用WinSCP工具，上传文件至Linux云服务

将文件上传至Linux服务器一般会采用WinSCP工具。本节为您介绍本地Windows计算机使用WinSCP工具，上传文件至Linux云服务器的操作方法。以下以CentOS 7.2为例。Linux云服务器可以访问公网。下载 WinSCP 客户端并安装。单击这里下载：https://winscp.net/eng/docs/lang:chs。

本节操作介绍本地Linux操作系统主机通过SCP向Linux云服务器传输文件的操作步骤。登录管理控制台，在ECS列表页面记录待上传文件的云服务器的弹性公网IP。上传文件在本地Linux操作系统主机上执行以下命令，传输文件到Linux操作系统云服务器。scp 本地主机文件地址 用户名@弹性公网IP:云服务器文件地址例如：将本地文件 /hom

为加强对系统数据的容灾管理，云堡垒机支持配置日志备份，提高审计数据安全性和系统可扩展性。本小节主要介绍如何在系统配置Syslog服务器参数，将日志远程备份至Syslog服务器。开启远程备份后，系统默认在每天零点备份前一天的系统数据。以天为单位自动备份，生成日志文件，并上传到Syslog服务器相应路径。支持备份至Syslog服务器的日志包括

工具中所有涉及上传文件功能的，如果需要上传的文件大于500MB或者解压后大于1GB，需要手动将文件上传至服务器，其他情况可通过Web界面上传功能上传。

如果待分析/待预检/待对齐/待重构的源码压缩包或软件包大于500MB或者解压后大于1GB，需要手动将源码或者软件包上传至服务器，其他情况可通过Web界面上传功能上传。

已成功登录Java性能分析。待安装Guardian的服务器已开启sshd。待安装Guardian的服务器已安装JRE，JRE版本要求为Huawei JDK 8或者Open JDK 8/11。Java性能分析优先选用非交互shell(non-interactive shell)中的JAVA_HOME环境变量所指定的JRE版本运行Guardi

连接远程主机和云命令行环境都提供了文件树操作能力，如：新建文件/目录、删除文件/目录、文件/目录重命名、上传下载文件等。连接远程主机场景下文件树操作的目标服务器是远程主机，云命令行环境则是对云环境的文件树进行操作。新建文件/目录方式1：选择目录节点 > 单击鼠标右键 > 单击新建文件。方式2：选择目录节点 > 在键盘上敲击快捷键Alt+N

已成功登录Java性能分析。待安装分析辅助软件的服务器已开启sshd。Java性能分析优先选用非交互shell(non-interactive shell)中的JAVA_HOME环境变量所指定的JRE版本运行分析辅助软件，其次选用非交互shell(non-interactive shell)中的PATH环境变量能发现的java命令运行分析