package com.vci.server.volume;
|
|
import java.io.BufferedInputStream;
|
import java.io.BufferedOutputStream;
|
import java.io.File;
|
import java.io.FileInputStream;
|
import java.io.FileOutputStream;
|
import java.io.RandomAccessFile;
|
import java.io.UnsupportedEncodingException;
|
import java.math.BigInteger;
|
import java.net.InetAddress;
|
import java.net.UnknownHostException;
|
import java.security.MessageDigest;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.Hashtable;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.concurrent.Callable;
|
import java.util.concurrent.ConcurrentHashMap;
|
import java.util.concurrent.ExecutionException;
|
import java.util.concurrent.ExecutorService;
|
import java.util.concurrent.Executors;
|
import java.util.concurrent.Future;
|
|
import org.apache.commons.lang3.StringUtils;
|
|
import com.vci.common.ServiceNames;
|
import com.vci.corba.common.VCIError;
|
import com.vci.corba.volume.VolumeService;
|
import com.vci.corba.volume.data.FileInfo;
|
import com.vci.corba.framework.data.PvolumeInfo;
|
import com.vci.corba.volume.data.VolumeUseInfo;
|
import com.vci.server.BaseService;
|
import com.vci.server.base.utility.ServerServiceProvider;
|
import com.vci.server.cache.OMCacheProvider;
|
import com.vci.server.cache.VolumeCacheProvider;
|
import com.vci.server.volume.delegate.FileControl;
|
import com.vci.server.volume.delegate.RC4;
|
import com.vci.server.volume.objects.VolumeFileUploadStatusInfo;
|
import com.vci.server.volume.uitls.EncryFileUtil;
|
import com.vci.server.volume.uitls.VolumeProperties;
|
import com.vci.server.volume.uitls.VolumeWithLog4j;
|
import com.zeroc.Ice.Current;
|
|
/**
|
* <p>Title: </p>
|
* <p>Description: </p>
|
* <p>Copyright: Copyright (c) 2011</p>
|
* <p>Company: VCI</p>
|
* @author Administrator
|
* @time 2011-7-3
|
* @version 1.0
|
*/
|
public class VolumeServiceImpl extends BaseService implements VolumeService{
|
|
int blockLength = 0;
|
int intBackUpCount = 0;
|
Boolean isFileEncry = false;
|
Boolean isReadOnly = false;
|
FileControl fileControl = new FileControl();
|
|
String fileKey = "vci@2008";
|
|
//PvolumeDelegate _volDelegate = new PvolumeDelegate();
|
|
Hashtable<String, PvolumeInfo> mapVolumn = new Hashtable<String, PvolumeInfo>();
|
Hashtable<String, RandomAccessFile> hashtable = new Hashtable<String, RandomAccessFile>();
|
|
public VolumeServiceImpl() {
|
try {
|
blockLength = VolumeProperties.blockLength() * 1024;
|
intBackUpCount = VolumeProperties.historyCopyCount();
|
|
isFileEncry = VolumeProperties.isFileEncry();
|
|
isReadOnly = VolumeProperties.isReadOnly();
|
|
} catch (Exception e) {
|
//e.printStackTrace();
|
VolumeWithLog4j.logger.error(e);
|
}
|
}
|
|
@Override
|
public String getServiceName() {
|
return VolumeProperties.VolumeServiceName();
|
}
|
|
|
/**
|
* 获取文件的更改时间
|
*/
|
public long getFileModifiedTime(String fileName, Current current) throws VCIError {
|
fileName = hanlderOS(fileName);
|
long modifiedTime = 0;
|
try {
|
File currentFile = new File(fileName);
|
if (!currentFile.exists()) {
|
throw new VCIError("710001", new String[]{fileName});
|
}
|
modifiedTime = currentFile.lastModified();
|
} catch (Exception g) {
|
//g.printStackTrace();
|
VolumeWithLog4j.logger.error("710002", g);
|
throw new VCIError("710002", new String[0]);
|
}
|
return modifiedTime;
|
}
|
|
/**
|
* 获取文件大小
|
*/
|
public long getFileSize(String fileName, Current current) throws VCIError {
|
fileName = hanlderOS(fileName);
|
long size = -1;
|
try {
|
File file = new File(fileName);
|
if (!file.exists()) {
|
throw new VCIError("710001", new String[0]);//服务器端文件不存在！
|
}
|
boolean isEncry = EncryFileUtil.isEncryFile(file);
|
|
size = file.length() - (isEncry ? EncryFileUtil.ENCRYHEADERSIZE : 0);
|
} catch (Exception g) {
|
//g.printStackTrace();
|
VolumeWithLog4j.logger.error("710003", g);
|
throw new VCIError("710003", new String[1]);//获取服务器端文件大小出错，请重新获取！
|
}
|
return size;
|
}
|
|
private Map<String, VolumeFileUploadStatusInfo> uploadStateInfoMap = new ConcurrentHashMap<String, VolumeFileUploadStatusInfo>();
|
/**
|
* receive one subsection of file from client everytime,and save them into
|
* a temporary file. When finished, save the file name into the rigth one.
|
*/
|
public boolean receiveFile(String fileName, byte[] data, long pointoffile,
|
long modifiedtime, long filesize, Current current) throws VCIError {
|
|
if (isReadOnly)
|
throw new VCIError("710000", new String[0]);//("服务器端文件已锁定,请稍后再试！");
|
|
fileName = hanlderOS(fileName);
|
String TempProfix = getTempFileSufixx(); //临时文件后缀
|
File newfile = new File(fileName + TempProfix);
|
if (pointoffile == 0 && !fileControl.lockWrite(fileName + TempProfix)) {
|
throw new VCIError("710004", new String[0]);//("服务器端文件已锁定,请稍后再试！");
|
}
|
|
boolean islast = false;
|
boolean alreadExistInMap = uploadStateInfoMap.containsKey(fileName);
|
VolumeFileUploadStatusInfo uploadInfo = new VolumeFileUploadStatusInfo();
|
if(alreadExistInMap){
|
uploadInfo = uploadStateInfoMap.get(fileName);
|
} else {
|
uploadInfo.setClientFileSize(filesize);
|
uploadInfo.setDestFileFullName(fileName);
|
uploadInfo.setBeginTransferTime(System.currentTimeMillis());
|
}
|
|
RandomAccessFile destfile = null;
|
try {
|
if (pointoffile == 0) { //开始传新的文件
|
newfile.mkdirs();
|
newfile.delete();
|
destfile = new RandomAccessFile(newfile.getPath(), "rw");
|
// 如果启用文件加密，则需要在文件开始写入加密标识文件头
|
if (this.isFileEncry) {
|
byte[] encryHeader = EncryFileUtil.getEncryHeader(fileName);
|
|
if (encryHeader != null && encryHeader.length > 0) {
|
destfile.write(encryHeader, 0, encryHeader.length);
|
}
|
}
|
hashtable.put(fileName, destfile);
|
}
|
destfile = ( (RandomAccessFile) hashtable.get(fileName));
|
data = encryByte(data);
|
|
if ( (filesize - pointoffile) > blockLength) {
|
destfile.write(data, 0, blockLength);
|
|
uploadInfo.setTransferCount(uploadInfo.getTransferCount() + 1);
|
uploadInfo.setEndTransferTime(System.currentTimeMillis());
|
uploadInfo.setSpanTransfer(uploadInfo.getEndTransferTime() - uploadInfo.getBeginTransferTime());
|
uploadStateInfoMap.put(fileName, uploadInfo);
|
} else {
|
destfile.write(data, 0, (int) (filesize - pointoffile));
|
destfile.close();
|
destfile = null;
|
hashtable.remove(fileName);
|
fileControl.lockWrite(fileName);
|
File file0 = new File(fileName);
|
|
handleDataFileHistoryCopy(fileName);
|
|
newfile.renameTo(file0);
|
newfile.setLastModified(modifiedtime);
|
fileControl.unlockWrite(fileName);
|
fileControl.unlockWrite(fileName + TempProfix);
|
|
uploadInfo.setTransferCount(uploadInfo.getTransferCount() + 1);
|
uploadInfo.setEndTransferTime(System.currentTimeMillis());
|
uploadInfo.setSpanTransfer(uploadInfo.getEndTransferTime() - uploadInfo.getBeginTransferTime());
|
islast = true;
|
VolumeWithLog4j.logger.info(uploadInfo.toString());
|
}
|
} catch (Exception eRe) {
|
VolumeWithLog4j.logger.error(fileName, eRe);
|
|
//System.out.println("FileTranImpl::ReceiveFile:" + fileName + TempProfix + eRe.getMessage());
|
try {
|
fileControl.unlockWrite(fileName + TempProfix);
|
if (destfile != null) {
|
destfile.close();
|
destfile = null;
|
}
|
} catch (Exception dd) {
|
VolumeWithLog4j.logger.error(fileName, dd);
|
}
|
try {
|
hashtable.remove(fileName);
|
} catch (Exception ee) {
|
VolumeWithLog4j.logger.error(fileName, ee);
|
}
|
fileControl.unlockWrite(fileName);
|
|
//eRe.printStackTrace();
|
VolumeWithLog4j.logger.error("710005", eRe);
|
throw new VCIError("710005", new String[0]);//("服务器端接收文件出错！" + eRe.getStackTrace());
|
} finally{
|
if(islast && alreadExistInMap){
|
uploadStateInfoMap.remove(fileName);
|
}
|
}
|
return true;
|
}
|
|
/**
|
* 返回临时文件名后缀
|
* @return
|
*/
|
private String getTempFileSufixx(){
|
return "$transfer"; //临时文件后缀
|
}
|
/**
|
* 校验上传到卷服务的文件是否完整（完成）
|
* @param destFileFullPath 远程文件完整路径
|
* @param clientFileSize 客户端文件大小
|
* @param clientFileMD5 客户端文件MD5值
|
* @param otherParams 其它保留参数
|
* @return
|
* @throws VCIError
|
*/
|
public boolean verifyFileUploadSuccess(String destFileFullPath,
|
long clientFileSize, String clientFileMD5, String[] otherParams, Current current) throws VCIError{
|
boolean res = true;
|
/**
|
* 基础逻辑：
|
* 1、检验destFileFullPath是否存在，如果存在校验clientFileSize是否一致，一致代表成功，不一致代表失败；
|
* 2、destFileFullPath不存在时，校验destFileFullPath+$transfer是否存在，如果存在校验clientFileSize和destFileFullPath+$transfer的大小是否一致，如果一致将fileName+$transfer重命名为fileName，返回成功，否则失败
|
*/
|
|
destFileFullPath = hanlderOS(destFileFullPath);
|
|
//System.out.println("========校验文件 [" + destFileFullPath + "]开始====================");
|
VolumeWithLog4j.logger.debug("校验文件:" + destFileFullPath);
|
|
String sInfo = "";
|
|
File destFile = new File(destFileFullPath);
|
if(destFile.exists()){
|
// destFileFullPath 文件存在只判断大小是否匹配
|
if (this.isFileEncry)
|
res = (clientFileSize == (destFile.length() - 13));
|
else
|
res = clientFileSize == destFile.length();
|
|
//System.out.println("====校验文件 [" + destFileFullPath + "]结果：" + res + "\n客户端大小：" + clientFileSize + "; 服务端大小:" + destFile.length());
|
sInfo = "校验文件 [" + destFileFullPath + "] 结果：" + res + "; 客户端大小：" + clientFileSize + "; 服务端大小:" + destFile.length();
|
VolumeWithLog4j.logger.debug(sInfo);
|
} else {
|
String TempProfix = getTempFileSufixx(); //临时文件后缀
|
String tempFileFullPath = destFileFullPath + TempProfix;
|
File tempFile = new File(tempFileFullPath);
|
if(tempFile.exists()){
|
// 临时文件存在
|
// 判断临时文件大小与clientFileSize是否匹配
|
boolean sizeEqual = clientFileSize == tempFile.length();
|
if(sizeEqual){
|
// 大小相同
|
res = true;
|
// 重命名
|
tempFile.renameTo(destFile);
|
} else {
|
res = false;
|
}
|
|
//System.out.println("====校验文件 [" + tempFileFullPath + "]结果：" + res + "\n客户端大小：" + clientFileSize + "; 服务端大小:" + tempFile.length());
|
sInfo = "校验文件 [" + tempFileFullPath + "]结果：" + res + "; 客户端大小：" + clientFileSize + "; 服务端大小:" + tempFile.length();
|
VolumeWithLog4j.logger.debug(sInfo);
|
|
} else {
|
//System.out.println("====校验文件 [" + tempFileFullPath + "] 失败，临时文件不存在===");
|
sInfo = "校验文件 [" + tempFileFullPath + "] 失败，临时文件不存在";
|
VolumeWithLog4j.logger.debug(sInfo);
|
|
res = false;
|
}
|
}
|
|
//System.out.println("========校验文件 [" + destFileFullPath + "] 结束====================：" + res);
|
sInfo = "校验文件 [" + destFileFullPath + "] 结束";
|
VolumeWithLog4j.logger.debug(sInfo);
|
|
return res;
|
}
|
|
private byte[] encryByte(byte[] file) {
|
if (isFileEncry) {// != null && isFileEncry.equalsIgnoreCase("true")) {
|
return RC4.encry_RC4_byte(file, fileKey);
|
} else {
|
return file;
|
}
|
}
|
|
private byte[] decryByte(byte[] file) {
|
if (isFileEncry) {// != null && isFileEncry.equalsIgnoreCase("true")) {
|
return RC4.encry_RC4_byte(file, fileKey);
|
} else {
|
return file;
|
}
|
}
|
|
/**
|
* deal with the history copy of current file. It has the max number of copies,
|
* the names of copies are **.bak0, **.bak1, **.bak2..., and **.bak0 is the latest one.
|
* ** is the name of current file.
|
*
|
* @param sFileName
|
* @return
|
* @throws VCIError
|
*/
|
private boolean handleDataFileHistoryCopy(String sFileName) throws VCIError {
|
//mod by wcx@20201105 子方法都做了处理,重复处理有异常
|
// sFileName = hanlderOS(sFileName);
|
boolean isSuccess = false;
|
try {
|
int currentHistoryCopyCount = (int) getDataFileHistoryCopyCount(sFileName);
|
if (currentHistoryCopyCount < 1) {
|
return true;
|
}
|
if (currentHistoryCopyCount <= intBackUpCount) {
|
for (int i = currentHistoryCopyCount - 2; i >=0 ; i--) {
|
ChangeFileNameEx(sFileName + ".bak" + i, sFileName + ".bak" + (i + 1));
|
}
|
ChangeFileNameEx(sFileName, sFileName + ".bak0");
|
} else {
|
for (int i = intBackUpCount - 1; i < currentHistoryCopyCount - 1; i++) {
|
deleteFileEx(sFileName + ".bak" + i);
|
}
|
for (int i = intBackUpCount - 2; i >= 0; i--) {
|
ChangeFileNameEx(sFileName + ".bak" + i, sFileName + ".bak" + (i + 1));
|
}
|
ChangeFileNameEx(sFileName, sFileName + ".bak0");
|
}
|
} catch (Exception e) {
|
//e.printStackTrace();
|
VolumeWithLog4j.logger.error("710006", e);
|
throw new VCIError("710006", new String[0]);
|
}
|
return isSuccess;
|
}
|
|
/**
|
* get the copy count of current file.
|
*
|
* @param sFileName
|
* @return
|
* @throws VCIError
|
*/
|
private long getDataFileHistoryCopyCount(java.lang.String sFileName) throws VCIError {
|
// sFileName = hanlderOS(sFileName);
|
int iHistoryCopyCount = 0;
|
try {
|
String sFileNameTemp = sFileName;
|
File sFileTemp = new File(sFileNameTemp);
|
if (sFileTemp.exists()) {
|
iHistoryCopyCount++;
|
}
|
for (int i = 0; ; i++) {
|
sFileNameTemp = sFileName + ".bak" + i;
|
sFileTemp = new File(sFileNameTemp);
|
if (sFileTemp.exists()) {
|
iHistoryCopyCount++;
|
} else {
|
break;
|
}
|
}
|
} catch (Exception ex) {
|
VolumeWithLog4j.logger.error("710007", ex);
|
throw new VCIError("710007", new String[0]);//("获取数据文件历史备份数出错！");
|
}
|
return iHistoryCopyCount;
|
}
|
|
/**
|
* 更改文件名称
|
*/
|
public boolean ChangeFileName(String resName, String desName, Current current) throws VCIError {
|
resName = hanlderOS(resName);
|
desName = hanlderOS(desName);
|
return ChangeFileNameEx(resName, desName);
|
}
|
|
/**
|
* 更改文件名称,内部方法
|
*/
|
private boolean ChangeFileNameEx(String resName, String desName) throws VCIError {
|
//resName = hanlderOS(resName);
|
//desName = hanlderOS(desName);
|
try {
|
File res = new File(resName);
|
if (!res.exists()) {
|
throw new VCIError("710001", new String[0]);//("原文件不存在，修改文件名称错误！");
|
}
|
File des = new File(desName);
|
if (des.exists()) {
|
throw new VCIError("710008", new String[0]);//("目标文件已经存在，修改文件名称错误！");
|
}
|
res.renameTo(des);
|
return true;
|
} catch (Exception g) {
|
throw new VCIError("710009", new String[0]);// throw new com.tji.kpdm.volume.PdmError (102,"更改文件名出错！");
|
}
|
}
|
|
/**
|
* 删除文件
|
*/
|
public boolean deleteFile(String fileName, Current current) throws VCIError {
|
fileName = hanlderOS(fileName);
|
|
return deleteFileEx(fileName);
|
}
|
|
|
/**
|
* 删除文件,内部方法
|
*/
|
private boolean deleteFileEx(String fileName) throws VCIError {
|
//fileName = hanlderOS(fileName);
|
try {
|
File filedelete = new File(fileName);
|
|
if (!filedelete.exists()) {
|
return true;
|
}
|
filedelete.delete();
|
return true;
|
}
|
catch (Exception g) {
|
g.printStackTrace();
|
throw new VCIError("710010", new String[0]);// 删除文件出错，请重新删除！
|
}
|
}
|
|
/**
|
* 复制文件
|
* @param fromFileName，原文件全路径
|
* @param copyFileName，复制后文件全路径
|
* @return
|
* @throws VCIError
|
*/
|
public boolean copyFile(String fromFileName, String copyFileName, Current current) throws VCIError {
|
fromFileName = hanlderOS(fromFileName);
|
copyFileName = hanlderOS(copyFileName);
|
BufferedInputStream inbuff = null;
|
BufferedOutputStream outbuff = null;
|
try {
|
File res = new File(fromFileName);
|
if (!res.exists()) {
|
throw new VCIError("710001", new String[0]);//("原文件不存在，修改文件名称错误！");
|
}
|
File des = new File(copyFileName);
|
if (des.exists()) {
|
throw new VCIError("710008", new String[0]);//("目标文件已经存在，修改文件名称错误！");
|
}
|
if (!des.exists()) {
|
des.mkdirs();
|
des.delete();
|
}
|
//新建文件输入流
|
inbuff = new BufferedInputStream(new FileInputStream(res));
|
//新建文件输出流
|
outbuff = new BufferedOutputStream(new FileOutputStream(des));
|
//缓冲数组
|
byte[] b = new byte[1024 * 5];
|
int len;
|
while ((len = inbuff.read(b)) != -1) {
|
outbuff.write(b, 0, len);
|
}
|
outbuff.flush();
|
return true;
|
} catch (Exception g) {
|
throw new VCIError("710023", new String[0]);// 复制文件出错
|
} finally {
|
try {
|
if (inbuff != null) {
|
inbuff.close();
|
}
|
if (outbuff != null) {
|
outbuff.close();
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
private String hanlderOS(String strFileName) {
|
String strNewFileName = strFileName;
|
|
// 将服务器文件路径转换为实际路径，替换路径前的“<卷>:”为卷的实际路径
|
int index = strNewFileName.indexOf(":");
|
if (index > 0)
|
{
|
String volumn = strNewFileName.substring(0, index);
|
|
try
|
{
|
PvolumeInfo pv = getVolumnInfo(volumn);
|
if (pv != null && !StringUtils.isEmpty(pv.id))
|
{
|
String path = pv.path;
|
if (path.endsWith("\\") || path.endsWith("/"))
|
path = path.substring(0, path.length() - 1);
|
|
strNewFileName = strNewFileName.replace(volumn + ":", path);
|
}
|
}
|
catch (VCIError re) {
|
VolumeWithLog4j.logger.error(strFileName, re);
|
}
|
}
|
|
String osStr = System.getProperty("os.name");
|
if ( !osStr.startsWith("Win") )
|
{
|
//Unix
|
strNewFileName = strNewFileName.replace('\\','/');
|
strNewFileName = strNewFileName.replace("//", "/");
|
}
|
else if ( osStr.startsWith("Win") )
|
{
|
//Win
|
strNewFileName = strNewFileName.replace('/','\\');
|
strNewFileName = strNewFileName.replace("\\\\", "\\");
|
}
|
|
return strNewFileName;
|
}
|
|
public long getCurrrentTimeMillions(Current current) {
|
return System.currentTimeMillis();
|
}
|
|
public boolean createDirectory(String historyDirectory, String directoryName, Current current) throws VCIError {
|
if (historyDirectory.equals(directoryName)) {
|
return true;
|
}
|
directoryName = hanlderOS(directoryName);
|
historyDirectory = hanlderOS(historyDirectory);
|
try {
|
if(!"".equalsIgnoreCase(historyDirectory)){
|
File formerFile = new File(historyDirectory);
|
String[] tempList = formerFile.list();
|
if(tempList.length != 0){
|
throw new VCIError("710011", new String[0]);
|
}
|
}
|
|
File filedir = new File(directoryName);
|
if (!filedir.exists()) {
|
filedir.mkdirs();
|
}
|
return true;
|
} catch (VCIError re) {
|
throw re;
|
} catch (Exception e) {
|
throw new VCIError("710012", new String[0]);//创建目录失败。
|
}
|
}
|
|
/**
|
* delete current file and its copies.
|
*
|
* @param sFileName
|
* @return
|
* @throws VCIError
|
*/
|
public boolean deleteAllFiles(String[] sFileNames, Current current) throws VCIError {
|
boolean isSuccess = true;
|
int length=sFileNames.length;
|
for(int i=0;i<length;i++){
|
sFileNames[i] = hanlderOS(sFileNames[i]);
|
try {
|
File delFile = new File(sFileNames[i]);
|
if (!delFile.exists()) {
|
throw new VCIError("710001", new String[0]);//("文件不存在！");
|
} else {
|
delFile.delete();
|
}
|
String sBackFileName = null;
|
for (int j = 0; j < intBackUpCount; j++) {
|
sBackFileName = sFileNames[i] + ".bak" + j;
|
delFile = new File(sBackFileName);
|
if (delFile.exists()) {
|
delFile.delete();
|
}
|
}
|
|
} catch (Exception g) {
|
VolumeWithLog4j.logger.error("710013", g);
|
|
isSuccess=false;
|
throw new VCIError("710013", new String[0]);//("删除数据文件及其备份错误！");
|
}
|
}
|
|
return isSuccess;
|
}
|
|
/**
|
* delete all copies of current file.
|
*
|
* @param sFileName
|
* @return
|
* @throws VCIError
|
*/
|
public boolean deleteAllBakFiles(String sFileName, Current current) throws VCIError {
|
boolean isSuccess = false;
|
sFileName = hanlderOS(sFileName);
|
try {
|
File delFile = new File(sFileName);
|
if (!delFile.exists()) {
|
throw new VCIError("710001", new String[0]);//("文件不存在！");
|
}
|
String sBackFileName = null;
|
for (int i = 0; i < intBackUpCount; i++) {
|
sBackFileName = sFileName + ".bak" + i;
|
delFile = new File(sBackFileName);
|
if (delFile.exists()) {
|
delFile.delete();
|
}
|
}
|
isSuccess = true;
|
} catch (Exception g) {
|
VolumeWithLog4j.logger.error("710014", g);
|
throw new VCIError("710014", new String[0]);//("删除数据文件备份错误！");
|
}
|
return isSuccess;
|
}
|
|
/**
|
* send a subsection of file to client everytime.
|
*
|
* @param fileName
|
* @param pointoffile
|
* @return
|
* @throws VCIError
|
*/
|
public byte[] sendFile(String fileName, long pointoffile, Current current) throws VCIError {
|
fileName = hanlderOS(fileName);
|
int bak = fileName.lastIndexOf(".bak");
|
boolean lockRead = false;
|
|
if (pointoffile == 0 && bak > 16) { //说明是历史版本文件
|
String nameTemp = fileName.substring(0, bak);
|
lockRead = fileControl.lockRead(nameTemp);
|
}
|
else if (pointoffile == 0) {
|
lockRead = fileControl.lockRead(fileName);
|
}
|
|
if (pointoffile == 0 && (!lockRead)) {
|
VolumeWithLog4j.logger.warn("710004, 文件被锁:" + fileName);
|
throw new VCIError("710004", new String[0]);//("服务器端文件已锁定,请稍后再试！");
|
} else {
|
File resoucefile = new File(fileName);
|
if (!resoucefile.exists()) {
|
VolumeWithLog4j.logger.warn("710001, 文件不存在:" + fileName);
|
throw new VCIError("710001", new String[0]);//服务器端文件不存在！
|
}
|
|
boolean isEncry = EncryFileUtil.isEncryFile(resoucefile);
|
if (isEncry)
|
pointoffile += EncryFileUtil.ENCRYHEADERSIZE;
|
|
byte[] read = null;
|
FileInputStream inputfile = null;
|
try {
|
inputfile = new FileInputStream(resoucefile);
|
|
inputfile.skip(pointoffile);
|
|
int len = blockLength;
|
if ((resoucefile.length() - pointoffile) <= blockLength) {
|
len = (int)(resoucefile.length() - pointoffile);
|
read = new byte[len];
|
} else {
|
read = new byte[blockLength];
|
}
|
|
inputfile.read(read, 0, len);
|
inputfile.close();
|
if ((resoucefile.length() - pointoffile) <= blockLength) {
|
fileControl.unlockRead(fileName);
|
}
|
|
long filesize = resoucefile.length();
|
StringBuffer log = new StringBuffer();
|
log.append("远程文件:" + fileName).append(",");
|
log.append("文件大小:" + filesize).append(",");
|
log.append("开始位置:" + pointoffile).append(",");
|
log.append("开始位置:" + (pointoffile + len)).append("");
|
//writeVolumeFileDownloadLog(log.toString());
|
VolumeWithLog4j.logger.debug(log.toString());
|
} catch (Exception e1) {
|
VolumeWithLog4j.logger.error("710015", e1);
|
|
try {
|
if (inputfile != null) {
|
inputfile.close();
|
}
|
} catch (Exception ex) {
|
}
|
fileControl.unlockRead(fileName);
|
throw new VCIError("710015", new String[0]);//服务器端发送文件出错！
|
}
|
|
if (isEncry) {
|
read = RC4.encry_RC4_byte(read, fileKey);
|
}
|
return read;
|
}
|
}
|
|
/**
|
* 获取单个文件的MD5值！用于比较两个文件是否完全相等
|
* @param file
|
* @return
|
*/
|
public String getFileMD5(String fileName, Current current) throws VCIError {
|
fileName = hanlderOS(fileName);
|
File file=new File(fileName);
|
if (!file.isFile()){
|
return null;
|
}
|
MessageDigest digest = null;
|
FileInputStream in=null;
|
byte buffer[] = new byte[1024];
|
int len;
|
try {
|
digest = MessageDigest.getInstance("MD5");
|
in = new FileInputStream(file);
|
while ((len = in.read(buffer, 0, 1024)) != -1) {
|
digest.update(buffer, 0, len);
|
}
|
in.close();
|
} catch (Exception e) {
|
VolumeWithLog4j.logger.error("710016", e);
|
throw new VCIError("710016", new String[0]);
|
}
|
BigInteger bigInt = new BigInteger(1, digest.digest());
|
return bigInt.toString(16);
|
}
|
|
/**
|
* 获取文件夹中文件的MD5值
|
* @param file
|
* @param listChild ;true递归子目录中的文件
|
* @return
|
*/
|
public Map<String, String> getDirMD5(String fileName,boolean listChild, Current current) throws VCIError {
|
fileName = hanlderOS(fileName);
|
File file=new File(fileName);
|
if(!file.isDirectory()){
|
return null;
|
}
|
//<filepath,md5>
|
Map<String, String> map=new HashMap<String, String>();
|
String md5;
|
File files[]=file.listFiles();
|
for(int i=0;i<files.length;i++){
|
File f=files[i];
|
String filePath=f.getPath();
|
if(f.isDirectory()&&listChild){
|
map.putAll(getDirMD5(filePath, listChild, current));
|
} else {
|
md5=getFileMD5(filePath, current);
|
if(md5!=null){
|
map.put(f.getPath(), md5);
|
}
|
}
|
}
|
return map;
|
}
|
|
public byte[][] downloadFile(String fileName, Current current) throws VCIError {
|
fileName = hanlderOS(fileName);
|
byte[][] bypes=null;
|
ArrayList<byte[]> arrayList=new ArrayList<byte[]>();
|
File file=new File(fileName);
|
if (!file.exists()) {
|
throw new VCIError("710001", new String[0]); //文件不存在
|
}
|
|
int pos = 0;
|
boolean isEncry = EncryFileUtil.isEncryFile(file);
|
if (isEncry)
|
pos = EncryFileUtil.ENCRYHEADERSIZE;
|
|
try {
|
FileInputStream in = new FileInputStream(file);
|
|
long fileSize = file.length();
|
|
if (blockLength < 0) {
|
throw new VCIError("710017", new String[0]); //没有设定每次传输的文件大小
|
}
|
byte[] fileByte =null;
|
long temp = 0;
|
|
if (pos > 0) {
|
in.skip(pos);
|
temp += EncryFileUtil.ENCRYHEADERSIZE;
|
}
|
|
while (temp < (fileSize - blockLength)) {
|
fileByte = new byte[blockLength];
|
in.read(fileByte, 0, blockLength);
|
arrayList.add(fileByte);
|
temp += blockLength;
|
}
|
|
int remainSize = (int)(fileSize - temp);
|
fileByte = new byte[remainSize];
|
in.read(fileByte, 0, remainSize);
|
arrayList.add(fileByte);
|
in.close();
|
|
int size=arrayList.size();
|
bypes=new byte[size][];
|
|
for(int i=0;i<size;i++){
|
if (isEncry)
|
bypes[i] = RC4.encry_RC4_byte(arrayList.get(i), fileKey);
|
else
|
bypes[i] = arrayList.get(i);
|
}
|
return bypes;
|
} catch (VCIError rme) {
|
throw rme;
|
} catch (Exception e) {
|
VolumeWithLog4j.logger.error("710018", e);
|
throw new VCIError("710018", new String[0]);//下载文件出错，请重新下载！
|
}
|
}
|
|
public FileInfo[] getFileList(String path, String savePath, Current current) throws VCIError {
|
|
String svrPath = hanlderOS(path);
|
|
FileInfo[] fileInfos = null;
|
try {
|
ArrayList<FileInfo> infos = new ArrayList<FileInfo>();
|
|
String volPath = path;
|
if (volPath.endsWith("\\") || volPath.endsWith("/"))
|
volPath = volPath.substring(0, volPath.length() - 1);
|
|
String tempPath = svrPath;
|
if (tempPath.endsWith("\\") || tempPath.endsWith("/"))
|
tempPath = tempPath.substring(0, tempPath.length() - 1);
|
|
collectFiles(new File(svrPath), volPath, tempPath, infos);
|
int size = infos.size();
|
fileInfos = new FileInfo[size];
|
for (int i = 0; i < size; i++) {
|
fileInfos[i] = infos.get(i);
|
}
|
} catch (Exception e) {
|
VolumeWithLog4j.logger.error("710019", e);
|
throw new VCIError("710019", new String[0]);//获取服务器端下载文件出错，请检查服务器端文件。
|
}
|
return fileInfos;
|
}
|
|
public FileInfo[] getFolderFiles(String path, Current current) throws VCIError {
|
String svrPath = hanlderOS(path);
|
FileInfo[] fileInfos = null;
|
try {
|
List<FileInfo> infos = new ArrayList<FileInfo>();
|
File file = new File(svrPath);
|
|
StringBuffer buf = new StringBuffer();
|
|
if (file.isDirectory()) {
|
File[] subFiles = file.listFiles();
|
|
if (subFiles != null) {
|
// 文件夹的话，递归处理子文件
|
for (File subFile : subFiles) {
|
if (subFile.isDirectory())
|
continue;
|
|
buf.setLength(0);
|
buf.append(path);
|
buf.append(File.separator);
|
buf.append(file.getAbsolutePath().substring(svrPath.length() + 1));
|
|
FileInfo info = new FileInfo();
|
info.filePath = subFile.getName();
|
info.fileSavePath = "";
|
info.isDirectory = false;
|
info.fileSize = subFile.length();
|
infos.add(info);
|
}
|
}
|
}
|
|
fileInfos = infos.toArray(new FileInfo[0]);
|
|
} catch (Exception e) {
|
VolumeWithLog4j.logger.error("710019", e);
|
throw new VCIError("710019", new String[0]);//获取服务器端下载文件出错，请检查服务器端文件。
|
}
|
|
return fileInfos;
|
}
|
|
private void collectFiles(File file,String saveDir,String folderPath,List<FileInfo> infos) {
|
File[] subFiles = null;
|
StringBuffer buf = new StringBuffer();
|
|
if (!file.exists())
|
return;
|
|
if (file.isDirectory()) {
|
subFiles = file.listFiles();
|
} else if (file.getName().equals("patchVersion.properties")) {
|
return;
|
}
|
|
if (subFiles != null) {
|
// 文件夹的话，递归处理子文件
|
for (File subFile:subFiles) {
|
collectFiles(subFile,saveDir,folderPath,infos);
|
}
|
|
// 将空文件夹也添加进来，需要传过去
|
if (subFiles.length == 0) {
|
if (file.getAbsolutePath().equals(folderPath)) {
|
return;
|
}
|
buf.setLength(0);
|
buf.append(saveDir);
|
buf.append(File.separator);
|
buf.append(file.getAbsolutePath().substring(folderPath.length() + 1));
|
FileInfo info = new FileInfo();
|
info.filePath = file.getAbsolutePath();
|
info.fileSavePath = buf.toString();
|
info.isDirectory = file.isDirectory();
|
infos.add(info);
|
}
|
} else {
|
// 将文件添加进来，需要传输
|
buf.setLength(0);
|
buf.append(saveDir);
|
buf.append(File.separator);
|
|
int len = 0;
|
if (file.getAbsolutePath().length() == folderPath.length()) {
|
len = file.getAbsolutePath().lastIndexOf(File.separator);
|
} else {
|
len = folderPath.length();
|
}
|
|
buf.append(file.getAbsolutePath().substring(len + 1));
|
// buf.append(file.getAbsolutePath().substring(folderPath.length() + 1));
|
FileInfo info = new FileInfo();
|
info.filePath = file.getAbsolutePath();
|
info.fileSavePath = buf.toString();
|
info.isDirectory = file.isDirectory();
|
if (!file.isDirectory()) {
|
info.fileSize = file.length();
|
}
|
infos.add(info);
|
}
|
return;
|
}
|
|
/**
|
* 获取指定目录下的子目录
|
* @param file
|
* @param infos
|
*/
|
public String[] getSubFolders(String path, Current current) {
|
String sParent = hanlderOS(path);
|
|
File file = new File(sParent);
|
if (!file.exists() || !file.isDirectory())
|
return new String[0];
|
|
List<String> lstSubFolder = new ArrayList<String>();
|
|
File[] subFiles = file.listFiles();
|
// 文件夹的话，递归处理子文件
|
for (File subFile:subFiles) {
|
if (!subFile.isDirectory() || subFile.getName() == "." || subFile.getName()== "..")
|
continue;
|
|
lstSubFolder.add(subFile.getName());
|
}
|
|
return lstSubFolder.toArray(new String[0]);
|
}
|
|
|
/**
|
* 通过集成方式获得文件大小
|
*/
|
public long getIntegrationFileSize(String fileName, Current current) throws VCIError {
|
long size = -1;
|
try {
|
fileName = new String(fileName.getBytes("ISO-8859-1"), "GBK");
|
fileName = hanlderOS(fileName);
|
File file1 = new File(fileName);
|
if (!file1.exists()) {
|
throw new VCIError("710001", new String[]{});//文件不存在!
|
}
|
size = file1.length();
|
} catch (Exception g) {
|
//g.printStackTrace();
|
VolumeWithLog4j.logger.error("710003", g);
|
throw new VCIError("710003", new String[]{});//获取文件大小出错，请重新获取!
|
}
|
return size;
|
}
|
|
/**
|
* 集成方式服务器端发送文件
|
*/
|
public byte[] receiveIntegrationFile(String fileName, long pointoffile, Current current) throws VCIError {
|
fileName = convertISO_8859_1ToGBK(fileName);
|
fileName = hanlderOS(fileName);
|
int bak = fileName.lastIndexOf(".bak");
|
boolean lockRead = false;
|
if (pointoffile == 0 && bak > 16) { //说明是历史版本文件
|
String nameTemp = fileName.substring(0, bak);
|
lockRead = fileControl.lockRead(nameTemp);
|
}
|
else if (pointoffile == 0) {
|
lockRead = fileControl.lockRead(fileName);
|
}
|
if (pointoffile == 0 && (!lockRead)) {
|
throw new VCIError("710004", new String[]{});//("服务器端文件已锁定,请稍后再试！");
|
} else {
|
byte[] read = null;
|
File resoucefile = new File(fileName);
|
if (!resoucefile.exists()) {
|
throw new VCIError("710001", new String[]{});//("文件不存在！");
|
}
|
FileInputStream inputfile = null;
|
try {
|
inputfile = new FileInputStream(resoucefile);
|
inputfile.skip(pointoffile);
|
int len = blockLength;
|
if ((resoucefile.length() - pointoffile) <= blockLength) {
|
len = (int)(resoucefile.length() - pointoffile);
|
read = new byte[len];
|
} else {
|
read = new byte[blockLength];
|
}
|
inputfile.read(read, 0, len);
|
inputfile.close();
|
if ((resoucefile.length() - pointoffile) <= blockLength) {
|
fileControl.unlockRead(fileName);
|
}
|
} catch (Exception e1) {
|
try {
|
if (inputfile != null) {
|
inputfile.close();
|
}
|
} catch (Exception ex) {
|
}
|
fileControl.unlockRead(fileName);
|
|
VolumeWithLog4j.logger.error("710005", e1);
|
throw new VCIError("710005", new String[]{});//("服务器端发送文件出错！");
|
}
|
return read;
|
}
|
}
|
|
String convertGBKToISO_8859_1(String text){
|
return convertEncoding(text, "GBK", "ISO-8859-1");
|
}
|
String convertISO_8859_1ToGBK(String text){
|
return convertEncoding(text, "ISO-8859-1", "GBK");
|
}
|
String convertEncoding(String text, String fromEncoding, String toEncoding){
|
String res = text;
|
try {
|
res = new String(text.getBytes(fromEncoding), toEncoding);
|
} catch (UnsupportedEncodingException e) {
|
//e.printStackTrace();
|
VolumeWithLog4j.logger.error(e);
|
}
|
return res;
|
}
|
/**
|
* 测试连接
|
*/
|
public boolean testConntect() {
|
return true;
|
}
|
|
@Override
|
public boolean isFileExist(String fileName, Current current) throws VCIError {
|
fileName = hanlderOS(fileName);
|
try {
|
File currentFile = new File(fileName);
|
if (currentFile.exists()) {
|
return true;
|
}
|
} catch (Exception g) {
|
//g.printStackTrace();
|
VolumeWithLog4j.logger.error("710002", g);
|
throw new VCIError("710002", new String[0]);
|
}
|
return false;
|
}
|
|
/**
|
* 获取当前文件柜服务器Host信息（返回格式为"HostIPIP@|@HostName"）[冗余存储主要解决可能由于文件柜服务器部署变更引起的问题分析， ADD By ZhongGY 2015-03-24]
|
*/
|
@Override
|
public String getHostInfo(Current current) throws VCIError {
|
try {
|
InetAddress address = InetAddress.getLocalHost();
|
return address.getHostAddress() + "@|@" + address.getHostName();
|
} catch (UnknownHostException e) {
|
//e.printStackTrace();
|
VolumeWithLog4j.logger.error(e);
|
throw new VCIError(e.getLocalizedMessage(), new String[0]);
|
}
|
}
|
|
|
/**
|
* 查询文件柜使用空间及磁盘总空间
|
*/
|
@Override
|
public VolumeUseInfo[] getVolumeUseInfo(Current current) throws VCIError {
|
|
//PvolumeDelegate pvolumeDelegate = new PvolumeDelegate();
|
PvolumeInfo[] pvolumeInfos = VolumeCacheProvider.getAllVolumes();
|
VolumeUseInfo[] volumns = new VolumeUseInfo[pvolumeInfos.length];
|
for(int i = 0; i < volumns.length; i++){
|
volumns[i] = new VolumeUseInfo();
|
volumns[i].id = pvolumeInfos[i].id;
|
volumns[i].name = pvolumeInfos[i].name;
|
volumns[i].host = pvolumeInfos[i].host;
|
volumns[i].path = pvolumeInfos[i].path;
|
volumns[i].type = pvolumeInfos[i].type;
|
volumns[i].usedSize = getUsedSize(new File(volumns[i].path));
|
volumns[i].diskSize = getDiskSize(new File(volumns[i].path));
|
}
|
return volumns;
|
}
|
|
|
private PvolumeInfo getVolumnInfo(String volumn) throws VCIError {
|
|
if (mapVolumn.containsKey(volumn))
|
return mapVolumn.get(volumn);
|
|
//PvolumeDelegate pvolumeDelegate = new PvolumeDelegate();
|
PvolumeInfo pvolume = VolumeCacheProvider.getVolume(volumn);
|
if (pvolume != null)
|
mapVolumn.put(volumn, pvolume);
|
|
return pvolume;
|
}
|
|
private String getDiskSize(File file) {
|
File[] listRoots = File.listRoots();
|
File root = null;
|
for (int i = 0; i < listRoots.length; i++) {
|
if(file.getAbsolutePath().startsWith(listRoots[i].getPath())){
|
root = listRoots[i];
|
}
|
}
|
if(root == null) return "未找到磁盘";
|
long total = root.getTotalSpace() / (1024*1024);
|
return String.valueOf(total);
|
}
|
public String getUsedSize(final File folder){
|
if(!folder.exists()) return "文件夹" + folder + "不存在";
|
if(!folder.isDirectory()) return String.valueOf(folder.length() / (1024 * 1024));
|
long total = 0;
|
try {
|
String[] listNames = folder.list();
|
if(listNames.length > 2000){
|
ExecutorService pool = Executors.newFixedThreadPool(10);
|
final int[] diff = new int[2]; //[起始index, 处理size]
|
int block = 1800;
|
List<Callable<Long>> tasks = new ArrayList<Callable<Long>>();
|
while(diff[0] < listNames.length){
|
diff[1] = listNames.length - diff[0];
|
diff[1] = diff[1] > block ? block : diff[1];
|
tasks.add(new Callable<Long>() {
|
int start = diff[0];
|
int block = diff[1];
|
@Override
|
public Long call() throws Exception {
|
return getTotalSize(folder, start, block);
|
}
|
});
|
diff[0] += diff[1];
|
}
|
List<Future<Long>> results;
|
results = pool.invokeAll(tasks);
|
pool.shutdown();
|
for(Future<Long> future : results){
|
long size = future.get();
|
total += size;
|
}
|
}else{
|
total = getTotalSize(folder, 0, listNames.length);
|
}
|
} catch (InterruptedException e) {
|
//e.printStackTrace();
|
VolumeWithLog4j.logger.error(e);
|
return "线程执行错误:" + e.getMessage();
|
} catch (ExecutionException e) {
|
//e.printStackTrace();
|
VolumeWithLog4j.logger.error(e);
|
return "计算出错:" + e.getMessage();
|
}
|
return String.valueOf(1.0*total/1024/1024);
|
}
|
private long getTotalSize(File folder, int start, int block){
|
long total = 0;
|
File[] listFiles = folder.listFiles();
|
if(start >= listFiles.length) return 0;
|
int end = start + block;
|
for (int i = start; i < end; i++) {
|
if(listFiles[i].isDirectory()){
|
total += getTotalSize(listFiles[i], 0, listFiles[i].list().length);
|
}else{
|
total += listFiles[i].length();
|
}
|
}
|
return total;
|
}
|
|
@Override
|
public boolean existPath(String filePath, Current current) throws VCIError {
|
try {
|
File currentFile = new File(filePath);
|
if (!currentFile.exists()) {
|
return false;
|
}
|
return true;
|
} catch (Exception e) {
|
return false;
|
}
|
}
|
|
@Override
|
public boolean testConntect(Current current) {
|
// TODO Auto-generated method stub
|
return true;
|
}
|
|
@Override
|
public long getTransmitBlockSize(com.zeroc.Ice.Current current) throws VCIError {
|
return VolumeProperties.blockLength();
|
}
|
}
|
