Java從FTP服務器上傳下載文件的代碼

jopen 10年前發布 | 30K 次閱讀 FTP 文件上傳
import java.io.;
import java.util.;
import java.sql.;
import java.net.Socket;
import java.net.ServerSocket;
import java.net.InetAddress;
import sun.net.ftp.;
import sun.net.TelnetInputStream;
import sun.net.TelnetOutputStream;
/*

用于連接到FTP服務器上
@return String 若失敗則返回失敗信息，成功返回空字符串
*/
private String connectToFtpServer(){
if ((this.ftpserver==null)||(this.ftpserver.equals(""))) return "FTP服務器名設置不正確!";

try{
fc.openServer(this.ftpserver);
fc.login(this.ftpuser,this.ftppwd);
fc.ascii();
}catch(FtpLoginException e){
return "沒有與FTP服務器連接的權限,或用戶名密碼設置不正確!";
}catch(IOException e){
return "與FTP服務器連接失敗!";
}catch(SecurityException e){
return "沒有權限與FTP服務器連接";
}
return "";
}
/*

用于關閉與FTP服務器的連接
*/
private void closeFtpConnect(){
if (fc.serverIsOpen()){
try{
fc.closeServer();
}catch(Exception e){
}finally{
fc = null;
}
}
}
public String downloadFile(String fileName){
//只下載文本文件或XML文件
if (!this.isTextFile(fileName)) return fileName + "不是XML文件或文本文件";
String retMessage = "";

if (!fc.serverIsOpen()){
retMessage = this.connectToFtpServer();
if (!retMessage.equals("")) return "下載文件：" + fileName + "時無法和FTP服務器連接";
}
//if (conn == null) return "下載文件：" + fileName + "時無法連接到數據庫";
String chkSql = "select 1 from t_trans_log where file_name = '" + fileName + "'";
if (sqlbean.checkQueryRowCount(chkSql) > 0) return retMessage;
if (this.dldir==null) this.dldir = "";
try{
TelnetInputStream is = fc.get(this.dldir + "/" + fileName);
BufferedReader br = new BufferedReader(new InputStreamReader(is));
//讀取文件內容到stringbuffer
StringBuffer sb = new StringBuffer();
int length;
char buffer[] = new char[1];
while((length = br.read(buffer,0,1)) != -1) sb.append(buffer);
//構造sql語句插入記錄
//String ls_lsh = get_lsh(12);
String ls_lsh = ah.getAutoID("xf_lsh",12);
String ls_sql = "insert into t_trans_log(tran_id,tran_flag,file_name,file_content)values('"
ls_sql += ls_lsh + "','0','" + fileName + "','" + sb.toString() + "')";
conn = connmanager.getConnection();
conn.setAutoCommit(false);
sqlbean.executeUpdate(conn,ls_sql);
//將stringbuffer寫入文件中
byte buf[] = sb.toString().getBytes();
OutputStream f1 = new FileOutputStream(this.bdldir + "/" + fileName);
f1.write(buf);
f1.close();
is.close();
br.close();
//刪除文件
this.deleteFile(this.dldir + "/" + fileName);
conn.commit();
conn.setAutoCommit(true);
connmanager.close(conn);
}catch(SQLException e){
retMessage = "下載文件：" + fileName + "時發生數據庫錯誤：" + e.getMessage();
}catch(IOException e){
retMessage = "下載文件：" + fileName + "時發生文件讀寫錯誤：" + e.getMessage();
}
return retMessage;
}
//下載指定目錄下的所有文件
public String downloadFiles(String dirName){
String retMessage = "";
if ((dirName == null)||(dirName.equals(""))) dirName = this.dldir;
String[] sa = this.list();
for (int i = 0;i < sa.length;i++){
retMessage = this.downloadFile(sa[i]);
if (!retMessage.equals("")) return retMessage;
}
return retMessage;
}
//下載FTP服務器上的所有文件
public String downloadFiles(){
return downloadFiles(this.dldir);
}
public String uploadFile(String fileName){
String retMessage = "";
if (!fc.serverIsOpen()){
retMessage = this.connectToFtpServer();
if (!retMessage.equals("")) return "上傳文件：" + fileName + "時無法和FTP服務器連接";
}
//if (conn == null) return "上傳文件：" + fileName + "時無法連接到數據庫";
//String chkSql = "select 1 from t_trans_log where file_name = '" + fileName + "'";
//if (Utils.checkQueryRowCount(conn,chkSql) > 0) return retMessage;
try{
if (this.uldir==null) this.uldir = "";
if (this.buldir==null) this.buldir = "";
TelnetOutputStream os = fc.put(this.uldir + "/" + fileName);
BufferedWriter wr = new BufferedWriter(new OutputStreamWriter(os));
StringBuffer sb = new StringBuffer();
InputStream f1 = new FileInputStream(this.buldir + "/" + fileName);
int size = f1.available();
byte b[] = new byte[size];
while(f1.read(b)!= -1) sb.append(new String(b,0,b.length));
//構造sql語句插入記錄
//String ls_sql = "insert into t_trans_log(tran_id,file_name,file_content)values('" + get_lsh(12) + "','" + fileName + "','" + sb.toString() + "')";
String ls_sql = "insert into t_trans_log(tran_id,file_name,file_content)values('" + ah.getAutoID("xf_lsh",12) + "','" + fileName + "','" + sb.toString() + "')";
conn = connmanager.getConnection();
conn.setAutoCommit(false);
sqlbean.executeUpdate(conn,ls_sql);
//寫入文件
wr.write(sb.toString());
f1.close();
wr.close();
os.close();
//刪除本地文件
File ls_file = new File(this.buldir + "/" + fileName);
ls_file.delete();
conn.commit();
conn.setAutoCommit(true);
connmanager.close(conn);
}catch(SQLException e){
retMessage = "上傳文件：" + fileName + "時發生數據庫錯誤：" + e.getMessage();
}catch(IOException e){
retMessage = "上傳文件：" + fileName + "時發生文件讀寫錯誤：" + e.getMessage();
}
return retMessage;
}
/**

功能：獲取指定目錄文件列表并上傳每一個文件
*/
public String uploadFiles(){
String retMessage = "";

if (this.buldir == null) this.buldir = "";
File ls_file = new File(this.buldir);
File[] entries = ls_file.listFiles();
for(int i=0; i this.uploadFile(entries[i].getName());
if (!retMessage.equals("")) return retMessage;
}
return retMessage;
}
public String deleteFile(String fileName){
String retMessage = "";
try{
Socket socket = new Socket(this.ftpserver,this.ftpport);
BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
if (!reader.readLine().startsWith("220")) return "DELE 無法連接到指定的FTP服務器";
Writer writer = new OutputStreamWriter(socket.getOutputStream());
writer.write("USER " + this.ftpuser + "rn");
writer.flush();
if (!reader.readLine().startsWith("331")) return "DELE 指定的登錄FTP用戶名無效";
writer.write("PASS " + this.ftppwd + "rn");
writer.flush();
if (!reader.readLine().startsWith("230")) return "DELE FTP用戶的登錄口令錯誤";
writer.write("DELE " + fileName + "rn");
writer.flush();
if (!reader.readLine().startsWith("250")) return "無法刪除指定文件" + fileName;
writer.close();
reader.close();
socket.close();
}catch(Exception e){
retMessage = "刪除文件" + fileName + "時發生錯誤" + e.getMessage();
}
return retMessage;
}
/**

功能：獲取指定目錄下以分號分隔的文件名列表
*/
public String getDownloadFileList(String dirName){
StringBuffer sb = new StringBuffer();
String[] sa = list(dirName);
int saLength = sa.length;

for (int i = 0; i < saLength; i++) sb.append(sa[i]).append(";");
return sb.toString();
}
/**

功能：獲取默認下載目錄下以分號分隔的文件名列表
*/
public String getDownloadFileList(){
return getDownloadFileList(this.dldir);
}

