- 前不久在项目开发中遇上的一个需求：需要在B机器上将A机器某路径下的文件拷贝到B机器上做保存。
简单分析下来，自己的理解就是：一个RPC，主要就是解决跨域传输文件的问题。在提前能拿到A机器的IP、Port、userName、Pwd的情况下还是很好解决的。
参考下Linux下，实现方式：
将本机文件上传到远程服务器
#scp /usr/local/news.txt root@192.168.1.1:/etc/opt
** /usr/local/** 本地文件的绝对路径
news.txt 要复制到服务器上的本地文件
root 通过root用户登录到远程服务器（也可以使用其他拥有同等权限的用户）
192.168.6.129 远程服务器的ip地址（也可以使用域名或机器名）
/etc/opt 将本地文件复制到位于远程服务器上的路径
将远程服务器文件下载到本机
#scp root@192.168.1.1:/usr/local/news.txt /usr/local
root 通过remote用户登录到远程服务器（也可以使用其他拥有同等权限的用户）
192.168.1.1 远程服务器的IP地址（当然也可以使用该服务器域名）
/usr/local/news.txt 欲复制到本机的位于远程服务器上的文件
/usr/local 将远程文件复制到本地的绝对路径
- java 实现的方式参照上述就简单了，如下：
需要导入Jar包：
<!-- https://mvnrepository.com/artifact/ch.ethz.ganymed/ganymed-ssh2 -->
<dependency>
<groupId>ch.ethz.ganymed</groupId>
<artifactId>ganymed-ssh2</artifactId>
<version>build210</version>
</dependency>
工具类：
public class Scpclient {
private static final FileLog logger = new FileLog(Scpclient.class.getName());
static private Scpclient instance;
static synchronized public Scpclient getInstance(String IP, int port,
String username, String passward) {
if (instance == null) {
instance = new Scpclient(IP, port, username, passward);
}
return instance;
}
public Scpclient(String IP, int port, String username, String passward) {
this.ip = IP;
this.port = port;
this.username = username;
this.password = passward;
}
/**
* 远程拷贝文件
* @param remoteFile 远程源文件路径
* @param localTargetDirectory 本地存放文件路径
*/
public Map<String,Object> getFile(String remoteFile, String localTargetDirectory) {
Connection conn = new Connection(ip,port);
try {
conn.connect();
boolean isAuthenticated = conn.authenticateWithPassword(username,
password);
if (isAuthenticated == false) {
logger.log(Level.ERROR_INT,"authentication failed");
return Common.pageMap(NetMsgUtil.INVOKING_SERVER_EXCEPTION,"authentication failed");
}
SCPClient client = new SCPClient(conn);
client.get(remoteFile, localTargetDirectory);
conn.close();
} catch (IOException e) {
logger.log(Level.ERROR_INT,e.getMessage());
return Common.pageMap(NetMsgUtil.INVOKING_SERVER_EXCEPTION,e.getMessage());
}
return Common.pageMap(NetMsgUtil.NET_NORMAL_MSG,"Document Success");
}
/**
* 远程上传文件
* @param localFile 本地文件路径
* @param remoteTargetDirectory 远程存放文件路径
*/
public void putFile(String localFile, String remoteTargetDirectory) {
Connection conn = new Connection(ip,port);
try {
conn.connect();
boolean isAuthenticated = conn.authenticateWithPassword(username,
password);
if (isAuthenticated == false) {
logger.log(Level.ERROR_INT,"authentication failed");
}
SCPClient client = new SCPClient(conn);
client.put(localFile, remoteTargetDirectory);
conn.close();
} catch (IOException e) {
logger.log(Level.ERROR_INT,e.getMessage());
}
}
/**
* 远程上传文件并对上传文件重命名
* @param localFile 本地文件路径
*@param remoteFileName远程文件名
* @param remoteTargetDirectory 远程存放文件路径
*@param mode 默认"0600"，length=4
*/
public void putFile(String localFile, String remoteFileName,String remoteTargetDirectory,String mode) {
Connection conn = new Connection(ip,port);
try {
conn.connect();
boolean isAuthenticated = conn.authenticateWithPassword(username,
password);
if (isAuthenticated == false) {
logger.log(Level.ERROR_INT,"authentication failed");
}
SCPClient client = new SCPClient(conn);
if((mode == null) || (mode.length() == 0)){
mode = "0600";
}
client.put(localFile, remoteFileName, remoteTargetDirectory, mode);
//重命名
Session sess = conn.openSession();
String tmpPathName = remoteTargetDirectory + File.separator+ remoteFileName;
String newPathName = tmpPathName.substring(0, tmpPathName.lastIndexOf("."));
sess.execCommand("mv " + remoteFileName + " " + newPathName);
conn.close();
} catch (IOException e) {
logger.log(Level.ERROR_INT,e.getMessage());
}
}
private String ip;
private int port;
private String username;
private String password;
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public int getPort() {
return port;
}
public void setPort(int port) {
this.port = port;
}
}
调用姿势：
Scpclient scpclient = Scpclient.getInstance(String IP, int port,String username, String passward);
// 拷贝
scpclient .getFile(...);
// 上传
scpclient .putFile(...);
- 最后，只想说一句，我们不生产代码，我们只是代码搬运工。
