Question

求助,哪位大侠可以提供一个java断点"上传"的例子,或者思路? 要上传的,不是下载

Answer 1

JAVA实现FTP断点上传
疯狂的流浪 发布于 2010年12月17日 13时 (0评) 12人收藏此代码， 我要收藏(?)
主要使用apache中的net包来实现。网址http://commons.apache.org/net/。具体包的下载和API文档请看官网。 断点上传就是在上传的过程中设置传输的起始位置。并设置二进制传输。
标签： Commons Net , FTP , 断点 , 上传
代码片段(1)
[代码] [Java]代码
view sourceprint?001 import java.io.File;

002 import java.io.FileInputStream;

003 import java.io.FileOutputStream;

004 import java.io.IOException;

005 import java.io.InputStream;

006 import java.io.OutputStream;

007 import java.io.PrintWriter;

008 import org.apache.commons.net.PrintCommandListener;

009 import org.apache.commons.net.ftp.FTP;

010 import org.apache.commons.net.ftp.FTPClient;

011 import org.apache.commons.net.ftp.FTPFile;

012 import org.apache.commons.net.ftp.FTPReply;

013

014 public class ContinueFTP {

015 private FTPClient ftpClient = new FTPClient();

016

017 public ContinueFTP(){

018 //设置将过程中使用到的命令输出到控制台

019 this.ftpClient.addProtocolCommandListener(new PrintCommandListener(new PrintWriter(System.out)));

020 }

021

022 /**

023 * java编程中用于连接到FTP服务器

024 * @param hostname 主机名

025 * @param port 端口

026 * @param username 用户名

027 * @param password 密码

028 * @return 是否连接成功

029 * @throws IOException

030 */

031 public boolean connect(String hostname,int port,String username,String password) throws IOException{

032 ftpClient.connect(hostname, port);

033 if(FTPReply.isPositiveCompletion(ftpClient.getReplyCode())){

034 if(ftpClient.login(username, password)){

035 return true;

036 }

037 }

038 disconnect();

039 return false;

040 }

041

042 /**

043 * 从FTP服务器上下载文件

044 * @param remote 远程文件路径

045 * @param local 本地文件路径

046 * @return 是否成功

047 * @throws IOException

048 */

049 public boolean download(String remote,String local) throws IOException{

050 ftpClient.enterLocalPassiveMode();

051 ftpClient.setFileType(FTP.BINARY_FILE_TYPE);

052 boolean result;

053 File f = new File(local);

054 FTPFile[] files = ftpClient.listFiles(remote);

055 if(files.length != 1){

056 System.out.println("远程文件不唯一");

057 return false;

058 }

059 long lRemoteSize = files[0].getSize();

060 if(f.exists()){

061 OutputStream out = new FileOutputStream(f,true);

062 System.out.println("本地文件大小为:"+f.length());

063 if(f.length() >= lRemoteSize){

064 System.out.println("本地文件大小大于远程文件大小，下载中止");

065 return false;

066 }

067 ftpClient.setRestartOffset(f.length());

068 result = ftpClient.retrieveFile(remote, out);

069 out.close();

070 }else {

071 OutputStream out = new FileOutputStream(f);

072 result = ftpClient.retrieveFile(remote, out);

073 out.close();

074 }

075 return result;

076 }

077

078 /**

079 * 上传文件到FTP服务器，支持断点续传

080 * @param local 本地文件名称，绝对路径

081 * @param remote 远程文件路径，使用/home/directory1/subdirectory/file.ext 按照Linux上的路径指定方式，支持多级目录嵌套，支持递归创建不存在的目录结构

082 * @return 上传结果

083 * @throws IOException

084 */

085 public UploadStatus upload(String local,String remote) throws IOException{

086 //设置PassiveMode传输

087 ftpClient.enterLocalPassiveMode();

088 //设置以二进制流的方式传输

089 ftpClient.setFileType(FTP.BINARY_FILE_TYPE);

090 UploadStatus result;

091 //对远程目录的处理

092 String remoteFileName = remote;

093 if(remote.contains("/")){

094 remoteFileName = remote.substring(remote.lastIndexOf("/")+1);

095 String directory = remote.substring(0,remote.lastIndexOf("/")+1);

096 if(!directory.equalsIgnoreCase("/")&&!ftpClient.changeWorkingDirectory(directory)){

097 //如果远程目录不存在，则递归创建远程服务器目录

098 int start=0;

099 int end = 0;

100 if(directory.startsWith("/")){

101 start = 1;

102 }else{

103 start = 0;

104 }

105 end = directory.indexOf("/",start);

106 while(true){

107 String subDirectory = remote.substring(start,end);

108 if(!ftpClient.changeWorkingDirectory(subDirectory)){

109 if(ftpClient.makeDirectory(subDirectory)){

110 ftpClient.changeWorkingDirectory(subDirectory);

111 }else {

112 System.out.println("创建目录失败");

113 return UploadStatus.Create_Directory_Fail;

114 }

115 }

116

117 start = end + 1;

118 end = directory.indexOf("/",start);

119

120 //检查所有目录是否创建完毕

121 if(end <= start){

122 break;

123 }

124 }

125 }

126 }

127

128 //检查远程是否存在文件

129 FTPFile[] files = ftpClient.listFiles(remoteFileName);

130 if(files.length == 1){

131 long remoteSize = files[0].getSize();

132 File f = new File(local);

133 long localSize = f.length();

134 if(remoteSize==localSize){

135 return UploadStatus.File_Exits;

136 }else if(remoteSize > localSize){

137 return UploadStatus.Remote_Bigger_Local;

138 }

139

140 //尝试移动文件内读取指针,实现断点续传

141 InputStream is = new FileInputStream(f);

142 if(is.skip(remoteSize)==remoteSize){

143 ftpClient.setRestartOffset(remoteSize);

144 if(ftpClient.storeFile(remote, is)){

145 return UploadStatus.Upload_From_Break_Success;

146 }

147 }

148

149 //如果断点续传没有成功，则删除服务器上文件，重新上传

150 if(!ftpClient.deleteFile(remoteFileName)){

151 return UploadStatus.Delete_Remote_Faild;

152 }

153 is = new FileInputStream(f);

154 if(ftpClient.storeFile(remote, is)){

155 result = UploadStatus.Upload_New_File_Success;

156 }else{

157 result = UploadStatus.Upload_New_File_Failed;

158 }

159 is.close();

160 }else {

161 InputStream is = new FileInputStream(local);

162 if(ftpClient.storeFile(remoteFileName, is)){

163 result = UploadStatus.Upload_New_File_Success;

164 }else{

165 result = UploadStatus.Upload_New_File_Failed;

166 }

167 is.close();

168 }

169 return result;

170 }

171 /**

172 * 断开与远程服务器的连接

173 * @throws IOException

174 */

175 public void disconnect() throws IOException{

176 if(ftpClient.isConnected()){

177 ftpClient.disconnect();

178 }

179 }

180

181 public static void main(String[] args) {

182 ContinueFTP myFtp = new ContinueFTP();

183 try {

184 myFtp.connect("192.168.21.171", 21, "test", "test");

185 System.out.println(myFtp.upload("E:\\VP6.flv", "/MIS/video/VP6.flv"));

186 myFtp.disconnect();

187 } catch (IOException e) {

188 System.out.println("连接FTP出错："+e.getMessage());

189 }

190 }

191 }

