java

package com.xinnet.upload.util;

import java.io.ByteArrayInputStream;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.SocketException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.UUID;

import javax.servlet.http.HttpServletResponse;

import org.apache.commons.io.IOUtils;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPReply;
import org.apache.tika.Tika;
import org.springframework.web.multipart.MultipartFile;

import com.sun.accessibility.internal.resources.accessibility;

public class FtpClientUtil {
public final static Map mapFormat = new HashMap(); 
static { 
mapFormat.put("text/plain", "txt"); 
mapFormat.put("image/jpeg", "jpg"); 
} 

public String uploadImage(MultipartFile file, String url) {
String judge =  "0";// FTP客户端无法连接
FTPClient ftpClient = setFtpClient();
if (null == ftpClient || !ftpClient.isConnected()) {
return judge;
}
try {
// 创建目录

String fcPath = makePath(url);
String fc [] =fcPath.split("\\\\");
String urls="/";
for(int i =0; i<fc.length; i++){
ftpClient.makeDirectory(fc[i]);
urls=urls+"/"+fc[i];
ftpClient.changeWorkingDirectory(urls);
}
//ftpClient.makeDirectory(fcPath);
// 设置上传目录
//ftpClient.changeWorkingDirectory(fcPath);

ftpClient.setBufferSize(1024); // 缓冲区大小，非大文件。
ftpClient.setControlEncoding("UTF-8");
// 设置文件类型（二进制）
ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
String names =file.getOriginalFilename();
names=names.substring(names.lastIndexOf("."), names.length());
String fileName = UUID.randomUUID().toString() + names;
boolean  rsult=ftpClient.storeFile(fileName, file.getInputStream());
if(!rsult){
return "0";
}
judge="1";
String url_other = fcPath + "\\" + fileName;

judge = url_other.replace("\\", "/");
} catch (IOException e) {
e.printStackTrace();
throw new RuntimeException("FTP客户端出错！", e);
} finally {
if("0".equals(judge)){
return "0";
}
try {
IOUtils.closeQuietly(file.getInputStream());
ftpClient.disconnect();
} catch (IOException e) {
e.printStackTrace();
throw new RuntimeException("关闭FTP连接发生异常！", e);
}
}
return judge;

}

public String uploadBytes(byte[] data, String url) {
String judge =  "0";// FTP客户端无法连接
FTPClient ftpClient = setFtpClient();
if (null == ftpClient || !ftpClient.isConnected()) {
return judge;
}
try {
// 创建目录
InputStream is = new ByteArrayInputStream(data);
String fcPath = makePath(url);
String fc [] =fcPath.split("\\\\");
String urls="/";
for(int i =0; i<fc.length; i++){
ftpClient.makeDirectory(fc[i]);
urls=urls+"/"+fc[i];
ftpClient.changeWorkingDirectory(urls);
}
//ftpClient.makeDirectory(fcPath);
// 设置上传目录
//ftpClient.changeWorkingDirectory(fcPath);

ftpClient.setBufferSize(1024); // 缓冲区大小，非大文件。
ftpClient.setControlEncoding("UTF-8");
// 设置文件类型（二进制）
ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
String names ="a.jpg";
Tika tika = new Tika();
String format = tika.detect(is);
//设置下载文件名
String name=url;
if(StringUtils.isNotEmpty(url)){
if(url.lastIndexOf("/")>-1){
name= url.substring(url.lastIndexOf("/")+1, url.length());
}
}
names=names.substring(names.lastIndexOf("."), names.length());
String fileName = UUID.randomUUID().toString() + "."+mapFormat.get(format);
judge="1";
String url_other = fcPath + "\\" + fileName;

judge = url_other.replace("\\", "/");
   
boolean  rsult=ftpClient.storeFile(fileName, is);
if(!rsult){
return "0";
}
is.close();
} catch (IOException e) {
e.printStackTrace();
throw new RuntimeException("FTP客户端出错！", e);
} finally {
if("0".equals(judge)){
return "0";
}
try {
// IOUtils.closeQuietly(file.getInputStream());
ftpClient.disconnect();
} catch (IOException e) {
e.printStackTrace();
throw new RuntimeException("关闭FTP连接发生异常！", e);
}
}
return judge;

}

public static  String getFileType(byte[] bytes){
StringBuilder builder = new StringBuilder();
if (bytes == null || bytes.length <= 0) {
return null;
}
String hv;
for (int i = 0; i < bytes.length; i++) {
// 以十六进制（基数 16）无符号整数形式返回一个整数参数的字符串表示形式，并转换为大写
hv = Integer.toHexString(bytes[i] & 0xFF).toUpperCase();
if (hv.length() < 2) {
builder.append(0);
}
builder.append(hv);
}
System.out.println(builder.toString());
return builder.toString();
}

/**
* FTP下载单个文件测试
*/
public boolean testDownload(HttpServletResponse response, String url) {
FTPClient ftpClient = null;
if (StringUtils.isEmpty(url)) {
return false;
}
try {
ftpClient = setFtpClient();
if (null == ftpClient || !ftpClient.isConnected()) {
return false;
}
// "/userManager/2014/11/07/959578cb-8b98-4063-9c50-ae6af80bfa26.jpg";
ftpClient.setBufferSize(1024); // 缓冲区大小，非大文件。
// 设置文件类型（二进制）
ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
//ftpClient.retrieveFile(remoteFileName, fos);
InputStream bis = ftpClient.retrieveFileStream(url);
            if(bis==null){
            return false;
            }
           
Tika tika = new Tika();
String mimeType = tika.detect(url);
//设置下载文件名
String name=url;
if(StringUtils.isNotEmpty(url)){
if(url.lastIndexOf("/")>-1){
name= url.substring(url.lastIndexOf("/")+1, url.length());
}
}
//response.reset();
//response.setContentType("charset=GBK");
//response.addHeader("Content-Transfer-Encoding", "base64");// 字节编码，中文是双字节
    //response.addHeader("Content-Type", mimeType);// 文件类型
//response.setContentType(mimeType+";charset=utf-8");
response.addHeader("content-disposition","attachment;filename=" + name);
response.setHeader("content-type",mimeType+";charset=utf-8");
response.setContentType("application/x-download");

//response.setContentType(mimeType);
OutputStream out = response.getOutputStream();
byte[] buffer = new byte[4096]; // 有待考虑
int size = 0;
while ((size = bis.read(buffer, 0, buffer.length)) != -1) {
out.write(buffer, 0, size);
}
} catch (IOException e) {
return false;
// e.printStackTrace();
// throw new RuntimeException("FTP客户端出错！", e);
} finally {
// IOUtils.closeQuietly(fos);
try {
ftpClient.disconnect();
} catch (IOException e) {
e.printStackTrace();
throw new RuntimeException("关闭FTP连接发生异常！", e);
}
}
return true;
}

private FTPClient setFtpClient() {
FTPClient ftpClient = new FTPClient();
int judge = 0;
try {
ftpClient.connect(FtpUploadProperties.get("ftpUpload.host"));
int reply = ftpClient.getReplyCode();

            if (!FTPReply.isPositiveCompletion(reply)) { 
            ftpClient.disconnect(); 
                return ftpClient;
            } 
boolean result =ftpClient.login(FtpUploadProperties.get("ftpUpload.username"), FtpUploadProperties.get("ftpUpload.password"));
if(result==false){
            ftpClient.disconnect(); 
                return ftpClient;
}
judge = 1;
} catch (SocketException e) {

} catch (IOException e) {

} finally {
if (judge == 0) {

return ftpClient;
}
}

return ftpClient;
}

private static String makePath(String form) {
// 年月日生成三级目录
String sep = "\\";
SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd");
String[] date = sf.format(new Date()).split("-");
StringBuffer sb = new StringBuffer();
sb.append(sep);
sb.append(form);
sb.append(sep);
sb.append(date[0]);
sb.append(sep);
sb.append(date[1]);
sb.append(sep);
sb.append(date[2]);
return sb.toString();
}

public static void main(String[] args) {
/* String names = "wqeqweqweqqweqw1";
names=names.substring(names.lastIndexOf("."), names.length());
System.out.println(names);
String fcPath = "\\123\\123\\1\\12\\12\\";
String fc [] =fcPath.split("\\\\");
for(int i =0; i<fc.length; i++){
System.out.println(fc[i]);
}*/
InputStream is;
try {
is = new FileInputStream("d:/文档.docx");
byte[] contentData = new byte[3]; 
is.read(contentData,0,contentData.length); 
getFileType(contentData);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}


}
}