13518219792
FTP 的主要操作都是基于各种命令基础之上的。常用的命令有： · 设置传输模式，它包括ASCⅡ(文本) 和BINARY 二进制模式; · 目录操作，改变或显示远程计算机的当前目录(cd、dir/ls 命令); · 连接操作，open命令用于建立同远程计算机的连接；close命令用于关闭连接; · 发汪侍仿送操作，put命令用于传送文件到谈旅远程计算机；mput 命令用于传送多个文件到远程计算机; · 获取操作，get命令用于接收一个文件；mget命令用于接收多个文件。 编程思路 根据FTP 的工作原理，在主函数中建立一个服务器套接字端口，等待客户端请求困纤，一旦客户端请求被接受，服务器程序就建立一个服务器分线程，处理客户端的命令。如果客户端需要和服务器端进行文件的传输，则建立一个新的套接字连接来完成文件的操作。 编程技巧说明
站在用户的角度思考问题，与客户深入沟通，找到乌兰察布网站设计与乌兰察布网站推广的解决方案，凭借多年的经验，让设计与互联网技术结合，创造个性化、用户体验好的作品，建站类型包括：网站制作、做网站、企业官网、英文网站、手机端网站、网站推广、国际域名空间、网站空间、企业邮箱。业务覆盖乌兰察布地区。
; FTP是Internet 上用来传送文件的协议 在Internet上通过FTP 服务器可以进行文件的上传（Upload）或下载（Download） FTP是实时联机服务 在使用它之前必须是具有该服务的一个用户（用户名和闷做派口令） 工作时客户端必须先登录到作为服务器一方的计算机上 用户登录后可以进行文件搜索和文件传送等有关操作 如改变当前工作目录 列文件目录 设置传输参数及传送文件等 使用FTP可以传送所有类型的文件 如文本文件 二进制可执行文件 图象文件 声音文件和数据压缩文件等 FTP 命令 FTP 的主要操作都是基于各种命令基础之上的 常用的命令有 ◆ 设置传输模式 它包括ASCⅡ（文本） 和BINARY 二进制模式 ◆ 目录操作 改变或显示远程计算机的当前目录（蚂贺cd dir/ls 命令） ◆ 连接操作 open命令用于建立同远程计算机的连接 close命令用于关闭连接 ◆ 发送操作 put命令用于传送文件到远程计算机 mput 命令用于传送多个文件到远程计算机 ◆ 获取操作 get命令用于接收一个文件 mget命令用于接收多个文件 编程思路 根据FTP的工作原理 在主函数中建立一个服务器套接字端口 等待客户端请求 一旦客户端请求被接受 服务器程序就建立一个服务器分线程 处理客户端的命令 如果客户端需要和服务器端进行文件的传输 则建立一个新的套接字连接来完成文件的操作
编程技巧说明 主函数设计 在主函数中 完成服务器端口的侦听和服务线程的创建 我们利用一个静态字符串变量initDir 来保存服务器线程运行时所在的工作目录 服务器的初始工作目录是由程序运行时用户输入的 缺省为C盘的根目录 具体的代码如下 public class ftpServer extends Thread{ private Socket socketClient; private int counter; private static String initDir; public static void main（String[] args）{ if（args length != ） { initDir = args[ ]; }else{ initDir = c: ;} int i = ; try{ System out println（ ftp server started! ） //监听 号端口 ServerSocket s = new ServerSocket（ ） for（ ）{ //接受客户端请求 Socket ining = s accept（） //创建服务线程 new ftpServer（ining i） start（） i++; } }catch（Exception e）胡型{} } 线程类的设计 线程类的主要设计都是在run（）方法中实现 用run（）方法得到客户端的套接字信息 根据套接字得到输入流和输出流 向客户端发送欢迎信息 FTP命令的处理 （ ） 访问控制命令 ◆ user name（user） 和 password （pass） 命令处理代码如下 if（str startsWith（ USER ））{ user = str substring（ ） user = user trim（） out println（ Password ） } if（str startsWith（ PASS ）） out println（ User +user+ logged in ） User 命令和 Password 命令分别用来提交客户端用户输入的用户名和口令 ◆ CWD （CHANGE WORKING DIRECTORY） 命令处理代码如下 if（str startsWith（ CWD ））{ String str = str substring（ ） dir = dir+ / +str trim（） out println（ CWD mand succesful ） } 该命令改变工作目录到用户指定的目录 ◆ CDUP （CHANGE TO PARENT DIRECTORY） 命令处理代码如下 if（str startsWith（ CDUP ））{ int n = dir lastIndexOf（ / ） dir = dir substring（ n） out println（ CWD mand succesful ） } 该命令改变当前目录为上一层目录 ◆ QUIT命令处理代码如下 if（str startsWith（ QUIT ）） { out println（ GOOD BYE ） done = true;} 该命令退出及关闭与服务器的连接 输出GOOD BYE
（ ） 传输参数命令 ◆ Port命令处理代码如下 if（str startsWith（ PORT ）） { out println（ PORT mand successful ） int i = str length（） ; int j = str lastIndexOf（ ） int k = str lastIndexOf（ j ） String str str ;str = ; str = ;for（int l=k+ ; lstr = str + str charAt（l） } for（int l=j+ ;l=i;l++）{ str = str + str charAt（l） } tempPort = Integer parseInt（str ） * * +Integer parseInt（str ） } 使用该命令时 客户端必须发送客户端用于接收数据的 位IP 地址和 位 的TCP 端口号 这些信息以 位为一组 使用十进制传输 中间用逗号隔开 ◆ TYPE命令处理代码如下 if（str startsWith（ TYPE ））{ out println（ type set ） } TYPE 命令用来完成类型设置 （ ） FTP 服务命令 ◆ RETR （RETEIEVE） 和 STORE （STORE）命令处理的代码 if（str startsWith（ RETR ））{ out println（ Binary data connection ） str = str substring（ ） str = str trim（） RandomAccessFile outFile = newRandomAccessFile（dir+ / +str r ） Socket tempSocket = new Socket（host tempPort） OutputStream outSocket= tempSocket getOutputStream（） byte byteBuffer[]= new byte[ ]; int amount; try{ while（（amount = outFile read（byteBuffer）） != ）{
outSocket write（byteBuffer amount） } outSocket close（） out println（ transfer plete ） outFile close（） tempSocket close（） } catch（IOException e）{} } if（str startsWith（ STOR ））{ out println（ Binary data connection ） str = str substring（ ） str = str trim（） RandomAccessFile inFile = newRandomAccessFile（dir+ / +str rw ） Socket tempSocket = new Socket（host tempPort） InputStream inSocket= tempSocket getInputStream（） byte byteBuffer[] = new byte[ ]; int amount; try{ while（（amount =inSocket read（byteBuffer） ）！= ）{ inFile write（byteBuffer amount） } inSocket close（） out println（ transfer plete ） inFile close（） tempSocket close（） } catch（IOException e） {} } 文件传输命令包括从服务器中获得文件RETR和向服务器中发送文件STOR 这两个命令的处理非常类似 处理RETR命令时 首先得到用户要获得的文件的名称 根据名称创建一个文件输入流 然后和客户端建立临时套接字连接 并得到一个输出流 随后 将文件输入流中的数据读出并借助于套接字输出流发送到客户端 传输完毕以后 关闭流和临时套接字 STOR 命令的处理也是同样的过程 只是方向正好相反 ◆ DELE （DELETE）命令处理代码如下 if（str startsWith（ DELE ））{ str = str substring（ ） str = str trim（） File file = new File（dir str） boolean del = file delete（） out println（ delete mand successful ） } DELE 命令用于删除服务器上的指定文件 ◆ LIST命令处理代码如下 if（str startsWith（ LIST ）） { try{ out println（ ASCII data ） Socket tempSocket = new Socket（host tempPort） PrintWriter out = new PrintWriter（tempSocket getOutputStream（） true） File file = new File（dir） String[] dirStructure = new String[ ]; dirStructure= file list（） String strType= ; for（int i= ;iif（ dirStructure[i] indexOf（ ） == ） { strType = d ;} else{ strType = ;} out println（strType+dirStructure[i]） } tempSocket close（） out println（ transfer plete ） } catch（IOException e） {} LIST 命令用于向客户端返回服务器中工作目录下的目录结构 包括文件和目录的列表 处理这个命令时 先创建一个临时的套接字向客户端发送目录信息 这个套接字的目的端口号缺省为 然后为当前工作目录创建File 对象 利用该对象的list（）方法得到一个包含该目录下所有文件和子目录名称的字符串数组 然后根据名称中是否含有文件名中特有的 来区别目录和文件 最后 将得到的名称数组通过临时套接字发送到客户端 lishixinzhi/Article/program/Java/hx/201311/26847
package com.quantongfu.;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java点虐 .ServerSocket;
import java.util.List;
import org.apache点抗 mons点虐 .;
import org.apache.log4j.Logger;
import org.apache.log4j点虐 .SocketServer;
import com.quantongfu.conf.FtpConf;
/**
* @项目名称: telinSyslog
* @文件名称:
* @创建日期：2015年9月14日 下午3:22:08
* @功能描述：ftp实体类，用于连接，上传
* @修订记录：
*/
public class Ftp {
private static Logger logger = Logger.getLogger();
private FTPClient ftp;
/**
*
* @param path
* 上传到ftp服务器哪个路径下
* @param addr
* 地址
* @param port
* 端口号
* @param username
* 用户名
* @param password
* 密码
* @return
* @throws Exception
*/
public boolean connect() throws Exception {
boolean result = false;
ftp = new FTPClient();
int reply;
(FtpConf.FTP_HOST, FtpConf.FTP_PORT);
(FtpConf.FTP_USER_NAME, FtpConf.FTP_PASSWORD);
;
;
reply = ;
if (!FTPReply.isPositiveCompletion(reply)) {
;
return result;
}
if (FtpConf.IS_FTP_DIRECTORY) {
;
}
result = true;
return result;
}
/**
*
* @param files
* 搜扮携 上传的文件
* @throws Exception
*/
public boolean upload(File file) throws IOException 世伏{
FileInputStream input = null;
try {
input = new FileInputStream(file);
boolean b = (file.getName() + ".tmp", input);
if (b) {
b = (file.getName() + ".tmp", file.getName());
}
return b;
} catch (Exception e) {
e.printStackTrace();
return false;
} finally {
缺族 if (input != null) {
input.close();
}
}
}
/**
*
* @param files
* 上传的文件
* @throws Exception
*/
public boolean upload(ServerSocket server, File file) throws Exception {
FileInputStream input = null;
try {
if (!file.exists()) {
return true;
}
input = new FileInputStream(file);
boolean b = (server, file.getName() + ".tmp", input);
if (b) {
b = (file.getName() + ".tmp", file.getName());
if (b) {
file.delete();
}
}
return b;
} catch (Exception e) {
logger.error("ftp error" + e.getMessage());
return false;
} finally {
if (input != null) {
try {
input.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
/*断开连接*/
public void disConnect() {
try {
if (ftp != null) {
;
}
} catch (IOException e) {
e.printStackTrace();
}
}
/*获取连接*/
public static Ftp getFtp() {
Ftp ftp = new Ftp();
try {
;
} catch (Exception e) {
logger.error("FTP连接异常" + e.getMessage());
e.printStackTrace();
}
return ftp;
}
/*重连*/
public Ftp reconnect() {
disConnect();
return getFtp();
}
}
使用Apache FtpClient jar包，获取jar :
参考
client = new FTPSClient(implictSSL);
KeyManagerFactory kmf = KeyManagerFactory.getInstance("X509");
kmf.init(KeyStore.getInstance("BKS"), "wshr.ut".toCharArray());
client.setTrustManager(new X509TrustManager() {
public X509Certificate[] getAcceptedIssuers() { return null; }
public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException { }
public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException { }
});
client.setKeyManager(kmf.getKeyManagers()[0]);
client.setNeedClientAuth(false);
client.setUseClientMode(false);
