需求描述：
創(chuàng)新互聯(lián)公司從2013年開始，是專業(yè)互聯(lián)網(wǎng)技術(shù)服務(wù)公司，擁有項(xiàng)目成都網(wǎng)站設(shè)計(jì)、成都做網(wǎng)站、外貿(mào)網(wǎng)站建設(shè)網(wǎng)站策劃，項(xiàng)目實(shí)施與項(xiàng)目整合能力。我們以讓每一個夢想脫穎而出為使命，1280元薌城做網(wǎng)站,已為上家服務(wù),為薌城各地企業(yè)和個人服務(wù),聯(lián)系電話:13518219792
客戶出完賬之后需要把出賬的數(shù)據(jù)以文本文件的方式傳送給收入管理系統(tǒng)，客戶以前是通過本地的一個工具軟件上傳的，由于安全監(jiān)管的原因，不允許在本地使用工具上傳，因此客戶希望我們在已經(jīng)上線使用的系統(tǒng)開發(fā)一個功能實(shí)現(xiàn)他們的需求。
業(yè)務(wù)梳理：
我梳理一下具體的細(xì)節(jié)，具體的流程如圖所示：
程序?qū)崿F(xiàn)：
一、首先是設(shè)計(jì)頁面
由于是在原系統(tǒng)的基礎(chǔ)上新增功能，需要提前做好菜單的配置工作。我設(shè)計(jì)的頁面如下圖，一個是下拉選擇框（用戶選擇相對應(yīng)的業(yè)務(wù)），一個是選擇文件，一個是月份（表示需要傳送的文件是哪個月），一個是上傳按鈕，用戶選擇文件之后選擇月份點(diǎn)擊上傳按鈕之后即可觸發(fā)上傳操作。
以下是JSP界面的源碼：
<%@ include file="/common/taglibs.jsp"%>
<%@ page language="java" pageEncoding="UTF-8"%>
<%@ page isELIgnored="false"%>
二、點(diǎn)擊上傳按鈕之后的函數(shù)為：importHandle()，提交的請求為interfaceupload_UPLOAD_interfaceupload.do
系統(tǒng)是由struts2實(shí)現(xiàn)的，因此要在配置中加入這一段請求相對應(yīng)的action的配置
/WEB-INF/jsp/revenue/interfaceupload.jsp
interfaceupload
三、做好了相對應(yīng)的準(zhǔn)備工作，繼續(xù)來寫接下來的業(yè)務(wù)邏輯。
編寫aicu.application.mps.voice.international.web.revenue.FileImportAction類
package aicu.application.mps.voice.international.web.revenue;
import aicu.application.mps.voice.international.web.revenue.FileUploadAction;
public class FileImportAction extends FileUploadAction {
public String execute() throws Exception {
System.out.println("hello");
smartUpload();
return SUCCESS;
}
}由于FileImportAction繼承了FileUploadAction，所以相對應(yīng)的請求都會由>FileUploadAction的execute()來處理。
首先是獲取上傳上來的文件對象，通過聲明上傳文件的對象，內(nèi)容類型，文件名，服務(wù)ID，然后在生成set()方法和get()方法便能獲取到文件對象。
protected File upload;// 實(shí)際上傳文件
protected String uploadContentType; // 文件的內(nèi)容類型
protected String uploadFileName; // 上傳文件名
protected String uploadServiceId;//上傳服務(wù)ID
public File getUpload() {
return upload;
}
public void setUpload(File upload) {
this.upload = upload;
}
public String getUploadContentType() {
return uploadContentType;
}
public void setUploadContentType(String uploadContentType) {
this.uploadContentType = uploadContentType;
}
public String getUploadFileName() {
return uploadFileName;
}
public void setUploadFileName(String uploadFileName) {
this.uploadFileName = uploadFileName;
}
public String getUploadServiceId() {
return uploadServiceId;
}
public void setUploadServiceId(String uploadServiceId) {
this.uploadServiceId = uploadServiceId;
}然后是對當(dāng)前的文本文件進(jìn)行MD5加密，生成同名的MD5文件，文件中只有一行加密之后的MD5字符串。
由于通過struts上傳的文件是存放在臨時(shí)目錄下，我處理的思路是，先把文件copy到指定的路徑下
String datapath = getRealPath()+"upload"+File.separator+UUID.randomUUID()+File.separator;
File newFile=new File(new File(datapath),uploadFileName);
if (!newFile.getParentFile().exists())
newFile.getParentFile().mkdirs();
FileUtils.copyFile(upload, newFile);
然后是生成MD5同名文件
FileMD5 filemd5=new FileMD5();
String md5str=filemd5.getMD5(newFile);
實(shí)現(xiàn)的思路是調(diào)用byteToHexString方法得到加密之后MD5的字符串，通過writeFileContent實(shí)現(xiàn)把文本寫入同名的MD5文件中。FileMD5類的getMD5(File file)方法：
public String getMD5(File file) {
Boolean bool = false;
FileInputStream fis = null;
String filename=file.getName();
String[] newfilepath=filename.split("\\.");
String filenameTemp = file.getParent()+file.separator+newfilepath[0]+ ".md5";
File md5file = new File(filenameTemp);
try {
MessageDigest md = MessageDigest.getInstance("MD5");
fis = new FileInputStream(file);
byte[] buffer = new byte[2048];
int length = -1;
long s = System.currentTimeMillis();
while ((length = fis.read(buffer)) != -1) {
md.update(buffer, 0, length);
}
byte[] b = md.digest();
String filecontent=byteToHexString(b);
if (!md5file.exists()) {
md5file.createNewFile();
bool = true;
System.out.println("success create file,the file is "
+ md5file.getName());
writeFileContent(filenameTemp, filecontent);
}
else {
md5file.delete();
System.out.println("success delete file,the file is "
+ md5file.getName());
md5file.createNewFile();
bool = true;
System.out.println("success create file,the file is "
+ md5file.getName());
writeFileContent(filenameTemp, filecontent);
}
return byteToHexString(b);
} catch (Exception ex) {
ex.printStackTrace();
return null;
} finally {
try {
fis.close();
} catch (IOException ex) {
ex.printStackTrace();
}
}
}byteToHexString方法，主要是實(shí)現(xiàn)對文本文件的MD5加密，得到加密之后的MD5文件
private String byteToHexString(byte[] tmp) {
String s;
char str[] = new char[16 * 2];
int k = 0;
for (int i = 0; i < 16; i++) {
byte byte0 = tmp[i];
str[k++] = hexdigits[byte0 >>> 4 & 0xf];
str[k++] = hexdigits[byte0 & 0xf];
}
s = new String(str);
return s;
}writeFileContent方法，實(shí)現(xiàn)把文本寫入同名的MD5文件中
public boolean writeFileContent(String filepath, String newstr) throws IOException {
Boolean bool = false;
//String filein = newstr + "\r\n";
String filein = new String(newstr);
String temp = "";
FileInputStream fis = null;
InputStreamReader isr = null;
BufferedReader br = null;
FileOutputStream fos = null;
PrintWriter pw = null;
try {
File file = new File(filepath);
fis = new FileInputStream(file);
isr = new InputStreamReader(fis);
br = new BufferedReader(isr);
StringBuffer buffer = new StringBuffer();
for (int i = 0; (temp = br.readLine()) != null; i++) {
buffer.append(temp);
buffer = buffer.append(System.getProperty("line.separator"));
}
buffer.append(filein);
fos = new FileOutputStream(file);
pw = new PrintWriter(fos);
pw.write(buffer.toString().toCharArray());
pw.flush();
bool = true;
} catch (Exception e) {
e.printStackTrace();
} finally {
if (pw != null) {
pw.close();
}
if (fos != null) {
fos.close();
}
if (br != null) {
br.close();
}
if (isr != null) {
isr.close();
}
if (fis != null) {
fis.close();
}
}
return bool;
}四、獲取到文本文件和生成同名的文件名之后，緊接著就是獲取相對應(yīng)的ftp主機(jī)，用戶名，密碼以及路徑信息了。我把這相對應(yīng)的信息保存在數(shù)據(jù)庫中。首先我們把獲取到的業(yè)務(wù)類型放入一個HashMap中。
parameterMap=new HashMap();
parameterMap.put("audit_flag",OperationType);然后我們配置ibaits的sqlid
然后執(zhí)行該sqlid的查詢，把結(jié)果放入List 中
List
下面是根據(jù)該sqlid查詢出來的List結(jié)果中，取出相關(guān)的信息
String host = (String)resultType.get(0).get("FTPHOST");
String user = (String)resultType.get(0).get("PROGUSER");
String pass = (String)resultType.get(0).get("PROGPASS");
String path = (String)resultType.get(0).get("REMOTEDIRECTORY");
//每月會自動生成一個月份的子目錄
String relpath=path+rpmonth+"/"; 至此，便可以獲取到相對應(yīng)的ftp主機(jī)，用戶名，密碼以及路徑信息了。
五、最后一步是實(shí)現(xiàn)上傳，我是用的FTPClient來實(shí)現(xiàn)的。
實(shí)現(xiàn)的操作都寫在了FtpBBSUtil的FtpSento方法中，其中datapath表示需要傳送文件的目錄。
FtpBBSUtil.getFtpBBS().FtpSento(datapath, host, user, pass, relpath);
FtpBBSUtil的FtpSento方法如下所示：
public void FtpSento(String localPath, String host, String user,
String pass, String path) throws Exception {
login(host, 21, user, pass);
File parentFile = new File(localPath);
File[] files = parentFile.listFiles();
String outPath = path;
for (File aFile : files) {
if (aFile != null && aFile.getName() != null) {
put(aFile, outPath, new String((aFile.getName())
.getBytes("GB18030"), "ISO8859-1"));
}
}
logout();
}總結(jié)
本篇文章描寫了Java如何實(shí)現(xiàn)對某一目錄下的文件夾下的文本文件實(shí)現(xiàn)MD5加密，并生成同名的MD5文件，根據(jù)配置信息，獲取主機(jī)ip，用戶名密碼，傳送的路徑，然后實(shí)現(xiàn)ftp遠(yuǎn)程傳送功能。如果你有類似的需求，希望可以幫助到你，或者你能從中獲取到靈感。
文章名稱：Java對文本文件MD5加密并ftp傳送到遠(yuǎn)程主機(jī)目錄的實(shí)現(xiàn)方法
標(biāo)題鏈接：
http://weahome.cn/article/pecssc.html
重慶分公司
重慶分公司
