JAVA SFTP文件上传、下载及批量下载实例

1.jsch官方API查看地址（附件为需要的jar）

http://www.jcraft.com/jsch/

2.jsch简介

JSch(Java Secure Channel)是一个SSH2的纯Java实现。它允许你连接到一个SSH服务器，并且可以使用端口转发，X11转发，文件传输等，当然你也可以集成它的功能到你自己的应用程序。

SFTP(Secure File Transfer Protocol)安全文件传送协议。可以为传输文件提供一种安全的加密方法。SFTP 为 SSH的一部份，是一种传输文件到服务器的安全方式，但是传输效率比普通的FTP要低。

3.api常用的方法：

put()：文件上传
get()：文件下载
cd()：进入指定目录
ls()：得到指定目录下的文件列表
rename()：重命名指定文件或目录
rm()：删除指定文件
mkdir()：创建目录
rmdir()：删除目录
put和get都有多个重载方法，自己看源代码

4.对常用方法的使用,封装成一个util类

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

236

237

238

239

240

241

242

243

244

245

246

247

248

249

250

251

252

253

254

255

256

257

258

259

260

261

262

263

264

265

266

267

268

269

270

271

272

273

274

275

276

277

278

279

280

281

282

283

284

285

286

287

288

289

290

291

292

293

294

295

296

297

298

299

300

301

302

303

304

305

306

307

308

309

310

311

312

313

314

315

316

317

318

319

320

321

322

323

324

325

326

327

328

329

330

331

332

333

334

335

336

337

338

339

340

341

342

343

344

345

346

347

348

349

350

351

352

353

354

355

356

357

358

359

360

361

362

363

364

365

366

367

368

369

370

371

372

373

374

375

376

377

378

379

380

381

382

383

384

385

386

387

388

389

390

391

392

393

394

395

import java.io.File;

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.FileOutputStream;

import java.io.IOException;

import java.util.ArrayList;

import java.util.Iterator;

import java.util.List;

import java.util.Properties;

import java.util.Vector;

import org.apache.log4j.Logger;

import com.jcraft.jsch.Channel;

import com.jcraft.jsch.ChannelSftp;

import com.jcraft.jsch.JSch;

import com.jcraft.jsch.Session;

import com.jcraft.jsch.SftpATTRS;

import com.jcraft.jsch.SftpException;

import com.jcraft.jsch.ChannelSftp.LsEntry;

/**

* sftp工具类

*

* @author xxx

* @date 2014-6-17

* @time 下午1:39:44

* @version 1.0

*/

public class SFTPUtils

