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<entries></entries> 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"));
}
}
<!-- comment these out if you want to see an example of custom fields, but remember to name the fields
in the same way they are named here: 'imfeeling' (livejournal.com style), 'listening' and 'new_field'
<p>
<b></b> <br />
<b>:</b> <br />
<b></b>?</p>
-->
分享到:
相关推荐
用java语言编写的ftp小工具,可以按指定时间监控ftp服务器,把服务器指定目录内新产生的文件或者文件夹下载到本地指定文件夹,下载后删除数据。 也可以监控本地文件夹,把文件夹内新产生的文件或者文件夹整体上传到...
java+jsp代码实现从FTP服务器上传下载文件。 里面给了java方法和jsp页面的代码。主要是实现从FTP服务器上面下载文件到自己本地文件夹下面。另外还给了几个网站供大家参考。
java实现对ftp服务器上传下载文件,全套代码,亲测,从项目中抽取出来的
凭借着这个工具类,可以方便的上传文件到FTP服务器,也可从FTP下载指定的文件到本地
上传文件到FTP服务器,支持断点续传,同时支持LINUX主机,代码里面包括了比较多的java网络操作类,比如连接FTP的常规类、递归创建远程服务器目录 上传文件到服务器,新上传和断点续传操作,远程文件名,在上传之前...
java ftp 文件上传,两个工具类,一个是直接写的,一个是进行了二次封装的。代码示例,项目工程jdk版本1.7的。
java 连接linux系统上的ftp服务器,通过java代码上传,下载文件 通过链接ftp,获取文件列表,上传。下载、删除文件功能实现
JAVA操作FTP文件服务器上传与下载文件,包含远程动态创建文件夹、查看文件是否存在、删除文件、上传文件和下载文件等方法
这是一个Java语言写成的上传到文件服务器的源代码 编译能通过可直接运行 另加三个实例代码
主要介绍了JAVA技术实现上传下载文件到FTP服务器(完整),本文使用 Apache Jakarta Commons Net(commons-net-3.3.jar) 基于FileZilla Server服务器实现FTP服务器上文件的上传/下载/删除等操作,需要的朋友可以参考下
2.1 配置使用IIS的FTP服务器; 2.2 客户端发出各种操作命令;至少实现conn(连接)、list(列示文件)、retr(下载)、store(上载)的功能。 2.3 接收服务器的操作结果。 3.用户界面:客户端界面用户可以设置远程...
可能需要定时的自动去检测服务器是否存在所需要的文件,如果有就自动通过ftp下载,以上为java实现代码
Java操作FTP服务器,连接FTP,上传文件,删除文件,下载文件
构建了一个ftp服务器,通过命令ftp可登录,登录后,无法下载,上传,ls也无法执行。 通过 passive 开启和关闭 PASV模式,再ls 也是同样的问题, # 主动模式 $ pftp -v -A -d 211.159.185.xxx Connected to 211...
本文介绍了在Java中,如何使用Java现有的可用的库来编写FTP客户端代码,并开发成Applet控件,做成基于Web的批量、大文件的上传下载控件。文章在比较了一系列FTP客户库的基础上,就其中一个比较通用且功能较强的j-ftp...
使用Java远程上传压缩包到服务器,或者在服务器上拉去压缩包或者文件,在服务器上创建目录。
这是用java实现ftp操作的一些代码,里面有上传,下载,删除服务器上制定文件以及断点续传的操作!!希望能帮助需要的人!!
java FTP上传文件(进度条显示进度)
使用java基于socket开发的FTP客户端和服务器,实现了基本的登录,注册,上传下载,等各种功能,同时使用了基于工厂的设计模式,具有较好的可扩展性
因此选择了FTP上传,在网上搜索了很多例子后并经自己对比整理后决定采用apache包中的FTP实现上传下载,在使用过程需要注意的是对中文名进行字符转码,FTP服务器我选用的是Serve-U,这个工具以前用过,比较稳定。...