代码:
FtpTool
package com.wirelesscity.tools.ftp;
import java.io.ByteArrayOutputStream;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.ArrayList;
import java.util.StringTokenizer;
import com.wirelesscity.common.StringUtil;
import sun.net.TelnetInputStream;
import sun.net.TelnetOutputStream;
import sun.net.ftp.FtpClient;
@SuppressWarnings("restriction")
public class FtpTool {
private FtpClient ftpclient;
private String ipAddress; // FTP地址
private int ipPort; // 端口
private String userName; // 用户名
private String PassWord; // 密码
/**
* 初始化参数FTPTOOL对象
* @param ipAddress
* @param ipPort
* @param userName
* @param PassWord
* @throws IOException
*/
public FtpTool(String ip, int port, String username, String password)
throws IOException {
ipAddress = new String(ip);
ipPort = port;
if (StringUtil.isEmpty(String.valueOf(port))) {
port = 21;
}
ftpclient = new FtpClient(ipAddress, ipPort);
userName = new String(username);
PassWord = new String(password);
}
/**
* 登录FTP服务器
*
* @throws Exception
*/
public void login() throws Exception {
ftpclient.login(userName, PassWord);
}
/**
* 退出FTP服务器
*
* @throws Exception
*/
public void logout() throws Exception {
// 用ftpclient.closeServer()断开FTP出错时用下更语句退出
ftpclient.sendServer("QUIT\r\n");
int reply = ftpclient.readServerResponse(); // 取得服务器的返回信息
System.out.println("reply:" + reply);
}
/**
* 在FTP服务器上建立指定的目录,当目录已经存在的情下不会影响目录下的文件,这样用以判断FTP
* 上传文件时保证目录的存在目录格式必须以"/"根目录开头
*
* @param pathList
* String
* @throws Exception
*/
public void buildList(String pathList) throws Exception {
ftpclient.ascii();
StringTokenizer s = new StringTokenizer(pathList, "/"); // sign
int count = s.countTokens();
String pathName = "";
while (s.hasMoreElements()) {
pathName = pathName + "/" + (String) s.nextElement();
try {
ftpclient.sendServer("XMKD " + pathName + "\r\n");
} catch (Exception e) {
e = null;
}
int reply = ftpclient.readServerResponse();
}
ftpclient.binary();
}
/**
* 取得指定目录下的所有文件名,不包括目录名称 分析nameList得到的输入流中的数,得到指定目录下的所有文件名
*
* @param fullPath
* String
* @return ArrayList
* @throws Exception
*/
public ArrayList fileNames(String fullPath) throws Exception {
ftpclient.ascii(); // 注意,使用字符模式
TelnetInputStream list = ftpclient.nameList(fullPath);
byte[] names = new byte[2048];
int bufsize = 0;
bufsize = list.read(names, 0, names.length); // 从流中读取
list.close();
ArrayList namesList = new ArrayList();
int i = 0;
int j = 0;
while (i < bufsize) {
if (names[i] == 10) { // 字符模式为10,二进制模式为13
// 文件名在数据中开始下标为j,i-j为文件名的长度,文件名在数据中的结束下标为i-1
String tempName = new String(names, j, i - j);
namesList.add(tempName);
j = i + 1; // 上一次位置字符模式
}
i = i + 1;
}
return namesList;
}
/**
* 上传文件到FTP服务器,destination路径以FTP服务器的"/"开始,带文件名、 上传文件只能使用二进制模式,当文件存在时再次上传则会覆盖
*
* @param source
* String
* @param destination
* String
* @throws Exception
*/
public void upFile(String source, String destination) throws Exception {
buildList(destination.substring(0, destination.lastIndexOf("/")));
ftpclient.binary(); // 此行代码必须放在buildList之后
TelnetOutputStream ftpOut = ftpclient.put(destination);
TelnetInputStream ftpIn = new TelnetInputStream(new FileInputStream(
source), true);
byte[] buf = new byte[204800];
int bufsize = 0;
while ((bufsize = ftpIn.read(buf, 0, buf.length)) != -1) {
ftpOut.write(buf, 0, bufsize);
}
ftpIn.close();
ftpOut.close();
}
/**
* JSP中的流上传到FTP服务器, 上传文件只能使用二进制模式,当文件存在时再次上传则会覆盖 字节数组做为文件的输入流,此方法适用于JSP中通过
* request输入流来直接上传文件在RequestUpload类中调用了此方法, destination路径以FTP服务器的"/"开始,带文件名
*
* @param sourceData
* byte[]
* @param destination
* String
* @throws Exception
*/
public void upFile(byte[] sourceData, String destination) throws Exception {
buildList(destination.substring(0, destination.lastIndexOf("/")));
ftpclient.binary(); // 此行代码必须放在buildList之后
TelnetOutputStream ftpOut = ftpclient.put(destination);
ftpOut.write(sourceData, 0, sourceData.length);
// ftpOut.flush();
ftpOut.close();
}
/**
* 从FTP文件服务器上下载文件SourceFileName,到本地destinationFileName 所有的文件名中都要求包括完整的路径名在内
*
* @param SourceFileName
* String
* @param destinationFileName
* String
* @throws Exception
*/
public void downFile(String SourceFileName, String destinationFileName)
throws Exception {
ftpclient.binary(); // 一定要使用二进制模式
TelnetInputStream ftpIn = ftpclient.get(SourceFileName);
byte[] buf = new byte[204800];
int bufsize = 0;
FileOutputStream ftpOut = new FileOutputStream(destinationFileName);
while ((bufsize = ftpIn.read(buf, 0, buf.length)) != -1) {
ftpOut.write(buf, 0, bufsize);
}
ftpOut.close();
ftpIn.close();
}
/**
* 从FTP文件服务器上下载文件,输出到字节数组中
*
* @param SourceFileName
* String
* @return byte[]
* @throws Exception
*/
public byte[] downFile(String SourceFileName) throws Exception {
ftpclient.binary(); // 一定要使用二进制模式
TelnetInputStream ftpIn = ftpclient.get(SourceFileName);
ByteArrayOutputStream byteOut = new ByteArrayOutputStream();
byte[] buf = new byte[204800];
int bufsize = 0;
while ((bufsize = ftpIn.read(buf, 0, buf.length)) != -1) {
byteOut.write(buf, 0, bufsize);
}
byte[] return_arraybyte = byteOut.toByteArray();
byteOut.close();
ftpIn.close();
return return_arraybyte;
}
}
FtpServiceImpl
package com.wirelesscity.tools.ftp;
import java.io.IOException;
public class FtpServiceImpl implements FtpService{
private String ftpIpAddress;
private int ftpPort;
private String ftpUserName;
private String ftpPassword;
//FTP路径配置
private String ftpLocalPathRoot;
private String ftpRemotePathRoot;
public String getFtpLocalPathRoot() {
return ftpLocalPathRoot;
}
public void setFtpLocalPathRoot(String ftpLocalPathRoot) {
this.ftpLocalPathRoot = ftpLocalPathRoot;
}
public String getFtpRemotePathRoot() {
return ftpRemotePathRoot;
}
public void setFtpRemotePathRoot(String ftpRemotePathRoot) {
this.ftpRemotePathRoot = ftpRemotePathRoot;
}
public void setFtpIpAddress(String ftpIpAddress) {
this.ftpIpAddress = ftpIpAddress;
}
public void setFtpPort(int ftpPort) {
this.ftpPort = ftpPort;
}
public void setFtpUserName(String ftpUserName) {
this.ftpUserName = ftpUserName;
}
public void setFtpPassword(String ftpPassword) {
this.ftpPassword = ftpPassword;
}
public String getFtpIpAddress() {
return ftpIpAddress;
}
public int getFtpPort() {
return ftpPort;
}
public String getFtpUserName() {
return ftpUserName;
}
public String getFtpPassword() {
return ftpPassword;
}
public void testUpload(){
// TODO Auto-generated method stub
try {
FtpTool ftpTool = new FtpTool(this.getFtpIpAddress(),
this.getFtpPort(), this.getFtpUserName(),
this.getFtpPassword());
ftpTool.login();
ftpTool.buildList("file/user/tttt");
String source = "D:/config.rar";
String destination = "/file/user/tttt/test.jar";
ftpTool.upFile(source, destination);
ftpTool.logout();
} catch (IOException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 建立文件夹路径
* @param pathList
* @throws Exception
*/
public void buildList(String pathList) throws Exception{
FtpTool ftpTool = new FtpTool(this.getFtpIpAddress(),
this.getFtpPort(), this.getFtpUserName(),
this.getFtpPassword());
ftpTool.login();
ftpTool.buildList(pathList);
ftpTool.logout();
}
/**
* 上传文件到FTP服务器,
* destination路径以FTP服务器的"/"开始,
* 带文件名、 上传文件只能使用二进制模式,当文件存在时再次上传则会覆盖
* @param source
* String
* @param destination
* String
* @throws Exception
*/
public void upFile(String source, String destination) throws Exception{
FtpTool ftpTool = new FtpTool(this.getFtpIpAddress(),
this.getFtpPort(), this.getFtpUserName(),
this.getFtpPassword());
ftpTool.login();
ftpTool.upFile(source, destination);
ftpTool.logout();
}
/**
* JSP中的流上传到FTP服务器, 上传文件只能使用二进制模式,当文件存在时再次上传则会覆盖 字节数组做为文件的输入流,此
* 方法适用于JSP中通过
* request输入流来直接上传文件在RequestUpload类中调用了此方法,
* destination路径以FTP服务器的"/"开始,带文件名
* @param sourceData
* byte[]
* @param destination
* String
* @throws Exception
*/
public void upFile(byte[] sourceData, String destination) throws Exception {
FtpTool ftpTool = new FtpTool(this.getFtpIpAddress(),
this.getFtpPort(), this.getFtpUserName(),
this.getFtpPassword());
ftpTool.login();
ftpTool.upFile(sourceData, destination);
ftpTool.logout();
}
/**
* @param args
*/
public static void main(String[] args) {
FtpServiceImpl ftpUtil=new FtpServiceImpl();
ftpUtil.testUpload();
}
}
FtpService:
package com.wirelesscity.tools.ftp;
public interface FtpService{
public String getFtpLocalPathRoot() ;
public String getFtpRemotePathRoot();
public void testUpload();
/**
* 建立文件夹路径
* @param pathList
* @throws Exception
*/
public void buildList(String pathList) throws Exception;
/**
* 上传文件到FTP服务器,
* destination路径以FTP服务器的"/"开始,
* 带文件名、 上传文件只能使用二进制模式,当文件存在时再次上传则会覆盖
* @param source
* String
* @param destination
* String
* @throws Exception
*/
public void upFile(String source, String destination) throws Exception;
/**
* JSP中的流上传到FTP服务器, 上传文件只能使用二进制模式,当文件存在时再次上传则会覆盖 字节数组做为文件的输入流,此
* 方法适用于JSP中通过
* request输入流来直接上传文件在RequestUpload类中调用了此方法,
* destination路径以FTP服务器的"/"开始,带文件名
* @param sourceData
* byte[]
* @param destination
* String
* @throws Exception
*/
public void upFile(byte[] sourceData, String destination) throws Exception ;
}
分享到:
相关推荐
从GRI(Ghost Rider Igniter)应用php开发框架中提取出的公用web功能组件,包括列表,图,日期,月份选择器,上传等。微信公众平台用到 文件列表 jQuery.min.js 官方jQuery v1.7.2版本 gri.controls.css 组件的...
C#操作FTP公用类,FTP上传下载公用类
关于附件上传至FTP服务器中的相关配置和方法
基于vue + element-ui + vuex的记忆多选表格弹框,公用组件用法。
一个已经包装好的分页组件,适合struts框架使用、这样,大家就不用麻烦自己写分页代码了。
本文介绍了vue 将页面公用的头部组件化的方法,分享给大家,具体如下: 呃……重新捡起前面用vue-cli快速生成的项目。 之前是做过一个多页面的改造,以及引入vux的ui组件,这次在这个项目的基础上,再来聊聊vue中的...
SocketTestDlg3.43.exe Socket和UDP一个公用的工具
ASP.NET访问数据库的公用类组件(支持多种数据库),很实用
基于vue + element-ui + vuex的记忆多选表格弹框,公用组件源码。
footer为公用组件,其他页面都需要引入。接下来通过本文给大家分享vue项目中公用footer组件底部位置的适配问题,需要的朋友可以参考下
本文档中描述的协议约定满足Internet公用密钥机制(PKI)中的许多可操作的需求.本文档同时讲述了一些使用文件传输协议(FTP)和超文本传输协议(HTTP)来从PKI仓库中获取证书和证书撤消列表(CRL)的协定. 附加的描述访问PKI...
vue项目前端导出数据到Excel,引用的公用组件
公用对话框,经典 公用对话框 公用对话框 公用对话框 公用对话框
1.修正了1.2版本在数量词处理的缺陷 2.优化分词性能 3.优化词典 请参考lucene中文分词公用组件V1.2之前版本使用说明
里面包括了对ftp创建文件夹,删除文件夹,查看文件夹,查看文件,以及查看文件和文件夹,上传和下载
在lucene中文分词公用组件V1.3基础上做一下更新: 1.修订特定情况下数量词切分造成指针越界异常的BUG 2.进一步优化算法效率 3.优化词典 4.对英文和数词更改为分割处理
公用工具领用登记表格式.doc
** * mysql数据库的通用操作类 * 主要包括查询结果集并封装成list的形式 * 数据库的插入、更新、删除操作(两种方式,包含事物的处理和不包含事物的处理) * 注意:在查询结果封装成list的方法中 ...
在vue的实际开发中往往会遇到公用一个组件的问题,比如有一个菜单中的两个按钮,点击每个按钮调用的是同一个组件,其内容是根据路由的参数的不同来请求不同的内容。 第一步,首先新建一个vue+webpack+vuecli的demo,...