一、前言
通过jsch依赖包连接Linux服务器，java使用com.jcraft.jsch.ChannelExec代码提交"mkdir"创建目录，并 channel.chmod进行目录授权，具体参考下面代码示例。
二、代码示例
import java.io.File;@b@import java.io.FileInputStream;@b@import java.io.FileOutputStream;@b@import java.io.InputStream;@b@import java.util.Properties;@b@import java.util.Vector;@b@@b@import org.apache.commons.logging.Log;@b@import org.apache.commons.logging.LogFactory;@b@@b@import com.iss.pms.util.PropertieFileReader;@b@import com.jcraft.jsch.Channel;@b@import com.jcraft.jsch.ChannelExec;@b@import com.jcraft.jsch.ChannelSftp;@b@import com.jcraft.jsch.JSch;@b@import com.jcraft.jsch.Session;@b@import com.jcraft.jsch.SftpException;@b@ @b@public class SftpClient{ @b@ @b@ private static Log log = LogFactory.getLog(SftpClient.class);@b@ @b@ //off-关闭;on-打开@b@ private static String sftp_mode="off";@b@ @b@ private static String sftp_host="127.0.0.1";@b@ @b@ private static Integer sftp_port=22;@b@ @b@ private static String sftp_loginuser="root";@b@ @b@ private static String sftp_loginpassword="123456";@b@ @b@ @b@ static{@b@ sftp_mode=PropertieFileReader.getString("sftp_mode");@b@ sftp_host=PropertieFileReader.getString("sftp_host");@b@ sftp_port=Integer.parseInt(PropertieFileReader.getString("sftp_port"));@b@ sftp_loginuser=PropertieFileReader.getString("sftp_loginuser");@b@ sftp_loginpassword=PropertieFileReader.getString("sftp_loginpassword"); @b@ }@b@ @b@ /**@b@ * 判断sftp开关是否打开@b@ * @return@b@ */@b@ public static boolean isOk(){@b@ if("off".equalsIgnoreCase(sftp_mode)){@b@ return false;@b@ }else{@b@ return true;@b@ }@b@ }@b@ @b@ /**@b@ * 上传指定文件到服务器目录@b@ * @param directory 服务器目录 如"/home/tmp/", @b@ * @param uploadFile 本地文件"C:\\logs\\dps-engine_error.log"@b@ */@b@ public static void upload(String directory, String uploadFile){@b@ @b@ ChannelSftp login_channel=connect(sftp_host,sftp_port,sftp_loginuser,sftp_loginpassword);@b@ try {@b@ upload("/home/xwood/www"+directory,uploadFile,login_channel);@b@ } catch (Exception e) {@b@ e.printStackTrace();@b@ System.out.println("upload cause error:"+e.getMessage());@b@ }@b@ }@b@ @b@ /** @b@ * 链接sftp @b@ * @param host 主机 @b@ * @param port 端口 @b@ * @param username 用户名 @b@ * @param password 密码 @b@ * @return @b@ */ @b@ public static ChannelSftp connect(String host, int port, String username,String password) { @b@ @b@ ChannelSftp sftp = null; @b@ try { @b@ JSch jsch = new JSch(); @b@ jsch.getSession(username, host, port); @b@ Session sshSession = jsch.getSession(username, host, port); @b@ System.out.println("Session创建成功"); @b@ sshSession.setPassword(password); @b@ System.out.println("密码输入成功");@b@ Properties sshConfig = new Properties(); @b@ sshConfig.put("StrictHostKeyChecking", "no");@b@ System.out.println("链接参数设置成功");@b@ sshSession.setConfig(sshConfig); @b@ sshSession.connect(); @b@ System.out.println("Session已连接"); @b@ Channel channel = sshSession.openChannel("sftp"); @b@ channel.connect(); @b@ sftp = (ChannelSftp) channel; @b@ System.out.println("连接到主机" + host + "."); @b@ } catch (Exception e) { @b@ e.printStackTrace(); @b@ return null;@b@ } @b@ return sftp; @b@ } @b@ @b@ /** @b@ * 文件重命名 @b@ * @param directory 目录 @b@ * @param oldname 旧文件名 @b@ * @param newname 新文件名 @b@ * @param sftp @b@ */ @b@ public static void renameFile(String directory, String oldname, String newname, @b@ ChannelSftp sftp) { @b@ try { @b@ try {@b@ sftp.cd(directory);@b@ } catch (Exception e) {@b@ sftp.mkdir(directory);@b@ sftp.cd(directory);@b@ } @b@ sftp.rename(oldname, newname); @b@ } catch (Exception e) { @b@ e.printStackTrace(); @b@ } @b@ @b@ } @b@ @b@ /** @b@ * 文件上传 @b@ * @param directory 目录 @b@ * @param uploadFile 要上传的文件名 @b@ * @param sftp @b@ */ @b@ public static void upload(String directory, String uploadFile, ChannelSftp sftp) throws Exception{ @b@ Session sftpSession=null;@b@ ChannelExec channel=null;@b@ try { @b@ log.info("directory:"+directory+"@uploadFile:"+uploadFile);@b@ File existFile=new File(directory);@b@ if(!existFile.exists()){@b@ existFile.mkdirs();@b@ }@b@ @b@ try{ @b@ if(sftp==null){@b@ sftp=connect(sftp_host,sftp_port,sftp_loginuser,sftp_loginpassword);@b@ }@b@ sftp.cd(directory); @b@ }catch(Exception ee){@b@ if(sftp==null){@b@ sftp=connect(sftp_host,sftp_port,sftp_loginuser,sftp_loginpassword);@b@ } @b@ try{@b@ sftp.mkdir(directory);@b@ sftp.cd(directory);@b@ }catch(Exception eee){@b@ sftpSession=sftp.getSession();@b@ channel=(ChannelExec)sftpSession.openChannel("exec");@b@ channel.setCommand("mkdir "+directory);@b@ chmod(directory, "777", sftpSession); @b@ }@b@ } @b@ File file = new File(uploadFile); @b@ sftp.put(new FileInputStream(file), file.getName()); @b@ } catch (Exception e) { @b@ e.printStackTrace(); @b@ log.error("directory:"+directory+"@uploadFile:"+uploadFile,e);@b@ }finally{@b@ if(channel!=null)@b@ channel.disconnect();@b@ if(sftpSession!=null)@b@ sftpSession.disconnect();@b@ sftp.disconnect();@b@ @b@ } @b@ } @b@ @b@ @b@ public static void upload(String directory,String sftpFileName,InputStream input, ChannelSftp sftp) throws SftpException{@b@ try {@b@ sftp.cd(directory);@b@ } catch (Exception e) {@b@ sftp.mkdir(directory);@b@ sftp.cd(directory);@b@ }@b@ sftp.put(input, sftpFileName);@b@ }@b@ @b@ /** @b@ * 文件下载 @b@ * @param directory 目录 @b@ * @param downloadFile 要下载文件名 @b@ * @param saveFile 保持的文件名 @b@ * @param sftp @b@ */ @b@ public static void download(String directory, String downloadFile, @b@ String saveFile, ChannelSftp sftp) { @b@ try { @b@ sftp.cd(directory); @b@ File file = new File(saveFile); @b@ sftp.get(downloadFile, new FileOutputStream(file)); @b@ } catch (Exception e) { @b@ e.printStackTrace(); @b@ } @b@ } @b@ @b@ /** @b@ * 文件删除 @b@ * @param directory 目录 @b@ * @param deleteFile 要删除的文件名 @b@ * @param sftp @b@ */ @b@ public static void delete(String directory, String deleteFile, ChannelSftp sftp) { @b@ try { @b@ sftp.cd(directory); @b@ sftp.rm(deleteFile); @b@ System.out.println("删除成功"); @b@ } catch (Exception e) { @b@ System.out.println("删除失败"); @b@ e.printStackTrace(); @b@ } @b@ } @b@ @b@ /** @b@ * 列出目录下的文件 @b@ * @param directory 目录 @b@ * @param sftp @b@ * @return @b@ * @throws SftpException @b@ */ @b@ public static Vector listFiles(String directory, ChannelSftp sftp) @b@ throws SftpException { @b@ return sftp.ls(directory); @b@ } @b@ @b@ @b@ //批量删除文件@b@ public static void delete(String directory, String[] fileNames, ChannelSftp aa) {@b@ for (String fileName : fileNames) {@b@ delete(directory, fileName, aa);@b@ }@b@ }@b@ @b@ /**@b@ * 创建目录文件夹@b@ * @param directory 要创建文件夹的位置路径@b@ * @param fileName 要创建文件夹的名称@b@ * @param sftp sftp连接@b@ */@b@ public static void mkdir(String directory,String fileName,ChannelSftp sftp){@b@ try { @b@ try {@b@ sftp.cd(directory);@b@ } catch (Exception e) {@b@ sftp.mkdir(directory);@b@ sftp.cd(directory);@b@ } @b@ sftp.mkdir(fileName); @b@ System.out.println("文件夹创建成功"); @b@ } catch (Exception e) { @b@ System.out.println("文件夹创建失败"); @b@ e.printStackTrace(); @b@ } @b@ }@b@ @b@ public static void chmod(String fileLinux, String chmod, Session session) throws Exception { @b@ ChannelSftp channel = (ChannelSftp) session.openChannel("sftp"); @b@ channel.connect(); @b@ chmod(fileLinux, chmod, channel); @b@ channel.disconnect(); @b@@b@ } @b@@b@ private static void chmod(String fileLinux, String chmod, ChannelSftp channel) throws SftpException { @b@ int chmodInt = Integer.parseInt(chmod, 8); @b@ channel.chmod(chmodInt, fileLinux); @b@ } @b@@b@ @b@ @b@@b@ @b@ @b@ @b@ public static void main(String[] args) throws Exception{ @b@ @b@ SftpClient.upload("/_site_domain_/_root/5870/5874/", "C:/temp/t_c279528.html");@b@ @b@ }@b@ @b@ @b@ @b@ @b@ @b@ @b@ @b@}主要代码说明；没有文件夹执行创建并授权
sftpSession=sftp.getSession();@b@channel=(ChannelExec)sftpSession.openChannel("exec");@b@channel.setCommand("mkdir "+directory);@b@chmod(directory, "777", sftpSession);