Answer 2

网上过于实现文件上传到文章是非常的多，开源项目也有不少，就我所查到的几篇文章中，有些方法过时，有些项目已经不再维护了。再此，以我所使用的进行一下总结。已经实现正常上传……

1，JSP页面

Java代码
<center>
<h1>文件上传</h1>
<form name="uploadform"method="post" action="adddata" ENCTYPE="multipart/form-data">
<table border="1"width="450"cellpadding="4" cellspacing="2"bordercolor="#9BD7FF">
<tr><td width="100%"colspan="2">
文件：<input name="file1"size="40"type="file">
</td></tr>
</table>
<table>
<tr><td align="center"><input name="upload" type="submit"value="上传"/></td></tr>
</table>
</form>
</center>

要实现文件上传，在form标签内必须包含 ENCTYPE="multipart/form-data" 才可以实现(RFC1867协议：http://www.faqs.org/rfcs/rfc1867.html)，且必须以 POST 方式上传。

2，web.xml 配置

Xml代码
<servlet>
<servlet-name>AddDataServlet</servlet-name>
<servlet-class>kxjh.AddDataServlet</servlet-class>
</servlet>
<servlet-mapping>
<servlet-name>AddDataServlet</servlet-name>
<url-pattern>/adddata</url-pattern>
</servlet-mapping>

3，Servelt 实现(commons-fileupload-1.2.1、commons-io-1.4)

Java代码
// 解析 request，判断是否有上传文件
boolean isMultipart = ServletFileUpload.isMultipartContent(request);
if (isMultipart) {
// 创建磁盘工厂，利用构造器实现内存数据储存量和临时储存路径
DiskFileItemFactory factory = new DiskFileItemFactory(1024 * 4, new File("D:\\Temp"));
// 设置最多只允许在内存中存储的数据,单位:字节
// factory.setSizeThreshold(4096);
// 设置文件临时存储路径
// factory.setRepository(new File("D:\\Temp"));
// 产生一新的文件上传处理程式
ServletFileUpload upload = new ServletFileUpload(factory);
// 设置路径、文件名的字符集
upload.setHeaderEncoding("UTF-8");
// 设置允许用户上传文件大小,单位:字节
upload.setSizeMax(1024 * 1024 * 100);
// 解析请求，开始读取数据
// Iterator<FileItem> iter = (Iterator<FileItem>) upload.getItemIterator(request);
// 得到所有的表单域，它们目前都被当作FileItem
List<FileItem> fileItems = upload.parseRequest(request);
// 依次处理请求
Iterator<FileItem> iter = fileItems.iterator();
while (iter.hasNext()) {
FileItem item = (FileItem) iter.next();
if (item.isFormField()) {
// 如果item是正常的表单域
String name = item.getFieldName();
String value = item.getString("UTF-8");
System.out.println("表单域名为:"+name+"表单域值为:"+value);
} else {
// 如果item是文件上传表单域
// 获得文件名及路径
String fileName = item.getName();
if (fileName != null) {
// 如果文件存在则上传
File fullFile = new File(item.getName());
if (fullFile.exists()) {
File fileOnServer = new File("D:\\My Documents\\" + fullFile.getName());
item.write(fileOnServer);
System.out.println("文件" + fileOnServer.getName() + "上传成功");
}
}
}
}
}

利用ccommons-fileupload-1.2.1实现上传，其实现必须包含commons-io-1.4，以上为我实现上传文件所使用的方法和所用到包的版本。

总结：以正常实现文件上传功能，在实现过程中如果form未配置 ENCTYPE="multipart/form-data" 元素，
则上传文件为本地的绝对路径，而非正常的文件。
详细使用参考api文档。