{

private static Logger log = Logger.getLogger(SFTPUtils.class.getName());

private String host;//服务器连接ip

private String username;//用户名

private String password;//密码

private int port = 22;//端口号

private ChannelSftp sftp = null;

private Session sshSession = null;

public SFTPUtils(){}

public SFTPUtils(String host, int port, String username, String password)

{

this.host = host;

this.username = username;

this.password = password;

this.port = port;

}

public SFTPUtils(String host, String username, String password)

{

this.host = host;

this.username = username;

this.password = password;

}

/**

* 通过SFTP连接服务器

*/

public void connect()

{

try

{

JSch jsch = new JSch();

jsch.getSession(username, host, port);

sshSession = jsch.getSession(username, host, port);

if (log.isInfoEnabled())

{

log.info("Session created.");

}

sshSession.setPassword(password);

Properties sshConfig = new Properties();

sshConfig.put("StrictHostKeyChecking", "no");

sshSession.setConfig(sshConfig);

sshSession.connect();

if (log.isInfoEnabled())

{

log.info("Session connected.");

}

Channel channel = sshSession.openChannel("sftp");

channel.connect();

if (log.isInfoEnabled())

{

log.info("Opening Channel.");

}

sftp = (ChannelSftp) channel;

if (log.isInfoEnabled())

{

log.info("Connected to " + host + ".");

}

catch (Exception e)

{

e.printStackTrace();

}

/**

* 关闭连接

*/

public void disconnect()

{

if (this.sftp != null)

{

if (this.sftp.isConnected())

{

this.sftp.disconnect();

if (log.isInfoEnabled())

{

log.info("sftp is closed already");

}

if (this.sshSession != null)

{

if (this.sshSession.isConnected())

{

this.sshSession.disconnect();

if (log.isInfoEnabled())

{

log.info("sshSession is closed already");

}

/**

* 批量下载文件

* @param remotPath：远程下载目录(以路径符号结束,可以为相对路径eg:/assess/sftp/jiesuan_2/2014/)

* @param localPath：本地保存目录(以路径符号结束,D:\\Duansha\\sftp\\)

* @param fileFormat：下载文件格式(以特定字符开头,为空不做检验)

* @param fileEndFormat：下载文件格式(文件格式)

* @param del：下载后是否删除sftp文件

* @return

*/

public List<String> batchDownLoadFile(String remotePath, String localPath,

String fileFormat, String fileEndFormat, boolean del)

{

List<String> filenames = new ArrayList<String>();

try

{

// connect();

Vector v = listFiles(remotePath);

// sftp.cd(remotePath);

if (v.size() > 0)

{

System.out.println("本次处理文件个数不为零,开始下载...fileSize=" + v.size());

Iterator it = v.iterator();

while (it.hasNext())

{

LsEntry entry = (LsEntry) it.next();

String filename = entry.getFilename();

SftpATTRS attrs = entry.getAttrs();

if (!attrs.isDir())

{

boolean flag = false;

String localFileName = localPath + filename;

fileFormat = fileFormat == null ? "" : fileFormat

.trim();

fileEndFormat = fileEndFormat == null ? ""

: fileEndFormat.trim();

// 三种情况

if (fileFormat.length() > 0 && fileEndFormat.length() > 0)

{

if (filename.startsWith(fileFormat) && filename.endsWith(fileEndFormat))

{

flag = downloadFile(remotePath, filename,localPath, filename);

if (flag)

{

filenames.add(localFileName);

if (flag && del)

{

deleteSFTP(remotePath, filename);

}

else if (fileFormat.length() > 0 && "".equals(fileEndFormat))

{

if (filename.startsWith(fileFormat))

{

flag = downloadFile(remotePath, filename, localPath, filename);

if (flag)

{

filenames.add(localFileName);

if (flag && del)

{

deleteSFTP(remotePath, filename);

}

else if (fileEndFormat.length() > 0 && "".equals(fileFormat))

{

if (filename.endsWith(fileEndFormat))

{

flag = downloadFile(remotePath, filename,localPath, filename);

if (flag)

{

filenames.add(localFileName);

if (flag && del)

{

deleteSFTP(remotePath, filename);

}

else

{

flag = downloadFile(remotePath, filename,localPath, filename);

if (flag)

{

filenames.add(localFileName);

if (flag && del)

{

deleteSFTP(remotePath, filename);

}

if (log.isInfoEnabled())

{

log.info("download file is success:remotePath=" + remotePath

+ "and localPath=" + localPath + ",file size is"

+ v.size());

}

catch (SftpException e)

{

e.printStackTrace();

}

finally

{

// this.disconnect();

}

return filenames;

}

/**

* 下载单个文件

* @param remotPath：远程下载目录(以路径符号结束)

* @param remoteFileName：下载文件名

* @param localPath：本地保存目录(以路径符号结束)

* @param localFileName：保存文件名

* @return

*/

public boolean downloadFile(String remotePath, String remoteFileName,String localPath, String localFileName)

{

FileOutputStream fieloutput = null;

try

{

// sftp.cd(remotePath);

File file = new File(localPath + localFileName);

// mkdirs(localPath + localFileName);

fieloutput = new FileOutputStream(file);

sftp.get(remotePath + remoteFileName, fieloutput);

if (log.isInfoEnabled())

{

log.info("===DownloadFile:" + remoteFileName + " success from sftp.");

}

return true;

}

catch (FileNotFoundException e)

{

e.printStackTrace();

}

catch (SftpException e)

{

e.printStackTrace();

}

finally

{

if (null != fieloutput)

{

try

{

fieloutput.close();

}

catch (IOException e)

{

e.printStackTrace();

}

return false;

}

/**

* 上传单个文件

* @param remotePath：远程保存目录

* @param remoteFileName：保存文件名

* @param localPath：本地上传目录(以路径符号结束)

* @param localFileName：上传的文件名

* @return

*/

public boolean uploadFile(String remotePath, String remoteFileName,String localPath, String localFileName)

{

FileInputStream in = null;

try

{

createDir(remotePath);

File file = new File(localPath + localFileName);

in = new FileInputStream(file);

sftp.put(in, remoteFileName);

return true;

}

catch (FileNotFoundException e)

{

e.printStackTrace();

}

catch (SftpException e)

{

e.printStackTrace();

}

finally

{

if (in != null)

{

try

{

in.close();

}

catch (IOException e)

{

e.printStackTrace();

}

return false;

}

/**

* 批量上传文件

* @param remotePath：远程保存目录

* @param localPath：本地上传目录(以路径符号结束)

* @param del：上传后是否删除本地文件

* @return

*/

public boolean bacthUploadFile(String remotePath, String localPath,

boolean del)

{

try

{

connect();

File file = new File(localPath);

File[] files = file.listFiles();

for (int i = 0; i < files.length; i++)

{

if (files[i].isFile()

&& files[i].getName().indexOf("bak") == -1)

{

if (this.uploadFile(remotePath, files[i].getName(),

localPath, files[i].getName())

&& del)

{

deleteFile(localPath + files[i].getName());

}

if (log.isInfoEnabled())

{

log.info("upload file is success:remotePath=" + remotePath

+ "and localPath=" + localPath + ",file size is "

+ files.length);

}

return true;

}

catch (Exception e)

{

e.printStackTrace();

}

finally

{

this.disconnect();

}

return false;

}

/**

* 删除本地文件

* @param filePath

* @return

*/

public boolean deleteFile(String filePath)

{

File file = new File(filePath);

if (!file.exists())

{

return false;

}

if (!file.isFile())

{

5.需要的时间辅助类，顺带记下，下次可以直接拿来用

/**

* 时间处理工具类（简单的）

* @author Aaron

* @date 2014-6-17

* @time 下午1:39:44

* @version 1.0

*/

public class DateUtil {

/**

* 默认时间字符串的格式

*/

public static final String DEFAULT_FORMAT_STR = "yyyyMMddHHmmss";

public static final String DATE_FORMAT_STR = "yyyyMMdd";

/**

* 获取系统时间的昨天

* @return

*/

public static String getSysTime(){

Calendar ca = Calendar.getInstance();

ca.set(Calendar.DATE, ca.get(Calendar.DATE)-1);

Date d = ca.getTime();

SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");

String a = sdf.format(d);

return a;

}

/**

* 获取当前时间

* @param date

* @return

*/

public static String getCurrentDate(String formatStr)

{

if (null == formatStr)

{

formatStr=DEFAULT_FORMAT_STR;

}

return date2String(new Date(), formatStr);

}

/**

* 返回年月日

* @return yyyyMMdd

*/

public static String getTodayChar8(String dateFormat){

return DateFormatUtils.format(new Date(), dateFormat);

}

/**

* 将Date日期转换为String

* @param date

* @param formatStr

* @return

*/

public static String date2String(Date date, String formatStr)

{

if (null == date || null == formatStr)

{

return "";

}

SimpleDateFormat df = new SimpleDateFormat(formatStr);

return df.format(date);

}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持快网idc。

原文链接：http://www.cnblogs.com/meimao5211/p/6376597.html

JAVA SFTP文件上传、下载及批量下载实例

相关文章

快网idc优惠网

相关文章

微信

快网idc优惠网

QQ交流群