- 浏览: 135978 次
- 性别:
- 来自: 上海
文章分类
最新评论
-
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 642在spring 配置文件中增加下面内容: spring版本 ... -
java http请求 返回结果是json ,转成对象使用
2012-10-15 21:52 6242URLConnection connection = nul ... -
ORACLE 循环语句 LOOP WHILE FOR
2011-07-12 09:52 2121loop循环:create or replace proced ... -
kettle 4.1 下载地址
2011-07-07 23:51 1073http://sourceforge.net/projects ... -
Oracle 函数大全(字符串函数,数学函数,日期函数,逻辑运算函数,其他函数)[转]
2011-06-14 14:30 871Oracle 函数大全(字符串函数,数学函数,日期函数,逻辑运 ... -
加载项目中所有spring配置文件 java 代码
2011-06-07 09:21 1344这个类要在启动程序 ... -
Spring 纯jdbc JdbcDaoSupport 事务处理
2011-06-03 14:46 2104PlatformTransactionMana ... -
struts2 获取上下文对象 关联spring
2011-06-02 15:25 982ApplicationContext applicationC ... -
kettle 4.1 下载地址
2011-05-17 09:48 869下载地址:http://sourceforge.net/pro ... -
向一个表中插入一个序列
2011-05-09 20:02 756update sirm_enum set objid = ro ... -
orcale 导入数据
2011-05-06 09:12 680现导入表结构,不导入数据 imp user/password@ ... -
获取汉字拼音首字母
2011-04-08 15:57 1553获取汉字拼音首字母 获取汉字拼音首字母 很好用....觉 ... -
microsoft sqlserver2005 java驱动包 sqljdbc.jar
2011-03-05 21:02 2785ms sql2005 java驱动包 sqljdbc.jar ... -
IDEA 9.0.2整合Tomcat开发
2011-02-13 16:26 849IDEA 9.0.2整合Tomcat开发 IDEA 9 ... -
java split 用法说明详解
2011-02-13 15:03 11151. 如字符串:http://www.vv ... -
IntelliJ IDEA常用设置
2011-02-13 14:20 1235IntelliJ IDEA是一款非常优 ... -
java jdk6.0 jdk-6u18-windows-i586.exe
2011-01-27 22:13 1421jdk-6u18-windows-i586.exe -
proc文件系统
2010-12-15 13:57 880/proc文件系统 /proc文件 ... -
linux命令
2010-12-15 12:17 740# ls ls -a 列出当前目录 ... -
查看linux内存使用情况
2010-12-15 10:27 878在Linux下查看内存我们 ...
相关推荐
Java访问权限控制,为Java操作文件、写入文件分配合适的权限,定义写到文件的信息、定义文件,输出到c:/hello.txt、写信息到文件、关闭输出流。 Java绘制图片火焰效果 1个目标文件 摘要:Java源码,图形操作,火焰...
Java访问权限控制,为Java操作文件、写入文件分配合适的权限,定义写到文件的信息、定义文件,输出到c:/hello.txt、写信息到文件、关闭输出流。 Java绘制图片火焰效果 1个目标文件 摘要:Java源码,图形操作,火焰...
ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
ftp4j是一个FTP客户端Java类库,实现了FTP客户端应具有的大部分功能文件(包括上传和下 载),浏览远程FTP服务器上的目录和文件,创建、删除、重命,移动远程目录和文件。ftp4j提供多种方式连接到远程FTP服务器包括...
9.2 服务器运行配置的设置 157 9.2.1 编辑httpd.conf文件 158 9.2.2 .htaccess文件和访问限制 160 9.3 虚拟主机 161 9.3.1 基于地址的虚拟主机 161 9.3.2 基于名字的虚拟主机 162 9.4 日志记录 163 9.5 CGI和SSI 164...
然后到项目根目录下执行可运行jar, java -jar xxxxxx.jar 如果每次都这么搞的话,不仅慢,而且容易出错。 有了jenkins以后,发布流程可以是这样: 1.用户在jenkins上点击某个按钮进行发布 2.jenkins收到发布...
2.1.8 struts 2的运行流程分析—helloworld 48 2.1.9 struts 2的异常处理 52 2.2 struts 2配置精要 54 2.2.1 web.xml中struts 2的配置实现 54 2.2.2 struts 2属性配置文件struts.properties详解 55 2.2.3 ...