【Java工具类】（22）—服务器传文件工具类SCp和Sftp

Java工具类（22）—服务器传文件工具类SCp和Sftp

1、Scp

package com.awifi.capacity.docker.manager.utils;import ch.ethz.ssh2.Connection;
import ch.ethz.ssh2.SCPClient;
import lombok.extern.slf4j.Slf4j;import java.io.IOException;/**
* java服务器通过SCP上传文件至Linux服务器
*/
@Slf4jpublic class ScpClient {private static ScpClient instance;private String ip;private int port;private String name;private String password;/*** 私有化默认构造函数* 实例化对象只能通过getInstance*/public ScpClient(){}/*** 私有化有参构造函数* @param ip 服务器ip* @param port 服务器端口 22* @param name 登录名* @param password 登录密码*/private ScpClient(String ip, int port, String name, String password){this.ip = ip ;this.port = port;this.name = name;this.password = password;}public void upload(String ip,int port, String userName, String pwd,String localUrl, String dataServerDestDir) {Connection con = new Connection(ip,port);try {log.info("开始连接服务器");con.connect();boolean isAuthed = con.authenticateWithPassword(userName, pwd);if (!isAuthed) {log.info("连接服务器失败！");throw new IOException("Authentication failed.文件scp到数据服务器时发生异常");}SCPClient client = new SCPClient(con);log.info("连接服务器成功！");client.put(localUrl, dataServerDestDir);//本地文件scp到远程目录
//            client.get(dataServerDestDir + "00审计.zip", localDir);//远程的文件scp到本地目录con.close();log.info("scp上传文件结束");}  catch (Exception e) {e.printStackTrace();log.error("文件scp到数据服务器时发生异常" + e);}log.info("scp文件结束");}/*** 单例模式* 懒汉式* 线程安全* @return*/public static ScpClient getInstance(){if(null == instance){synchronized (ScpClient.class){if(null == instance){instance = new ScpClient();}}}return instance;}public static ScpClient getInstance(String ip, int port, String name, String password){if(null == instance){synchronized (ScpClient.class){if(null == instance){instance = new ScpClient(ip,port,name,password);}}}return instance;}public String getIp() {return ip;}public void setIp(String ip) {this.ip = ip;}public int getPort() {return port;}public void setPort(int port) {this.port = port;}public String getName() {return name;}public void setName(String name) {this.name = name;}public String getPassword() {return password;}public void setPassword(String password) {this.password = password;}
}

2、Sftp

package com.awifi.capacity.repository.provider.Util;import com.jcraft.jsch.*;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.io.IOUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;import java.io.*;
import java.util.Vector;/**
* FTP服务器工具类：
*      JSch类 通过 SFTP 协议上传文件到 freeSSHd 服务器
*
* @author  zhangxin
* @time    2019-05-28
* @vision  1.0.0
*/
@Slf4j
public class SftpUtil {private static Integer lock =11;private static SftpUtil sftpUtil;public static SftpUtil getInstance(String username, String password, String host, int port){log.info("尝试连接服务器 {} {} {} {}",host,port,username,password);if(sftpUtil ==null) {synchronized (SftpUtil.class) {if(sftpUtil==null) {sftpUtil = new SftpUtil(username, password, host, port);sftpUtil.login();}}}if(!sftpUtil.session.isConnected()){log.error("sftp 的会话已经断开了 !!!!!!!!!!!!!!!!!!");sftpUtil.login();}return sftpUtil;}private Logger logger = LoggerFactory.getLogger(SftpUtil.class);private ChannelSftp sftp;private Session session;/*** 用户名*/private String username;/*** 密码*/private String password;/*** 秘钥*/private String privateKey;/*** FTP服务器Ip*/private String host;/*** FTP服务器端口号*/private int port;/*** 构造器：基于密码认证sftp对象* @param username  用户名* @param password  密码* @param host      服务器ip* @param port      服务器端口号*/public SftpUtil(String username, String password, String host, int port){this.username = username;this.password = password;this.host = host;this.port = port;}/*** 构造器：基于秘钥认证sftp对象* @param username   用户名* @param privateKey 秘钥* @param host       服务器ip* @param port       服务器端口号*/public SftpUtil(String username, String privateKey, int port, String host){this.username = username;this.privateKey = privateKey;this.host = host;this.port = port;}/*** 连接SFTP服务器*/public void login(){log.info("开始尝试登录sftp");JSch jsch = new JSch();try{if(privateKey != null){//设置登陆主机的秘钥jsch.addIdentity(privateKey);}//采用指定的端口连接服务器session = jsch.getSession(username,host,port);if(password != null){//设置登陆主机的密码session.setPassword(password);}//优先使用 password 验证   注：session.connect()性能低，使用password验证可跳过gssapi认证，提升连接服务器速度session.setConfig("PreferredAuthentications","password");//设置第一次登陆的时候提示，可选值：(ask | yes | no)session.setConfig("StrictHostKeyChecking","no");session.connect();//创建sftp通信通道Channel channel = session.openChannel("sftp");channel.connect();sftp = (ChannelSftp) channel;logger.info("sftp server connect success !!");}catch (JSchException e){logger.error("SFTP服务器连接异常！！", e);}}/*** 关闭SFTP连接*/public void logout(){if(sftp != null){if(sftp.isConnected()){sftp.disconnect();logger.info("sftp is close already");}}if(session != null){if(session.isConnected()){session.disconnect();logger.info("session is close already");}}}/*** 将输入流上传到SFTP服务器，作为文件** @param directory     上传到SFTP服务器的路径* @param sftpFileName  上传到SFTP服务器后的文件名* @param input         输入流* @throws SftpException*/public void upload(String directory, String sftpFileName, InputStream input) throws SftpException{long start = System.currentTimeMillis();try{//如果文件夹不存在，则创建文件夹if(sftp.ls(directory) == null){sftp.mkdir(directory);}//切换到指定文件夹sftp.cd(directory);}catch (SftpException e){//创建不存在的文件夹，并切换到文件夹sftp.mkdir(directory);sftp.cd(directory);}sftp.put(input, sftpFileName);logger.info("上传{} 文件到 {} 上传成功！！ 耗时：{}ms",sftpFileName,directory,(System.currentTimeMillis() - start));}/*** 上传单个文件** @param directory     上传到SFTP服务器的路径* @param uploadFileUrl 文件路径*/public void upload(String directory, String uploadFileUrl){File file = new File(uploadFileUrl);try{upload(directory, file.getName(), new FileInputStream(file));}catch (FileNotFoundException | SftpException e){logger.error("上传文件异常！", e);}}/*** 将byte[] 上传到SFTP服务器，作为文件*           注： 从String转换成byte[] 需要指定字符集** @param directory     上传到SFTP服务器的路径* @param sftpFileName  上传SFTP服务器后的文件名* @param bytes         字节数组*/public void upload(String directory, String sftpFileName, byte[] bytes){try{upload(directory, sftpFileName, new ByteArrayInputStream(bytes));}catch (SftpException e){logger.error("上传文件异常！", e);}}/*** 将字符串按照指定编码格式上传到SFTP服务器** @param directory       上传到SFTP服务器的路径* @param sftpFileName    上传SFTP服务器后的文件名* @param dataStr         字符串* @param charsetName     字符串的编码格式*/public void upload(String directory, String sftpFileName, String dataStr, String charsetName){try{upload(directory, sftpFileName, new ByteArrayInputStream(dataStr.getBytes(charsetName)));}catch (UnsupportedEncodingException | SftpException e){logger.error("上传文件异常！", e);}}/*** 下载文件** @param directory     SFTP服务器的文件路径* @param downloadFile  SFTP服务器上的文件名* @param saveFile      保存到本地路径*/public void download(String directory, String downloadFile, String saveFile){try{if(directory != null && !"".equals(directory)){sftp.cd(directory);}File file = new File(saveFile);sftp.get(downloadFile, new FileOutputStream(file));}catch (SftpException | FileNotFoundException e){logger.error("文件下载异常！", e);}}/*** 下载文件** @param directory     SFTP服务器的文件路径* @param downloadFile  SFTP服务器上的文件名* @return              字节数组*/public byte[] download(String directory, String downloadFile){try{if(directory != null && !"".equals(directory)){sftp.cd(directory);}InputStream inputStream = sftp.get(downloadFile);return IOUtils.toByteArray(inputStream);}catch (SftpException | IOException e){logger.error("文件下载异常！", e);}return null;}/*** 下载文件** @param directory     SFTP服务器的文件路径* @param downloadFile  SFTP服务器上的文件名* @return              输入流*/public InputStream downloadStream(String directory, String downloadFile){try{if(directory != null && !"".equals(directory)){sftp.cd(directory);}return sftp.get(downloadFile);}catch (SftpException e){logger.error("文件下载异常！", e);}return null;}/*** 删除文件** @param directory         SFTP服务器的文件路径* @param deleteFileName    删除的文件名称*/public void delete(String directory, String deleteFileName){try{sftp.cd(directory);sftp.rm(deleteFileName);}catch (SftpException e){logger.error("文件删除异常！", e);}}/*** 删除文件夹** @param directory         SFTP服务器的文件路径*/public void delete(String directory){Vector vector = listFiles(directory);vector.remove(0);vector.remove(0);for(Object v : vector){ChannelSftp.LsEntry lsEntry = (ChannelSftp.LsEntry)v;try{sftp.cd(directory);sftp.rm(lsEntry.getFilename());}catch (SftpException e){logger.error("文件删除异常！", e);}}}/*** 获取文件夹下的文件** @param directory     路径* @return*/public Vector<?> listFiles(String directory){try{if(isDirExist(directory)){Vector<?> vector =  sftp.ls(directory);//移除上级目录和根目录："." ".."vector.remove(0);vector.remove(0);return vector;}}catch (SftpException e){logger.error("获取文件夹信息异常！", e);}return null;}/*** 检测文件夹是否存在** @param directory     路径* @return*/public boolean booleanUrl(String directory){try{if(sftp.ls(directory) == null){return false;}}catch (Exception e){logger.error("检测文件夹异常！", e);}return true;}/*** 创建一个文件目录** @param createpath        路径* @return*/public boolean createDir(String createpath) {try {if (isDirExist(createpath)) {this.sftp.cd(createpath);return true;}String pathArry[] = createpath.split("/");StringBuffer filePath = new StringBuffer("/");for (String path : pathArry) {if (path.equals("")) {continue;}filePath.append(path + "/");if (isDirExist(filePath.toString())) {sftp.cd(filePath.toString());} else {// 建立目录sftp.mkdir(filePath.toString());// 进入并设置为当前目录sftp.cd(filePath.toString());}}this.sftp.cd(createpath);} catch (SftpException e) {logger.error("目录创建异常！", e);return false;}return true;}/*** 判断目录是否存在* @param directory     路径* @return*/public boolean isDirExist(String directory) {boolean isDirExistFlag = false;try {SftpATTRS sftpATTRS = this.sftp.lstat(directory);isDirExistFlag = true;return sftpATTRS.isDir();} catch (Exception e) {if (e.getMessage().toLowerCase().equals("no such file")) {isDirExistFlag = false;}}return isDirExistFlag;}//    /**
//   * 方法功能说明：目录不存在时创建目录
//   * @参数： @param path
//   * @return void
//   * @throws
//   */
//    public void mkdirs(String path){//      File file = new File(path);
//      String fs = file.getParent();
//      file = new File(fs);
//      if(!file.exists()){//          file.mkdirs();
//      }
//  }/*** 判断文件或目录是否存在* @return*/public boolean isExist(String path,ChannelSftp sftp){boolean  isExist=false;try {sftp.lstat(path);isExist = true;} catch (Exception e) {if (e.getMessage().toLowerCase().equals("no such file")) {isExist = false;}}return isExist;}public static void main(String[] args) {SftpUtil sftpUtil =new SftpUtil("root","mNRbc6v9","192.168.211.119",22);sftpUtil.login();sftpUtil.createDir("/root/trunk/remote10/a/b/c/c/d");
//        sftpUtil.upload("/root/trunk/project48/conf","G:\\capacitygroup\\code\\open-plat-form\\rdp-svnadmin\\branches\\rdp-svnadmin-init-20210806\\testconf\\authz"
//                );}
}

【Java工具类】（22）—服务器传文件工具类SCp和Sftp相关推荐

服务器传文件的工具,向服务器传文件的工具
向服务器传文件的工具内容精选换一换 Web服务端证书,即鲲鹏性能分析工具的Web服务端与Web浏览器之间通讯的证书.已成功登录鲲鹏性能分析工具.只有管理员用户(tunadmin)可以执行生成CSR ...
微信传文件又慢又限制大小？试试这3个免费在线传文件工具！
编者荐语平时生活中,常需要在不同设备间临时传输文件或文本,比如你打印时需要把文件从一台电脑传到另外一台电脑.临时需要把Mac上的一个APK文件发送到Android设备.把一些软件配置参数从Windo ...
java scp发送文件到服务器,Java实现往远程服务器传输文件
Java实现往远程服务器传输文件内容精选换一换已成功登录Java性能分析.待安装Guardian的服务器已开启sshd.待安装Guardian的服务器已安装JRE,JRE版本要求为Huawei ...
手机连接服务器传文件在哪里,手机云服务器传文件在哪里
手机云服务器传文件在哪里内容精选换一换登录Windows操作系统的弹性云服务器时,需使用密码方式登录.因此,用户需先根据创建弹性云服务器时使用的密钥文件,获取该弹性云服务器初始安装时系统生成的管 ...
手机文件传云服务器,手机云服务器传文件
手机云服务器传文件内容精选换一换华为云帮助中心,为用户提供产品简介.价格说明.购买指南.用户指南.API参考.最佳实践.常见问题.视频帮助等技术文档,帮助您快速上手使用华为云服务. 如果私钥文件 ...
手机怎么向服务器传文件,手机向云服务器传文件
手机向云服务器传文件内容精选换一换登录Windows操作系统的弹性云服务器时,需要使用密码方式登录.此时,用户需要先根据购买弹性云服务器时下载的私钥文件,获取该弹性云服务器初始安装时系统生成的管 ...
利用WebClient类向服务器上载文件(转孟子的)
利用WebClient类向服务器上载文件(转孟子的) 今天看了TERRYLEE老大的一篇写上传的.里面有个WEBCLIENT我就上网查了一下,找到孟子大人的一篇文章.感觉不错,就转了过来.大家一起学习 ...
java发送post请求上传文件和json数据
java发送post请求上传文件和json数据因为第三方的上传服务post参数使用了两个@requestpart参数. 但是feign不可以使用两个@requestpart参数.会报错:java.l ...
java获取ajax上传的文件,Java使用Ajax异步上传文件
相关代码示例: html代码片段: 名称 class="layui-input"> 描述文件请选择配置文件立即提交重置 js代码片段: //上传配置文件 $(&quo ...

【Java工具类】（22）—服务器传文件工具类SCp和Sftp

Java工具类（22）—服务器传文件工具类SCp和Sftp

1、Scp

2、Sftp

【Java工具类】（22）—服务器传文件工具类SCp和Sftp相关推荐

最新文章

热门文章