- 浏览: 138126 次
- 性别:
- 来自: 上海
文章分类
最新评论
-
xiangen11111:
microsoft sqlserver2005 java驱动包 sqljdbc.jar -
liujianshiwo:
--第一步建立一个函数
CREATE OR REPLACE F ...
获取汉字拼音首字母 -
guoyangjie:
怎么是个jar包啊,能不能贴出源码来
获取汉字拼音首字母 -
liujianshiwo:
microsoft sqlserver2005 java驱动包 sqljdbc.jar -
liujianshiwo:
microsoft sqlserver2005 java驱动包 sqljdbc.jar
需要jdk6 , jsch-0.1.44.jar 如果你的jar 和这个不匹配 命令返回信息 就有问题
private String host;
private String user;
private String password;
private int port;
private Session session;
/**
* 创建一个连接
* @param host 地址
* @param user 用户名
* @param password 密码
* @param port ssh2端口
*/
public Ssh2Util(String host, String user, String password, int port) {
this.host = host;
this.user = user;
this.password = password;
this.port = port;
}
private void initialSession() throws Exception {
if (session == null) {
JSch jsch = new JSch();
session = jsch.getSession(user, host, port);
session.setUserInfo(new UserInfo() {
public String getPassphrase() {
return null;
}
public String getPassword() {
return null;
}
public boolean promptPassword(String arg0) {
return false;
}
public boolean promptPassphrase(String arg0) {
return false;
}
public boolean promptYesNo(String arg0) {
return true;
}
public void showMessage(String arg0) {
}
});
session.setPassword(password);
session.connect();
}
}
/**
* 关闭连接
* @throws Exception
*/
public void close() throws Exception {
if (session != null && session.isConnected()) {
session.disconnect();
session = null;
}
}
/**
* 上传文件
* @param localPath 本地路径,若为空,表示当前路径
* @param localFile 本地文件名,若为空或是“*”,表示目前下全部文件
* @param remotePath 远程路径,若为空,表示当前路径,若服务器上无此目录,则会自动创建
* @throws Exception
*/
public void putFile(String localPath, String localFile, String remotePath) throws Exception {
this.initialSession();
Channel channelSftp = session.openChannel("sftp");
channelSftp.connect();
ChannelSftp c = (ChannelSftp)channelSftp;
String remoteFile = null;
if (remotePath != null && remotePath.trim().length() > 0) {
try {
c.mkdir(remotePath);
} catch (Exception e) {}
remoteFile = remotePath + "/.";
} else {
remoteFile = ".";
}
String file = null;
if (localFile == null || localFile.trim().length() == 0) {
file = "*";
} else {
file = localFile;
}
if (localPath != null && localPath.trim().length() > 0) {
if (localPath.endsWith("/")) {
file = localPath + file;
} else {
file = localPath + "/" + file;
}
}
c.put(file, remoteFile);
channelSftp.disconnect();
}
// public static void main(String[] args) {
// Ssh2Util ssh = new Ssh2Util("192.168.1.189", "root", "test" , 22);
// try {
// String rs = ssh.runCommand("ddddd");
// } catch (Exception e) {
// e.printStackTrace();
// }
// }
//command 命令
public String runCommand(String command) throws Exception {
CommonUtil.printLogging("[" + command + "] begin", host, user);
this.initialSession();
InputStream in = null;
InputStream err = null;
BufferedReader inReader = null;
BufferedReader errReader = null;
int time = 0;
String s = null;
boolean run = false;
StringBuffer sb = new StringBuffer();
Channel channel = session.openChannel("exec");
((ChannelExec) channel).setCommand(command);
channel.setInputStream(null);
((ChannelExec) channel).setErrStream(null);
err = ((ChannelExec) channel).getErrStream();
in = channel.getInputStream();
channel.connect();
inReader = new BufferedReader(new InputStreamReader(in, "UTF-8"));
errReader = new BufferedReader(new InputStreamReader(err, "UTF-8"));
while (true) {
s = errReader.readLine();
if (s != null) {
sb.append("error:" + s).append("\n");
} else {
run = true;
break;
}
}
while (true) {
s = inReader.readLine();
if (s != null) {
sb.append("info:" + s).append("\n");
} else {
run = true;
break;
}
}
while (true) {
if (channel.isClosed() || run) {
//CommonUtil.printLogging("[" + command + "] finish: " + channel.getExitStatus(), host, user);
break;
}
try {
Thread.sleep(1000);
} catch (Exception ee) {
}
if (time > 180) {
//CommonUtil.printLogging("[" + command + "] finish2: " + channel.getExitStatus(), host, user);
break;
}
time ++;
}
inReader.close();
errReader.close();
channel.disconnect();
session.disconnect();
System.out.println(sb.toString());
return sb.toString();
}
private String host;
private String user;
private String password;
private int port;
private Session session;
/**
* 创建一个连接
* @param host 地址
* @param user 用户名
* @param password 密码
* @param port ssh2端口
*/
public Ssh2Util(String host, String user, String password, int port) {
this.host = host;
this.user = user;
this.password = password;
this.port = port;
}
private void initialSession() throws Exception {
if (session == null) {
JSch jsch = new JSch();
session = jsch.getSession(user, host, port);
session.setUserInfo(new UserInfo() {
public String getPassphrase() {
return null;
}
public String getPassword() {
return null;
}
public boolean promptPassword(String arg0) {
return false;
}
public boolean promptPassphrase(String arg0) {
return false;
}
public boolean promptYesNo(String arg0) {
return true;
}
public void showMessage(String arg0) {
}
});
session.setPassword(password);
session.connect();
}
}
/**
* 关闭连接
* @throws Exception
*/
public void close() throws Exception {
if (session != null && session.isConnected()) {
session.disconnect();
session = null;
}
}
/**
* 上传文件
* @param localPath 本地路径,若为空,表示当前路径
* @param localFile 本地文件名,若为空或是“*”,表示目前下全部文件
* @param remotePath 远程路径,若为空,表示当前路径,若服务器上无此目录,则会自动创建
* @throws Exception
*/
public void putFile(String localPath, String localFile, String remotePath) throws Exception {
this.initialSession();
Channel channelSftp = session.openChannel("sftp");
channelSftp.connect();
ChannelSftp c = (ChannelSftp)channelSftp;
String remoteFile = null;
if (remotePath != null && remotePath.trim().length() > 0) {
try {
c.mkdir(remotePath);
} catch (Exception e) {}
remoteFile = remotePath + "/.";
} else {
remoteFile = ".";
}
String file = null;
if (localFile == null || localFile.trim().length() == 0) {
file = "*";
} else {
file = localFile;
}
if (localPath != null && localPath.trim().length() > 0) {
if (localPath.endsWith("/")) {
file = localPath + file;
} else {
file = localPath + "/" + file;
}
}
c.put(file, remoteFile);
channelSftp.disconnect();
}
// public static void main(String[] args) {
// Ssh2Util ssh = new Ssh2Util("192.168.1.189", "root", "test" , 22);
// try {
// String rs = ssh.runCommand("ddddd");
// } catch (Exception e) {
// e.printStackTrace();
// }
// }
//command 命令
public String runCommand(String command) throws Exception {
CommonUtil.printLogging("[" + command + "] begin", host, user);
this.initialSession();
InputStream in = null;
InputStream err = null;
BufferedReader inReader = null;
BufferedReader errReader = null;
int time = 0;
String s = null;
boolean run = false;
StringBuffer sb = new StringBuffer();
Channel channel = session.openChannel("exec");
((ChannelExec) channel).setCommand(command);
channel.setInputStream(null);
((ChannelExec) channel).setErrStream(null);
err = ((ChannelExec) channel).getErrStream();
in = channel.getInputStream();
channel.connect();
inReader = new BufferedReader(new InputStreamReader(in, "UTF-8"));
errReader = new BufferedReader(new InputStreamReader(err, "UTF-8"));
while (true) {
s = errReader.readLine();
if (s != null) {
sb.append("error:" + s).append("\n");
} else {
run = true;
break;
}
}
while (true) {
s = inReader.readLine();
if (s != null) {
sb.append("info:" + s).append("\n");
} else {
run = true;
break;
}
}
while (true) {
if (channel.isClosed() || run) {
//CommonUtil.printLogging("[" + command + "] finish: " + channel.getExitStatus(), host, user);
break;
}
try {
Thread.sleep(1000);
} catch (Exception ee) {
}
if (time > 180) {
//CommonUtil.printLogging("[" + command + "] finish2: " + channel.getExitStatus(), host, user);
break;
}
time ++;
}
inReader.close();
errReader.close();
channel.disconnect();
session.disconnect();
System.out.println(sb.toString());
return sb.toString();
}
发表评论
-
quartz
2016-02-19 13:59 687在spring 配置文件中增加下面内容: spring版本 ... -
java http请求 返回结果是json ,转成对象使用
2012-10-15 21:52 6309URLConnection connection = nul ... -
ORACLE 循环语句 LOOP WHILE FOR
2011-07-12 09:52 2169loop循环:create or replace proced ... -
kettle 4.1 下载地址
2011-07-07 23:51 1102http://sourceforge.net/projects ... -
Oracle 函数大全(字符串函数,数学函数,日期函数,逻辑运算函数,其他函数)[转]
2011-06-14 14:30 910Oracle 函数大全(字符串函数,数学函数,日期函数,逻辑运 ... -
加载项目中所有spring配置文件 java 代码
2011-06-07 09:21 1381这个类要在启动程序 ... -
Spring 纯jdbc JdbcDaoSupport 事务处理
2011-06-03 14:46 2134PlatformTransactionMana ... -
struts2 获取上下文对象 关联spring
2011-06-02 15:25 1016ApplicationContext applicationC ... -
kettle 4.1 下载地址
2011-05-17 09:48 902下载地址:http://sourceforge.net/pro ... -
向一个表中插入一个序列
2011-05-09 20:02 786update sirm_enum set objid = ro ... -
orcale 导入数据
2011-05-06 09:12 705现导入表结构,不导入数据 imp user/password@ ... -
获取汉字拼音首字母
2011-04-08 15:57 1600获取汉字拼音首字母 获取汉字拼音首字母 很好用....觉 ... -
microsoft sqlserver2005 java驱动包 sqljdbc.jar
2011-03-05 21:02 2823ms sql2005 java驱动包 sqljdbc.jar ... -
IDEA 9.0.2整合Tomcat开发
2011-02-13 16:26 882IDEA 9.0.2整合Tomcat开发 IDEA 9 ... -
java split 用法说明详解
2011-02-13 15:03 11451. 如字符串:http://www.vv ... -
IntelliJ IDEA常用设置
2011-02-13 14:20 1266IntelliJ IDEA是一款非常优 ... -
java jdk6.0 jdk-6u18-windows-i586.exe
2011-01-27 22:13 1451jdk-6u18-windows-i586.exe -
proc文件系统
2010-12-15 13:57 904/proc文件系统 /proc文件 ... -
linux命令
2010-12-15 12:17 790# ls ls -a 列出当前目录 ... -
查看linux内存使用情况
2010-12-15 10:27 916在Linux下查看内存我们 ...
相关推荐
根据提供的文件信息,我们可以归纳出...综上所述,本文档涉及了 SSH2 远程执行命令、FTP 文件传输以及 Java 文件处理等知识点。这些技术在日常开发工作中非常实用,对于从事相关领域的技术人员来说具有较高的参考价值。
在Java中,实现SSH连接一般会用到JSch库,这个库支持SSH2协议,并且包含了建立连接、执行命令、文件传输等功能。`TestSshConnect.java`应该就是利用JSch库进行SSH连接的代码,你可以从中学习如何设置凭据,建立安全...
在JMeter中,这个库用于建立到远程SSH服务器的连接,并执行命令。 接着,`ApacheJMeter_ssh-1.1.1-SNAPSHOT.jar`是Apache JMeter的SSH命令 sampler插件,它扩展了JMeter的功能,使得JMeter能够发送SSH命令到远程...
2. **文件操作**:FTP服务器需要提供文件的上传、下载、重命名、删除等基本操作。这涉及到对本地文件系统的操作,如使用`java.io.File`类进行文件操作。 3. **数据传输**:FTP协议有ASCII和二进制两种传输模式,...
FTP服务器是运行FTP服务的软件,它允许用户通过FTP协议上传、下载和管理远程主机上的文件。Java中实现FTP服务器,可以利用Apache Commons Net库,它提供了丰富的FTP服务器和客户端功能。 2. **Java中的FTP服务器...
在这个场景中,我们关注的是一个基于Java开发的FTP上传工具,它能够帮助用户将本地文件上传到FTP服务器。以下是一些关于FTP上传工具和相关技术的知识点: 1. **FTP基本概念**: FTP是一个应用层协议,基于TCP/IP...
2. FTP服务端:FTP服务端是运行在服务器上的软件,等待并响应来自客户端的请求。"ftp服务端"在本例中可能是服务器应用程序的源代码或配置文件,供学习者了解如何设置和管理FTP服务器。FTP服务器通常监听特定的端口...
在Web应用中,SSH可以用于部署过程,例如通过SSH连接远程服务器,然后使用scp或sftp命令将编译后的WAR或JAR文件上传到Tomcat的webapps目录,完成应用的部署。 8. **安全考虑** 使用SSH进行文件传输的一大优势是其...
Java FTP简易服务器是一种使用Java编程语言实现的简单文件传输协议(FTP)服务器。FTP是互联网上广泛用于在客户端和服务器之间传输文件的标准协议。通过Java实现FTP服务器,开发者可以利用Java的强大特性和丰富的库...
1. **JSch库**:JSch是Java的一个SSH2库,它提供了连接到SSH服务器、执行命令、文件传输(SCP和SFTP)等功能。JSch JAR包通常包含在SSH2开发所需的所有依赖中,是实现SSH2连接的基础。 2. **公钥与私钥认证**:SSH2...
总的来说,用Java实现FTP服务器涉及网络编程、线程管理、命令解析以及文件操作等多个方面,需要对Java I/O和网络通信有深入理解。通过这种方式,你可以创建一个自定义的、符合特定需求的FTP服务器。
2. **FTP(File Transfer Protocol)/SFTP(Secure File Transfer Protocol)**:如果服务器支持FTP或SFTP,也可以通过FTP客户端(如FileZilla)进行文件上传。 3. **Git**:既然提到了两个git提交间的差异,我们...
多线程FTP上传是指通过多个并发连接同时上传文件,以提高文件上传的速度和效率。这种技术尤其适用于大文件或大批量文件的传输,因为它可以充分利用网络带宽资源。 在实现FTP多线程上传时,我们需要考虑以下几个关键...
这通常涉及使用Java的`java.net.URL`和`java.net.URLConnection`类,连接到FTP服务器并列出指定目录下的文件。通过比较本地版本号与服务器上的版本号,判断是否有可用更新。 3. **文件下载**:如果检测到新版本,...
例如,Python脚本可以通过ftplib连接到服务器,然后使用STOR命令上传文件,用RETR命令下载文件。确保在脚本中处理错误,如网络中断或文件不存在的情况。 4. 配置信息:脚本需要包含FTP服务器的地址、端口号(默认21...
3. **命令交互**:通过控制连接发送FTP命令,如`LIST`获取目录信息,`CWD`改变工作目录,`PUT`上传文件,`GET`下载文件,`DELE`删除文件等。 4. **数据传输**:FTP使用两个连接——控制连接和数据连接。一旦命令...
FTP服务器是运行FTP服务的软件,允许用户通过FTP客户端连接并进行文件的上传、下载以及管理操作。"ftp服务器源码"指的是提供了FTP服务器功能的程序源代码,这通常是供开发者研究、学习或定制FTP服务器功能时使用的。...
FTP基于TCP/IP协议族,分为控制连接和数据连接两部分,允许用户远程登录到FTP服务器,进行文件的上传、下载、删除、重命名等操作。FTP具有可靠性和高效性,尤其在传输大文件时,相较于HTTP协议,FTP通常表现出更好的...
在Java编程环境中,FTP(File Transfer Protocol)是一种常用的技术,用于在本地计算机和远程服务器之间交换文件。本文将深入探讨如何使用Java实现FTP文件的上传和下载操作。 FTP协议是Internet上的一个标准协议,...
FTP服务器是运行FTP服务的软件,允许用户通过FTP协议上传、下载或管理远程文件。本篇文章将详细探讨FTP服务器的开发和测试工具,以及如何利用提供的"FtpServer-master"压缩包进行相关操作。 FTP服务器开发涉及的...