public class CopyFile {
public static void main(String[] args) throws IOException {
FileInputStream readFis=new FileInputStream("d:/1.txt");
FileChannel readFc=readFis.getChannel();
readFc.read(bb);
FileChannel writeFs=writeFis.getChannel();
writeFs.write((ByteBuffer) bb.flip());
}
最近接到一个产品需求是给指定的 sftp 服务器的指定目录定时推送文件数据.
因为项目组已有现成的组件可以轻松实现 sftp 服务器文件的快速上传,本来是一件很容易的事情,但是问题出现在这个指定的 sftp 服务器所指定的密码带有系统关键字和一些特殊字符,导致现在的组件在解析过程中会失败.
所以呢重新开发了下面的这套脚本来满足这个特殊的需求.
Python代码
sftp配置文件代码
(1). yaml 模块
导入 yaml 模块前可以使用以下命令进行模块的安装
yaml 模块今天这一节的作用是读取 sftp 配置文件代码,将指定key: test_file_upload 下的 key:value 的值转换为字典.
例如：load_config_from_param_conf 函数中的返回值就是使用 yaml 读取到 sftp 配置文件代码后,返回 key: test_file_upload 下配置选项值.
格式如下：
最后将返回值传给 upload 函数作为参数.
按照 yaml 模块的安装方法,先安装 optparse 模块后,然后在文件中从optparse 中导入 OptionParser 模块
①.). 形参：--node,实参：node
所代表的业务含义是：指定要上传的 sftp 的节点,具体参数值对应 sftp配置文件代码中的 test_file_upload
所代表的业务含义是：指定本地需要被上传到 sftp 服务器的具体文件路径
参数：action的枚举
store: 参数列表中带有--node, 那么就会将下一个元素即：test_file_upload 作为其 dest 实参 node 的值; 如果没有--node,那么对应的node的值就为 None;
store_true: 参数列表中有--local_file, 那么其 dest 实参 local_file 的值就为 True; 否者就为 default 定义的默认值,这里没有给定 default 的默认值;
store_false: 参数列表中有--local_file, 那么其 dest 实参 local_file 的值就为 False; 否者就为 default 定义的默认值,这里没有给定 default 的默认值;
参数：type
type是指定传入参数的类型,这里的参数类型为 string 类型.
参数：dest
dest是参数传入后由哪个变量来存储的,后面代码对该参数的引用也是使用这里定义的变量名来引用的.
参数：default
default 是与 action 的值结合使用的.
参数：help
help相当于帮助说明文档,用于描述这个参数的含义.
代码:
import java.util.Properties;
import com.cloudpower.util.Login;
import com.util.LoadProperties;
public class Ftp {
public static void main(String[] args) {
Properties properties = LoadProperties.getProperties();
Login.login(properties);
状态集合I的a弧转换,表示为move(I,a)定义为状态集合J,其中J是所有那些可从I的某一状态经过一条a弧而到达的状态的全体.
定义Ia = ★-closure(move(I,a))
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Vector;
import org.apache.commons.lang.ArrayUtils;
import com.huawei.bme.commons.om.log.DebugLog;
import com.huawei.bme.commons.om.log.LogFactory;
import com.huawei.icity.commons.constants.KeyConstant;
import com.huawei.icity.commons.constants.NumberConstant;
import com.huawei.icity.commons.exception.SPMException;
import com.huawei.icity.commons.log.IcityLogFactory;
import com.huawei.icity.commons.log.IcityRuntimeLog;
import com.huawei.icity.commons.sysconfig.StaticInitData;
import com.huawei.icity.commons.utils.StringTools;
import com.huawei.icity.omp.common.util.CommonTools;
import com.huawei.icity.omp.interfaces.hint.constant.TimetaskConstants;
import com.huawei.mdmc.bfm.cms.assist.common.domain.SingleTableModel;
import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.ChannelS;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.JSchException;
import com.jcraft.jsch.Session;
import com.jcraft.jsch.SftpException;
/**
*
*/
public class SFTPTool
{
* 调测日志记录器.
private static final DebugLog DEBUGGER = LogFactory.getDebugLog(SFTPTool.class);
* 运行日志记录器.
private static final IcityRuntimeLog RUNTIMELOGGER = IcityLogFactory
.getRuntimeLog(SFTPTool.class);
private ChannelSftp sftp = null;
* SFTP IP地址
private String ip;
* SFTP 端口
private String port;
* SFTP 用户名
private String userName;
* SFTP 密码
private String password;
* SFTP上传模式:BINARY
* 获取实例
* @return SFTPTool newinstance实例
public static SFTPTool getNewInstance()
return new SFTPTool();
* 初始化连接参数
* @param sftpIP
* IP
* @param sftpPort
* 端口
* @param sftpUsername
* 用户名
* @param sftpPassword
* 密码
public void init(String sftpIP, String sftpPort, String sftpUsername, String sftpPassword)
// 获取SFTP连接信息
this.ip = sftpIP;
this.port = sftpPort;
this.userName = sftpUsername;
this.password = sftpPassword;
* @param sftpDir
* SFTP服务器文件存放路径
* @param locDir
* 本地文件存放路径
* @param regex
* 指定文件名的格式
* @param needBackup
* 是否需要文件备份(true:是;false:否)
* @param needFullMatch
* 是否要求全局匹配(true:是;false:否)
* @param deleteFtpFile
* the delete ftp file
public ListFile synSFTPFileToLocal(String sftpDir, String locDir, String regex,
boolean needBackup, boolean needFullMatch, boolean deleteFtpFile)
ListFile files = new ArrayListFile(KeyConstant.INITIAL_NUMBER);
try
this.connect(ip, Integer.parseInt(this.port), userName, password);
// 获得FTP上文件名称列表
ListString ftpFileNameList = this.listFiles(sftpDir, regex, needFullMatch);
File localFile = null;
int size = ftpFileNameList.size();
// 根据每个FTP文件名称创建本地文件.
for (int i = 0; i size; i++)
localFile = this.download(sftpDir, locDir, ftpFileNameList.get(i), deleteFtpFile);
if (localFile.exists())
files.add(localFile);
if (needBackup)
// 备份源文件生成默认备份文件路径(据请求文件路径,生成同级目录的备份文件夹绝对路径)
String parentDir = sftpDir.substring(NumberConstant.INT_0,
sftpDir.lastIndexOf("/") + 1);
String backupDir = parentDir + TimetaskConstants.DEFAULT_BACKUP_DIRNAME;
boolean bakExists = openDir(backupDir);
if (bakExists)
this.uploadFile(backupDir, localFile);
else
boolean parentExists = openDir(parentDir);
if (parentExists)
s;
DEBUGGER.error("sftp parentDir no exisits ");
catch (Exception e)
DEBUGGER.error("synSFTPFileToLocal Exception", e);
finally
this.disconnect();
return files;
* 连接sftp服务器
* @param sftpip
* ip地址
* @param sftpport
* @param sftpusername
* @param sftppassword
* @return channelSftp
* @throws SPMException
public ChannelSftp connect(String sftpip, int sftpport, String sftpusername, String sftppassword)
sftp = new ChannelSftp();
JSch jsch = new JSch();
jsch.getSession(sftpusername, sftpip, sftpport);
Session sshSession = jsch.getSession(sftpusername, sftpip, sftpport);
RUNTIMELOGGER.info("Session created");
sshSession.setPassword(sftppassword);
Properties sshConfig = new Properties();
sshConfig.put("StrictHostKeyChecking", "no");
sshSession.setConfig(sshConfig);
// 设置超时时间为
sshSession.setTimeout(Integer.parseInt(StaticInitData.getFtpConnectTimeOut())
* NumberConstant.INT_1000);
sshSession.connect();
Channel channel = sshSession.openChannel("sftp");
channel.connect();
sftp = (ChannelSftp) channel;
// 设置文件类型
// ftpClient.setFileType(BINARY_FILE_TYPE);
// 与防火墙相关
// ftpClient.enterLocalPassiveMode();
catch (JSchException e)
DEBUGGER.error("JSchException : {}", e);
return sftp;
// /**
// * 创建指定文件夹
// *
// * @param dirName
// * dirName
// */
// public void mkDir(String dirName)
// {
// try
// s;
// }
// catch (SftpException e)
// DEBUGGER.error("mkDir Exception : " + e);
* 创建指定文件夹
* @param dirName
* dirName
public void mkDir(String dirName)
String[] dirs = dirName.split("/");
String now = s;
for (int i = 0; i dirs.length; i++)
boolean dirExists = openDir(dirs[i]);
if (!dirExists)
s(dirs[i]);
catch (SftpException e)
DEBUGGER.error("mkDir Exception : " + e);
* 打开指定目录
* @param directory
* directory
* @return 是否打开目录
public boolean openDir(String directory)
return true;
DEBUGGER.error("openDir Exception : " + e);
return false;
public?static?void?downloadFileFtp(KmConfig?kmConfig,String?fileName,?String?clientFileName,?OutputStream?outputStream){
try?{
String?ftpHost?=?kmConfig.getFtpHost();
int?port?=?kmConfig.getFtpPort();
String?userName?=?kmConfig.getFtpUser();
String?passWord?=?kmConfig.getFtpPassword();
String?path?=?kmConfig.getFtpPath();
FtpClient?ftpClient?=?new?FtpClient(ftpHost,?port);//?ftpHost为FTP服务器的IP地址,port为FTP服务器的登陆端口,ftpHost为String型,port为int型.
ftpClient.login(userName,?passWord);//?userName、passWord分别为FTP服务器的登陆用户名和密码
ftpClient.binary();
ftpClient.cd(path);//?path为FTP服务器上保存上传文件的路径.
TelnetInputStream?in?=?ftpClient.get(fileName);
int?cnt=0;
while?((cnt=in.read(bytes,0,bytes.length))?!=?-1)?{
outputStream.write(bytes,?0,?cnt);
//##############################################
//#############################################
outputStream.close();
in.close();
}?catch?(Exception?e)?{
ftpClient.closeServer();
e.printStackTrace();
以上就是土嘎嘎小编为大家整理的sftp的java代码相关主题介绍,如果您觉得小编更新的文章只要能对粉丝们有用,就是我们最大的鼓励和动力,不要忘记讲本站分享给您身边的朋友哦！！