ftp客户端代码java
维护一个ftp的服务器列表，包含ip端口用户名密码
定时的递归扫描每个ftp服务器的目录和文件，保存到本地数据库
搜索的时候，从本地数据库查询
至于java访问ftp服务器的方法，已经有很多现成的实现
比如www.apache.org的commons-net里就有
有的版本的sun jdk自身就带
㈡ JAVA编写FTP连接报错java.net.ConnectException: Connection refused: connect FTP
你用的FTPClient引入不对吧，我们项目上都是用的
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;
下面是我们项目上用到的FTP的实现代码（FTP需要先连接，再登录，之后就是校验登录是否成功），具体代码如下：
/**
*获取FTPClient对象
*
*@paramftpHostFTP主机服务器
*@paramftpPasswordFTP登录密码
*@paramftpUserNameFTP登录用户名
*@paramftpPortFTP端口默认为21
*@returnFTPClient
*@throwsException
*/
(StringftpHost,StringftpUserName,
StringftpPassword,intftpPort)throwsException{
try{
FTPClientftpClient=newFTPClient();
ftpClient.connect(ftpHost,ftpPort);//连接FTP服务器
ftpClient.login(ftpUserName,ftpPassword);//登陆FTP服务器
if(!FTPReply.isPositiveCompletion(ftpClient.getReplyCode())){
logger.error("未连接到FTP，用户名或密码错误!");
ftpClient.disconnect();
returnnull;
}else{
logger.info("FTP连接成功!");
returnftpClient;
}
}catch(){
logger.error("FTP的IP地址可能错误，请正确配置!");
throwsocketException;
}catch(IOExceptionioException){
logger.error("FTP的端口错误,请正确配置!");
throwioException;
}
}
㈢ 怎样用java开发ftp客户端
package zn.ccfccb.util;
import hkrt.b2b.view.util.Log;
import hkrt.b2b.view.util.ViewUtil;
import java.io.ByteArrayOutputStream;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.InputStream;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import zn.ccfccb.util.CCFCCBUtil;
import zn.ccfccb.util.ZipUtilAll;
public class CCFCCBFTP {
/**
* 上传文件
*
* @param fileName
* @param plainFilePath 明文文件路径路径
* @param filepath
* @return
* @throws Exception
*/
public static String fileUploadByFtp(String plainFilePath, String fileName, String filepath) throws Exception {
FileInputStream fis = null;
ByteArrayOutputStream bos = null;
FTPClient ftpClient = new FTPClient();
String bl = "false";
try {
fis = new FileInputStream(plainFilePath);
bos = new ByteArrayOutputStream(fis.available());
byte[] buffer = new byte[1024];
int count = 0;
while ((count = fis.read(buffer)) != -1) {
bos.write(buffer, 0, count);
}
bos.flush();
Log.info("加密上传文件开始");
Log.info("连接远程上传服务器"+CCFCCBUtil.CCFCCBHOSTNAME+":"+22);
ftpClient.connect(CCFCCBUtil.CCFCCBHOSTNAME, 22);
ftpClient.login(CCFCCBUtil.CCFCCBLOGINNAME, CCFCCBUtil.CCFCCBLOGINPASSWORD);
// Log.info("连接远程上传服务器"+"192.168.54.106："+2021);
// ftpClient.connect("192.168.54.106", 2021);
// ftpClient.login("hkrt-CCFCCBHK", "3OLJheziiKnkVcu7Sigz");
FTPFile[] fs;
fs = ftpClient.listFiles();
for (FTPFile ff : fs) {
if (ff.getName().equals(filepath)) {
bl="true";
ftpClient.changeWorkingDirectory("/"+filepath+"");
}
}
Log.info("检查文件路径是否存在：/"+filepath);
if("false".equals(bl)){
ViewUtil.dataSEErrorPerformedCommon( "查询文件路径不存在："+"/"+filepath);
return bl;
}
ftpClient.setBufferSize(1024);
ftpClient.setControlEncoding("GBK");
// 设置文件类型（二进制）
ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
ftpClient.storeFile(fileName, fis);
Log.info("上传文件成功："+fileName+"。文件保存路径："+"/"+filepath+"/");
return bl;
} catch (Exception e) {
throw e;
} finally {
if (fis != null) {
try {
fis.close();
} catch (Exception e) {
Log.info(e.getLocalizedMessage(), e);
}
}
if (bos != null) {
try {
bos.close();
} catch (Exception e) {
Log.info(e.getLocalizedMessage(), e);
}
}
}
}
/**
*下载并解压文件
*
* @param localFilePath
* @param fileName
* @param routeFilepath
* @return
* @throws Exception
*/
public static String fileDownloadByFtp(String localFilePath, String fileName,String routeFilepath) throws Exception {
FileInputStream fis = null;
ByteArrayOutputStream bos = null;
FileOutputStream fos = null;
FTPClient ftpClient = new FTPClient();
String SFP = System.getProperty("file.separator");
String bl = "false";
try {
Log.info("下载并解密文件开始");
Log.info("连接远程下载服务器"+CCFCCBUtil.CCFCCBHOSTNAME+":"+22);
ftpClient.connect(CCFCCBUtil.CCFCCBHOSTNAME, 22);
ftpClient.login(CCFCCBUtil.CCFCCBLOGINNAME, CCFCCBUtil.CCFCCBLOGINPASSWORD);
// ftpClient.connect(CMBCUtil.CMBCHOSTNAME, 2021);
// ftpClient.login(CMBCUtil.CMBCLOGINNAME, CMBCUtil.CMBCLOGINPASSWORD);
FTPFile[] fs;
ftpClient.makeDirectory(routeFilepath);
ftpClient.changeWorkingDirectory(routeFilepath);
bl = "false";
fs = ftpClient.listFiles();
for (FTPFile ff : fs) {
if (ff.getName().equals(fileName)) {
bl = "true";
Log.info("下载文件开始。");
ftpClient.setBufferSize(1024);
// 设置文件类型（二进制）
ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
InputStream is = ftpClient.retrieveFileStream(fileName);
bos = new ByteArrayOutputStream(is.available());
byte[] buffer = new byte[1024];
int count = 0;
while ((count = is.read(buffer)) != -1) {
bos.write(buffer, 0, count);
}
bos.flush();
fos = new FileOutputStream(localFilePath+SFP+fileName);
fos.write(bos.toByteArray());
Log.info("下载文件结束："+localFilePath);
}
}
Log.info("检查文件是否存："+fileName+" "+bl);
if("false".equals(bl)){
ViewUtil.dataSEErrorPerformedCommon("查询无结果，请稍后再查询。");
return bl;
}
return bl;
} catch (Exception e) {
throw e;
} finally {
if (fis != null) {
try {
fis.close();
} catch (Exception e) {
Log.info(e.getLocalizedMessage(), e);
}
}
if (bos != null) {
try {
bos.close();
} catch (Exception e) {
Log.info(e.getLocalizedMessage(), e);
}
}
if (fos != null) {
try {
fos.close();
} catch (Exception e) {
Log.info(e.getLocalizedMessage(), e);
}
}
}
}
// 调用样例：
public static void main(String[] args) {
try {
// 密钥/res/20150228
// ZipUtilAll.unZip(new File(("D:/123/123.zip")), "D:/123/");
// ZipDemo1232.unZip(new File(("D:/123/123.zip")), "D:/123/");
// 明文文件路径
String plainFilePath = "D:/req_20150204_0011.txt";
// 密文文件路径
String secretFilePath = "req_20150204_00134.txt";
// 加密
// encodeAESFile(key, plainFilePath, secretFilePath);
fileDownloadByFtp("D://123.zip","123.zip","req/20150228");
ZipUtilAll.unZip("D://123.zip", "D:/123/李筱/");
// 解密
plainFilePath = "D:/123.sql";
// secretFilePath = "D:/test11111.sql";
// decodeAESFile(key, plainFilePath, secretFilePath);
} catch (Exception e) {
e.printStackTrace();
}
}
}
㈣ 怎么用Java开发FTP客户端
摘要
本文解释了如何利用库用Java语言编写FTP客户端代码。它比较了FTP库的一个完全列表，演示了每个库的优点和缺点，并且帮助决策者为他们的需要选择适当的库。另外，本文阐述了Fa?ade模式如何在取代一个库时改变管理。最后，作者Jean-Pierre Norguet讨论并解决了由于缺乏权威性的说明书引起的一些问题。
让我们假设一个情景：我们要编写一个纯Java应用程序，该程序必须从运行FTP服务器的远程计算机上下载文件。我们也通过远程文件信息，像名字、日期、或者尺寸，来过滤下载。
自己来写一个FTP协议处理，尽管是有可能，并且可能很有趣。但是这样做也有可能有困难、花费长时间、并且有潜在的风险。既然我们不肯花费时间、精力、或者金钱自己来写一个处理器，那我们推荐使用一个可重用的现有的软件组件。万维网上有并且大量的库可供使用。有了一个FTP客户端库，下载一个文件用Java语言编写就像下面一样简单：
FTPClient ftpClient = new FTPClient();
ftpClient.connect("ftp.foo.com", "user01", "pass1234");
ftpClient.download("C:\\Temp\\", "README.txt");
// Eventually other operations here ...
ftpClient.disconnect();
寻找一个适合我们需要的高质量的Java FTP客户端库并不像他看起来那么简单；它可能相当困难。要找到一个Java FTP客户端库需要花一些时间。接着，在我们找到所有的已存在的库之后，我们选哪个？每个库适合不同的需要。库在质量上是不等的，并且它们的设计有本质的区别。每个提供一套不同的属性和使用不同类型的行话来描述他们。
因此，计算和比较FTP客户端库证明是困难而且令人迷惑的。重复使用已存在的组件是一个值得推荐的过程，但在这个例子中，启动它也是令人沮丧的。并且这有点羞愧：在选好的一个好的FTP库之后，剩下的工作就是例程了。
本文旨在使选择过程简短、容易、并且有价值。我首先列出了所有的FTP客户端库。接着，我定义和描述了库应该用某种方式找到的相关标准的一个表格。最后，我列出了一个总浏览的矩阵，该矩阵给出了库间相互比较的过程的快速浏览。所有的信息提供了我们作出一个迅速、可靠、和长期的决定所需的每件事。
使用JDK（Java 开发工具集）的FTP支持
用于FTP的访问规范是用于注释的请求：959（RFC959）。Sun Microsystems提供了JDK的一个RFC959执行。但是它是内部的、非文档化的、并且不提供任何资源。当RFC959在尚未公开时，它实际上是执行RFC1738、URL规范的一个公共界面的后终端。如图1。
图1. 使用JDK的FTP支持。
RFC1738的一个执行过程在JDK中作为标准给出。它为基本的FTP传送做一个可推理的工作。它是公共的、文档化的、并且提供源代码。要使用它，我们可编写下面语句：
URL url = new URL("ftp://user01:[email protected]/README.txt;type=i");
URLConnection urlc = url.openConnection();
InputStream is = urlc.getInputStream(); // To download
OutputStream os = urlc.getOutputStream(); // To upload
使用JDK的FTP客户端严格的遵守标准推荐，但它有以下几个说明：
它从根本上区别于第三方的FTP客户端库；这些执行RFC959而不是RFC1738
RFC959用大多数的桌面FTP客户端工具执行。许多Java程序员使用这些工具连接到FTP服务器上。作为一个尝试，这些工具及有可能优先于类似的RFC959库。
URL 和URLConnection类只开放用于通讯的流。Sun库不为构造原始的FTP服务器响应成为像String、 File、 RemoteFile、 或者 Calendar之类的更合用的Java对象而提供直接支持。所以我们不得不编写更多的代码，只是为了把数据写入一个文件中或者开始一个目录列表。
正像RFC1738的3.2部分解释的一样，"最优化"，FTP URL在每个操作后要求关闭（控制）连接。这对于传送许多小文件是一种浪费、并且毫无效率。而且，作了特别限制FTP服务器可能把会这样一个通讯开销认为一个是恶毒的网络攻击或者滥用而拒绝提供进一步的服务。
最后，它缺乏几个有用的属性。
由于以上所有或者某种原因，可优先使用一个第三方的库。下面部分列出了可供选择的第三方的库。
见:http://www.javaworld.com/javaworld/jw-04-2003/ftp/jw-0404-ftptable.html
㈤ 关于JAVA FTP 客户端程序异常
501 PORT not allowed after EPSV ALL~~~说明还是网络的问题，我对网络不熟~~~比如用ftp工具的时候，有些ftp站点必须采用被动模式才能连接。下面的你看看吧，或许有用，找网管看看应该使用哪种方式访问
***************************************************
3. EPSV命令
EPSV请求服务器在一个数据端口上侦听等待连接，它可以带参数。对它的响应是TCP端口号。响应的格式与EPRT参数的很象。这对实现上有很大的方便。而且响应还留下了网络协议和/或网络地址的空位，可以供以后使用。使用扩展地址进行被动模式的响应码必须是229，对它的解释如下：
2yz 主动完成
x2z 连接
xy9 进行扩展的被动模式
响应的格式如下：
<指示服务器已经进入初扩展的被动模式>
(<d><d><d><TCP端口><d>)
包括在括号内的字符串必须是EPRT打开数据连接的端口。具体如上所未，这里就不多说了。数据连接使用的协议必须和控制连接使用的协议和地址一致，下面是响应的一个例子：
Entering Extended Passive Mode (|||6446|)
标准错误代码500和501对EPSV已经足够了。在EPSV命令没有使用参数时，服务器会基于控制连接所使用的协议选择数据连接使用的网络协议。但是在有代理的情况下，这种机制可能不合适。因此客户也需要能够要求一个指定协议。如果服务器返回说明它在指定端口不支持此协议，客户必须发送ABOR（放弃）命令使服务器关闭连接，然后客户再使用EPSV命令要求使用特定的网络协议，具体格式如下：
EPSV<空格><网络协议>
如果请求的网络协议是服务器支持的，那就必须使用此协议；如果不支持，则返回522。最后，EPSV命令可以使用参数"ALL"通过网络地址翻译器，EPRT命令不再使用。下面是例子：
EPSV<空格>ALL
接收到此命令后，服务器要拒绝除了EPSV以外所有建立连接的命令。在下一节我们将详细说明此命令的功能。
**********************************************************************
㈥ 如何用Java获取远程服务器中指定目录下的所有文件夹名
//创建一个ftpclient对象
FTPClientfc=newFTPClient();
//创建连接
fc.connect("ip地址",端口号);
//登录
fc.login("用户名","密码");
//校验登陆
reply=fc.getReplyCode();
if(!FTPReply.isPositiveCompletion(reply)){
fc.disconnect();
}
//切换到指定地址
fc.changeWorkingDirectory("地址");
//获取该目录下的所有文件
FTPFile[]fs=fc.listFiles();
for（FTPFileff:fs）{
System.out.println(ff.getName());
}
//注销退出
fc.logout();
㈦ 用java写一个sftp客户端程序 能够上一个sftp的目录下载文件到本地指定目录
不需要装软件，下载需要执行sftp服务器目录和本地目录
你说的directory空指针，应该是你没有指定从sftp的哪个目录下载
㈧ 用java编写ftp客户端这样的网络程序需用到Java的什么知识
会socket编程就可以了
我给你个测试：
import java.awt.*;
import java.awt.event.*;
import java.io.*;
import javax.swing.*;
import sun.net.ftp.*;
//FTP连接与浏览
public class FtpClientDemo extends JFrame{
JTextField jtfServer; //输入Ftp服务器地址
JTextField jtfUser; //输入用户名
JPasswordField jtfPass; //输入密码
JButton jbConnect; //连接按钮
JButton jbDisconnect; //断开按钮
JTextArea jtaShowFiles; //显示服务器目录与文件
FtpClient ftpClient;
public FtpClientDemo(){
super("FTP连接与浏览"); //调用父类构造函数
jtfServer=new JTextField(13); //实例化组件
jtfUser=new JTextField(8);
jtfPass=new JPasswordField(8);
jbConnect=new JButton("连接");
jbDisconnect=new JButton("断开");
jtaShowFiles=new JTextArea();
Container container=getContentPane(); //得到容器
JPanel panel=new JPanel(); //实例化面板
panel.add(new JLabel("地址")); //增加组件到面板上
panel.add(jtfServer);
panel.add(new JLabel("用户名"));
panel.add(jtfUser);
panel.add(new JLabel("密码"));
panel.add(jtfPass);
container.add(panel,BorderLayout.NORTH); //增加组件到容器上
JScrollPane jsp=new JScrollPane(jtaShowFiles);
container.add(jsp,BorderLayout.CENTER);
panel=new JPanel();
panel.add(jbConnect);
panel.add(jbDisconnect);
container.add(panel,BorderLayout.SOUTH);
jbConnect.addActionListener(new ActionListener(){ //连接按钮事件处理
public void actionPerformed(ActionEvent ent){
connectServer(); //调用连接到服务器的方法
}
});
jbDisconnect.addActionListener(new ActionListener(){ //断开按钮事件处理
public void actionPerformed(ActionEvent ent){
disconnectServer(); //调用断开与服务器连接的方法
}
});
setSize(460,260); //设置窗口尺寸
setVisible(true); //设置窗口可视
setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); //关闭窗口时退出程序
}
public void connectServer(){
try{
ftpClient = new FtpClient(); //实例化FtpClient对象
String serverAddr=jtfServer.getText(); //得到服务器地址
String user=jtfUser.getText(); //得到用户名
String pass=jtfPass.getPassword().toString(); //得到密码
ftpClient.openServer(serverAddr); //连接到服务器
ftpClient.login(user,pass); //在服务器上注册
InputStream is=ftpClient.list(); //得到服务器目录与文件列表输入流
StringBuffer info=new StringBuffer(); //实例化StringBuffer对象,用于输出信息
int ch;
while ((ch=is.read())>=0){ //未读完列表,则继续
info.append((char)ch); //增加信息
}
jtaShowFiles.setText(new String(info)); //显示信息
is.close(); //关闭输入流
}
catch (IOException ex){
JOptionPane.showMessageDialog(FtpClientDemo.this,ex.getMessage()); //显示提示信息
ex.printStackTrace(); //在命令行窗口输出出错信息
}
}
public void disconnectServer(){
try{
ftpClient.closeServer(); //关闭与服务器的连接
}
catch (IOException ex){
ex.printStackTrace();
}
}
public static void main(String[] args){
new FtpClientDemo();
}
}
㈨ 求用java写一个ftp服务器客户端程序。
import java.io.*;
import java.net.*;public class ftpServer extends Thread{ public static void main(String args[]){
String initDir;
initDir = "D:/Ftp";
ServerSocket server;
Socket socket;
String s;
String user;
String password;
user = "root";
password = "123456";
try{
System.out.println("MYFTP服务器启动....");
System.out.println("正在等待连接....");
//监听21号端口
server = new ServerSocket(21);
socket = server.accept();
System.out.println("连接成功");
System.out.println("**********************************");
System.out.println("");
InputStream in =socket.getInputStream();
OutputStream out = socket.getOutputStream();
DataInputStream din = new DataInputStream(in);
DataOutputStream dout=new DataOutputStream(out);
System.out.println("请等待验证客户信息....");
while(true){
s = din.readUTF();
if(s.trim().equals("LOGIN "+user)){
s = "请输入密码:";
dout.writeUTF(s);
s = din.readUTF();
if(s.trim().equals(password)){
s = "连接成功。";
dout.writeUTF(s);
break;
}
else{s ="密码错误，请重新输入用户名：";<br> dout.writeUTF(s);<br> <br> }
}
else{
s = "您输入的命令不正确或此用户不存在，请重新输入：";
dout.writeUTF(s);
}
}
System.out.println("验证客户信息完毕...."); while(true){
System.out.println("");
System.out.println("");
s = din.readUTF();
if(s.trim().equals("DIR")){
String output = "";
File file = new File(initDir);
String[] dirStructure = new String[10];
dirStructure= file.list();
for(int i=0;i<dirStructure.length;i++){
output +=dirStructure[i]+"\n";
}
s=output;
dout.writeUTF(s);
}
else if(s.startsWith("GET")){
s = s.substring(3);
s = s.trim();
File file = new File(initDir);
String[] dirStructure = new String[10];
dirStructure= file.list();
String e= s;
int i=0;
s ="不存在";
while(true){
if(e.equals(dirStructure[i])){
s="存在";
dout.writeUTF(s);
RandomAccessFile outFile = new RandomAccessFile(initDir+"/"+e,"r");
byte byteBuffer[]= new byte[1024];
int amount;
while((amount = outFile.read(byteBuffer)) != -1){
dout.write(byteBuffer, 0, amount);break;
}break;
}
else if(i<dirStructure.length-1){
i++;
}
else{
dout.writeUTF(s);
break;
}
}
}
else if(s.startsWith("PUT")){
s = s.substring(3);
s = s.trim();
RandomAccessFile inFile = new RandomAccessFile(initDir+"/"+s,"rw");
byte byteBuffer[] = new byte[1024];
int amount;
while((amount =din.read(byteBuffer) )!= -1){
inFile.write(byteBuffer, 0, amount);break;
}
}
else if(s.trim().equals("BYE"))break;
else{
s = "您输入的命令不正确或此用户不存在，请重新输入：";
dout.writeUTF(s);
}
}
din.close();
dout.close();
in.close();
out.close();
socket.close();
}
catch(Exception e){
System.out.println("MYFTP关闭!"+e);
}
}}
㈩ FTP客户端程序设计(java)
mina.apache.org 服务器端，客户端都有！开源的！