每隔1分钟(做成配置),sftp连接南京公司服务器指定的目录(做成配置),同时sftp连接江苏省调服务器指定的目录(做成配置)。南京公司服务器作为基准,比较江苏省调服务器上缺失的文件夹和文件,找到缺失文件夹和文件后,上传到江苏省调的服务器。用jdk8的idea编程实现,附加注释
时间: 2024-05-07 08:16:58 浏览: 106
ChitGPT: 您好!感谢您使用我们的人工智能系统。您的问题是每隔1分钟,通过sftp连接南京公司服务器和江苏省调服务器,比较文件夹和文件,并上传缺失的文件夹和文件到江苏省调服务器。对吗?
以下是实现此功能的Java代码,注释已添加:
```
import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.Session;
import com.jcraft.jsch.ChannelSftp.LsEntry;
import java.io.File;
import java.io.FileInputStream;
import java.util.Properties;
import java.util.Vector;
public class SftpTransfer {
// 定义常量
private static final String PROTOCOL = "sftp";
private static final String KNOWN_HOST_PATH = "known_hosts";
private static final int TIMEOUT = 3000;
private static final String PROPERTY_SFTP_PASSWORD = "password";
private static final String PROPERTY_SFTP_USERNAME = "username";
private static final int DEFAULT_SFTP_PORT = 22;
public static void main(String[] argv) {
try {
//读取配置文件
Properties properties = new Properties();
FileInputStream inputStream = new FileInputStream("config.properties");
properties.load(inputStream);
//南京公司服务器 sftp 连接信息
String njHost = properties.getProperty("njServerHost");
int njPort = Integer.parseInt(properties.getProperty("njServerPort", String.valueOf(DEFAULT_SFTP_PORT)));
String njUsername = properties.getProperty("njServerUsername");
String njPassword = properties.getProperty("njServerPassword");
String njRemoteDirectory = properties.getProperty("njServerRemoteDirectory");
//江苏省调服务器 sftp 连接信息
String jsHost = properties.getProperty("jsServerHost");
int jsPort = Integer.parseInt(properties.getProperty("jsServerPort", String.valueOf(DEFAULT_SFTP_PORT)));
String jsUsername = properties.getProperty("jsServerUsername");
String jsPassword = properties.getProperty("jsServerPassword");
String jsRemoteDirectory = properties.getProperty("jsServerRemoteDirectory");
// 构造连接信息
JSch jsch = new JSch();
jsch.setKnownHosts(KNOWN_HOST_PATH);
Session njSession = jsch.getSession(njUsername, njHost, njPort);
Session jsSession = jsch.getSession(jsUsername, jsHost, jsPort);
njSession.setPassword(njPassword);
jsSession.setPassword(jsPassword);
njSession.setTimeout(TIMEOUT);
jsSession.setTimeout(TIMEOUT);
njSession.setConfig("StrictHostKeyChecking", "no");
jsSession.setConfig("StrictHostKeyChecking", "no");
//连接南京公司服务器和江苏省调服务器
njSession.connect();
jsSession.connect();
// 配置南京公司服务器 sftp channel
ChannelSftp njChannel = (ChannelSftp) njSession.openChannel(PROTOCOL);
njChannel.connect();
njChannel.cd(njRemoteDirectory);
// 配置江苏省调服务器 sftp channel
ChannelSftp jsChannel = (ChannelSftp) jsSession.openChannel(PROTOCOL);
jsChannel.connect();
jsChannel.cd(jsRemoteDirectory);
//获取南京公司服务器上的文件列表
Vector<LsEntry> njRemoteFiles = njChannel.ls("*");
// 比较南京公司服务器和江苏省调服务器上的文件列表
for (LsEntry njRemoteFile : njRemoteFiles) {
String fileName = njRemoteFile.getFilename();
File localFile = new File(jsRemoteDirectory + fileName);
if (!localFile.exists()) {
// 如果本地不存在该文件,则上传到江苏省调服务器
FileInputStream fileInputStream = new FileInputStream(njRemoteDirectory + fileName);
jsChannel.put(fileInputStream, fileName);
fileInputStream.close();
}
}
// 关闭资源
njChannel.disconnect();
njSession.disconnect();
jsChannel.disconnect();
jsSession.disconnect();
} catch (Exception e) {
e.printStackTrace();
}
}
}
```
您可以根据您的需要,修改配置文件来设置服务器地址、端口、用户名、密码和远程目录。同时,您也可以通过修改代码来调整执行频率和其他功能。如果您需要进一步帮助,请告诉我,我会尽力为您提供帮助!
阅读全文