网络编程>>FTP客户端

Posted on 2009-12-18 22:19 啥都写点阅读(715) 评论(0) 编辑收藏所属分类: J2SE

一种登录FTP服务器的方法是使用Socket，用Socket连接FTP服务器，通过FTP命令与FTP服务器交互，用这种方法实现FTP客户端比较麻烦。

Java提供了sun.net.ftp.FtpClient类，这是一个标准的FTP客户端类，通过它能方便地在FTP上浏览、上传和下载。

FtpClient的openServer方法连接到FTP服务器，login方法登录服务器，closeServer方法断开与服务器的连接，cd方法切换FTP的目录，list方法获取当前目录下的文件和子目录信息，binary方法表示以二进制的形式与FTP交互，get方法获得FTP服务器上文件的输入流，put方法获得往FTP服务器上写文件的输出流。

/**-----------------------------Connector.java-------------------------------------------*/

import sun.net.ftp.FtpClient;

/**

* 连接FTP服务器

public class Connector extends Thread {

MainFrame frame = null;

// 需要IP地址、用户名、密码

String ip = "";

String username = "";

String password = "";

public Connector(MainFrame frame, String ip, String username,

String password) {

// 初始化信息

this.frame = frame;

this.ip = ip;

this.username = username;

this.password = password;

}

public void run() {

try {

frame.consoleTextArea.append("connecting the server " + ip

+ ",wait for a moment..\n");

frame.ftpClient = new FtpClient();

// 连接服务器

frame.ftpClient.openServer(ip);

frame.consoleTextArea.append("connect server " + ip

+ " succeed,please continue!\n");

// 用用户名和密码登陆

frame.ftpClient.login(username, password);

frame.currentDirTextField.setText("/");

frame.setTableData();

frame.serverIPTextField.setText(ip);

frame.userNameTextField.setText(username);

frame.passwordTextField.setText(password);

} catch (Exception e) {

frame.consoleTextArea.append("can not connect the server " + ip + "!\n");

}

/**-----------------------------------DownloadFileThread.java----------------------------------------------*/

import java.io.File;

import java.io.FileOutputStream;

import java.io.InputStream;

import sun.net.ftp.FtpClient;

/**

* 下载文件的线程

public class DownloadFileThread extends Thread {

private boolean running = false;

// FTP服务器的IP

String ip = "";

// 连接服务器的用户名和密码

String username = "";

String password = "";

// 待下载文件在FTP上的目录和文件名

String ftpDir = "";

String ftpFileName = "";

// 下载到本地后的文件名

String localFileName = "";

MainFrame frame = null;

// 构造方法

public DownloadFileThread(MainFrame frame, String server, String username,

String password, String path, String filename, String userpath) {

this.ip = server;

this.username = username;

this.password = password;

this.ftpDir = path;

this.ftpFileName = filename;

this.localFileName = userpath;

this.frame = frame;

}

public void run() {

running = true;

FileOutputStream os = null;

InputStream is = null;

FtpClient ftpClient = null;

try {

String savefilename = localFileName;

// 新建FTP客户端

ftpClient = new FtpClient();

ftpClient.openServer(ip);

// 登陆

ftpClient.login(username, password);

if (ftpDir.length() != 0){

// 切换到指定的目录下

ftpClient.cd(ftpDir);

}

// 以二进制格式打开FTP

ftpClient.binary();

// 打开文件

is = ftpClient.get(ftpFileName);

// 保存到本地

File file_out = new File(savefilename);

os = new FileOutputStream(file_out);

byte[] bytes = new byte[1024];

// 开始复制

int c;

frame.taskList.add(ftpFileName);

frame.consoleTextArea.append("downloading the file " + ftpFileName

+ " , wait for a moment!\n");

while (running && ((c = is.read(bytes)) != -1)) {

os.write(bytes, 0, c);

}

if (running){

// 下载成功后，清除任务和线程

frame.taskList.remove(ftpFileName);

frame.consoleTextArea.append(" the file " + ftpFileName

+ " download has finished!\n");

frame.performTaskThreads.removeElement(this);

}

} catch (Exception e) {

// 下载失败

frame.consoleTextArea.append(" the file " + ftpFileName

+ " ,download has problem!\n");

frame.performTaskThreads.removeElement(this);

} finally {

try {

if (is != null){

is.close();

}

if (os != null){

os.close();

}

if (ftpClient != null){

ftpClient.closeServer();

}

} catch (Exception e){

e.printStackTrace();

}

public void toStop(){

this.running = false;

}

/**--------------------------------------MainFrame.java------------------------------------------------*/

import java.awt.BorderLayout;

import java.awt.Color;

import java.awt.FileDialog;

import java.awt.FlowLayout;

import java.awt.List;

import java.awt.Point;

import java.awt.SystemColor;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.awt.event.MouseEvent;

import java.awt.event.WindowEvent;

import java.io.InputStream;

import java.util.StringTokenizer;

import java.util.Vector;

import javax.swing.BorderFactory;

import javax.swing.JButton;

import javax.swing.JFrame;

import javax.swing.JLabel;

import javax.swing.JOptionPane;

import javax.swing.JPanel;

import javax.swing.JScrollPane;

import javax.swing.JTable;

import javax.swing.JTextArea;

import javax.swing.JTextField;

import javax.swing.SwingUtilities;

import javax.swing.UIManager;

import javax.swing.border.TitledBorder;

import javax.swing.table.DefaultTableModel;

import book.string.ChangeCharset;

import sun.net.ftp.FtpClient;