/**

功能：以數組的形式返回服務器上指定目錄下的文件名列表
*/
public String[] list(String dirName){
String[] fileNameList = new String[0];
Vector lines = new Vector();
String line = null;

if (fc.serverIsOpen()){
try{
fc.cd(dirName.equals("")?this.dldir:dirName);
TelnetInputStream ins = fc.list();
fc.cd("/");
LineNumberReader in = new LineNumberReader(new InputStreamReader(ins));
line = in.readLine();
while((line != null)&&!(line.trim().equals(""))&&!(line.trim().equals("/n"))){
lines.add(line.substring(line.lastIndexOf(" ") + 1,line.length()));
line = in.readLine();
}
in.close();
ins.close();
}catch(Exception e){
}
if (!lines.isEmpty()) fileNameList = (String[])lines.toArray(fileNameList);
}
return fileNameList;
}
/**

功能：以數組的形式返回服務器上默認下載目錄下的文件名列表
*/
public String[] list(){
return this.list(this.dldir);
}

public String getDlDir(){return this.dldir;}
/**

功能：用于判斷文件是否是XML或TXT文件
*/
private boolean isTextFile(String fileName){
return (fileName.toLowerCase().endsWith(".xml")||fileName.toLowerCase().endsWith(".txt"));
}
} 
</pre>
本文由用戶 jopen 自行上傳分享，僅供網友學習交流。所有權歸原作者，若您的權利被侵害，請聯系管理員。
轉載本站原創文章，請注明出處，并保留原始鏈接、圖片水印。
本站是一個以用戶分享為主的開源技術平臺，歡迎各類分享！
本文地址：http://www.baiduhome.net/lib/view/open1390525435351.html
FTP 文件上傳
Java從FTP服務器上傳下載文件的代碼

相關經驗

相關資訊

相關文檔

目錄
