一、背景

大型系统架构往往被分解为多个独立可运行的组件, 以满足性能、可靠性、可扩展性的需求。多个组件间的数据交互往往采用两种方式：小量数据通过Sock函数、RMI、WebService等接口方式传递；大量采用文件方式传递。
采用文件传递数据有两种方式：通过Windows的NFS系统，文件共享。采用FTP/SFTP做文件上传、下载。本文讲解采用FTP服务传递文件时，FTP服务器环境搭建及公共代码组件。

二、FTP Server环境搭建

2.1 下载开源组件Apache Server 1.0.6版本

到官方网站下载http://mina.apache.org/ftpserver-project

2.2 在users.properties配置文件添加用户名和密码

2.3 在ftpd-typical.xml设置端口，密码是否加密(本配置文件清除密码加密)

2.4 运行FTP Server

命令行执行：start “apache ftp server….” bin\ftpd.bat res\conf\ftpd-typical.xml

三、FTP客户端访问公共组件

3.1 添加commons-net-3.3.jar包到Eclipse.

3.2 公共基础类

import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPReply;public class FTPUtility { private String ftpIP = ""; private int ftpPort = 0; private String userName = ""; private String passWord = ""; FTPClient client = null; /** * 构造函数，初始化连接FTP服务器的参数。 * @param ftpIP 服务器IP地址 * @param ftpPort 服务器端口 * @param userName 登陆用户名 * @param passWord 登陆密码 */ public FTPUtility(String ftpIP, int ftpPort, String userName, String passWord) { this.ftpIP = ftpIP; this.ftpPort = ftpPort; this.userName = userName; this.passWord = passWord; } /** * 连接FTP服务器。 * @return true: 连接成功; false:连接失败 */ public boolean connet() { // 1、连接FTP服务器 client = new FTPClient(); try { client.connect(ftpIP, ftpPort); client.login(userName, passWord); // 文件按二进制传输，按ASCII码传输EXCEL文件会被损坏。 client.setFileType(FTPClient.BINARY_FILE_TYPE); } catch (SocketException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } // 2、检验返回码，是否连接成功。 int replyCode = client.getReplyCode(); if (!FTPReply.isPositiveCompletion(replyCode)) { try { client.disconnect(); } catch (IOException e) { e.printStackTrace(); } System.err.println("FTP server refused connection."); return false; } return true; } /** * 上传文件到FTP服务器 * @param localFilePath 待上传的本地文件完整路径 * @param ftpFileName 上传后保存到FTP服务器的名称(一般和本地文件名一致) * @throws IOException IO异常 */ public void upLoadFile(String localFilePath, String ftpFileName) throws IOException { FileInputStream localIn = new FileInputStream(localFilePath); client.storeFile(ftpFileName, localIn); localIn.close(); } /** * 从FTP服务器下载文件到本地。 * @param ftpFileName 所下载文件在FTP服务器上的名称 * @param localFilePath 下载后文件保存的完整路径(文件名一般和FTP上保存的文件一致) * @throws IOException IO异常 */ public void downLoadFile(String ftpFileName, String localFilePath) throws IOException { FileOutputStream localOut = new FileOutputStream(localFilePath); client.retrieveFile(ftpFileName, localOut); localOut.close(); } /** * 关闭FTP连接 * @throws IOException */ public void disconnet() throws IOException { client.logout(); } }

• 1

四、客户端测试代码

public class TestMain
{public static void main(String[] args) { FTPUtility ftp = new FTPUtility("10.70.60.60", 2121, "admin", "admin"); if(!ftp.connet()) { return; } try { ftp.upLoadFile("d:/temp/IBMS_NE_T.txt", "IBMS_NE_T.txt"); ftp.upLoadFile("d:/temp/2保修合同4.xlsx", "2保修合同4.xlsx"); ftp.downLoadFile("IBMS_NE_T.txt", "d:/temp/IBMS_NE_T_new.txt"); ftp.downLoadFile("2保修合同4.xlsx", "d:/temp/2保修合同4_new.xlsx"); ftp.disconnet(); } catch (IOException e) { e.printStackTrace(); } } }