public class MainFrame extends JFrame {

//连接服务器的按钮

JButton connectButton = new JButton("连接");

// FTP服务器IP地址输入框

JLabel IPLabel = new JLabel("IP：");

JTextField serverIPTextField = new JTextField(16);

// /用户名标签和输入框

JLabel userNameLabel = new JLabel("用户名：");

JTextField userNameTextField = new JTextField(16);

// 密码标签和输入框

JLabel passwordLabel = new JLabel("密码：");

JTextField passwordTextField = new JTextField(16);

// 当前目录标签和输入框

JLabel currentDirLabel = new JLabel("当前目录：");

JTextField currentDirTextField = new JTextField(30);

// 转入上一级目录的按钮

JButton upLevelButton = new JButton("上一级目录");

// 上载和下载文件的按钮

JButton downloadButton = new JButton("下载");

JButton uploadButton = new JButton("上传");

// 断开和退出的按钮

JButton disconnectButton = new JButton("断开");

JButton exitButton = new JButton("关闭");

// 表格的数据，用于显示FTP服务器上的信息

String[] columnname = { "文件名", "文件大小", "修改日期" };

DefaultTableModel tableModel = new DefaultTableModel();

JTable ftpFileInfosTable = new JTable();

JScrollPane ftpFileScrollPane1 = new JScrollPane(ftpFileInfosTable);

// 下载和上传的文件对话框

FileDialog saveFileDialog = new FileDialog(this, "Download To ..",

FileDialog.SAVE);

FileDialog openFileDialog = new FileDialog(this, "Upload File ..",

FileDialog.LOAD);

FtpClient ftpClient = null;

// IP地址、用户名、密码、FTP路径

String ip = "";

String username = "";

String password = "";

String path = "";

Vector files = new Vector();

Vector fileSizes = new Vector();

Vector fileTypes = new Vector();

Vector fileDates = new Vector();

// 当前选择的表格中的行号和列号

int row = 0;

int column = 0;

// 当前正在执行上下载任务的线程

Vector performTaskThreads = new Vector();

// 显示当前的任务列表

java.awt.List taskList = new List();

// 显示FTP客户端程序的控制台信息

JTextArea consoleTextArea = new JTextArea();

// 因为从FTP中取得编码是ISO-8859-1，为了支持中文，所以将其转换。

// 这个类是在将字符串的章节中定义的，这里直接使用了。

ChangeCharset changeCharset = new ChangeCharset();

public MainFrame() {

init();

setLocation(100, 150);

setTitle("FTP 客户端");

pack();

try {

// 设置界面为系统默认外观

UIManager.setLookAndFeel(UIManager.getSystemLookAndFeelClassName());

SwingUtilities.updateComponentTreeUI(this);

} catch (Exception e) {

e.printStackTrace();

}

private void init(){

// 初始化各个文本框

serverIPTextField.setText("127.0.0.1");

userNameTextField.setText("");

passwordTextField.setText("");

currentDirTextField.setText("");

currentDirTextField.setEditable(false);

// 将IP、用户名、密码、连接标签和输入框放在面板panel1中

JPanel panel1 = new JPanel();

panel1.setLayout(new FlowLayout());

panel1.add(IPLabel);

panel1.add(serverIPTextField);

panel1.add(userNameLabel);

panel1.add(userNameTextField);

panel1.add(passwordLabel);

panel1.add(passwordTextField);

panel1.add(connectButton);

// 将当前目录、上一级目录的标签、输入框和按钮放在面板panel2中

JPanel panel2 = new JPanel();

panel2.setLayout(new FlowLayout());

panel2.add(currentDirLabel);

panel2.add(currentDirTextField);

panel2.add(upLevelButton);

JPanel panelA = new JPanel();

panelA.setLayout(new BorderLayout());

panelA.add(panel1, BorderLayout.NORTH);

panelA.add(panel2, BorderLayout.CENTER);

ftpFileScrollPane1.setBorder(new TitledBorder(BorderFactory

.createEtchedBorder(Color.white, new Color(134, 134, 134)),

"FTP服务器上文件信息"));

// 将下载、上传、断开、退出按钮放在panel3中

JPanel panel3 = new JPanel();

panel3.setLayout(new FlowLayout());

panel3.add(downloadButton);

panel3.add(uploadButton);

panel3.add(disconnectButton);

panel3.add(exitButton);

// 将任务列表放在有滚动条的面板中

JScrollPane taskScrollPane = new JScrollPane(taskList);

taskScrollPane.setBorder(new TitledBorder(BorderFactory

.createEtchedBorder(Color.white, new Color(134, 134, 134)), "上下载队列"));

// 将控制台信息的文本域放在滚动条面板中，并且设置为不可编辑

consoleTextArea.setBackground(SystemColor.control);

consoleTextArea.setEditable(false);

consoleTextArea.setText("");

consoleTextArea.setRows(5);

JScrollPane consoleScrollPane = new JScrollPane(consoleTextArea);

consoleScrollPane.setBorder(new TitledBorder(BorderFactory

.createEtchedBorder(Color.white, new Color(134, 134, 134)), "上下载信息"));

JPanel panelB = new JPanel();

panelB.setLayout(new BorderLayout());

panelB.add(panel3, BorderLayout.NORTH);

panelB.add(taskScrollPane, BorderLayout.CENTER);

panelB.add(consoleScrollPane, BorderLayout.SOUTH);

// 将各个面板添加到主面板中

this.getContentPane().setLayout(new BorderLayout());

this.getContentPane().add(panelA, BorderLayout.NORTH);

this.getContentPane().add(ftpFileScrollPane1, BorderLayout.CENTER);

this.getContentPane().add(panelB, BorderLayout.SOUTH);

// 为按钮添加事件处理器

connectButton.addActionListener(new ActionListener(){