本文为大家介绍了FTP上传下载队列窗口的实现方法，供大家参考，具体内容如下

1、首先看一下队列窗口的界面

2、看一下上传队列窗口的界面

3、看一下下载队列窗口的界面

package com.oyp.ftp.panel.queue; import static java.awt.BorderLayout.CENTER; import static java.awt.BorderLayout.EAST; import static javax.swing.ListSelectionModel.SINGLE_SELECTION; import java.awt.BorderLayout; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.io.File; import java.io.IOException; import java.util.LinkedList; import javax.swing.BoxLayout; import javax.swing.JButton; import javax.swing.JPanel; import javax.swing.JScrollPane; import javax.swing.JTable; import javax.swing.JToggleButton; import javax.swing.JToolBar; import javax.swing.ListSelectionModel; import javax.swing.Timer; import javax.swing.table.DefaultTableModel; import com.oyp.ftp.FTPClientFrame; import com.oyp.ftp.utils.FtpClient; import com.oyp.ftp.utils.FtpFile; /** * 任务队列控制面板 */ public class QueuePanel extends JPanel implements ActionListener { private JTable queueTable = new JTable(); // 显示任务队列的表格组件 private JScrollPane scrollPane = new JScrollPane(); private FTPClientFrame frame; // 主窗体的引用对象 private String[] columns; private FtpClient ftpClient; // FTP协议的控制类 private Timer queueTimer; // 队列的定时器 private LinkedList<Object[]> localQueue; // 本地面板的上传队列 private LinkedList<Object[]> ftpQueue; // FTP面板的下载队列 private JToggleButton stopButton; private boolean stop = false; // 队列的控制变量 /** * 默认的构造方法 */ public QueuePanel() { initComponent(); } /** * 自定义的构造方法 * * @param frame * 主窗体 */ public QueuePanel(FTPClientFrame frame) { this.frame = frame; // 从主窗体获取本地面板的上传队列 localQueue = (LinkedList<Object[]>) frame.getLocalPanel().getQueue(); // 从主窗体获取FTP面板的下载队列 ftpQueue = (LinkedList<Object[]>) frame.getFtpPanel().getQueue(); initComponent(); // 初始化窗体界面 // 创建定时器，每间隔1秒执行队列刷新任务 queueTimer = new Timer(1000, new ActionListener() { /** * 定时器的事件处理方法 */ @Override public void actionPerformed(ActionEvent e) { if (localQueue.size() + ftpQueue.size() == queueTable .getRowCount()) // 如果队列大小没有改变 return; // 结束本方法，不做任何操作 refreshQueue(); // 否则刷新显示队列信息的表格数据 } }); } private void initComponent() { BorderLayout cardLayout = new BorderLayout(); setLayout(cardLayout); columns = new String[] { "任务名称", "方向", "主机", "执行状态" }; queueTable.setModel(new DefaultTableModel(new Object[][] {}, columns)); queueTable.getTableHeader().setReorderingAllowed(false); scrollPane.setViewportView(queueTable); cardLayout.layoutContainer(scrollPane); add(scrollPane, CENTER); JToolBar controlTool = new JToolBar(JToolBar.VERTICAL); controlTool.setRollover(true); controlTool.setFloatable(false); JButton upButton = new JButton("上移"); upButton.setActionCommand("up"); upButton.addActionListener(this); JButton downButton = new JButton("下移"); downButton.setActionCommand("down"); downButton.addActionListener(this); stopButton = new JToggleButton("暂停"); stopButton.setActionCommand("stop&start"); stopButton.addActionListener(this); JButton delButton = new JButton("删除"); delButton.setActionCommand("del"); delButton.addActionListener(this); JButton clearButton = new JButton("清空"); clearButton.setActionCommand("clear"); clearButton.addActionListener(this); controlTool.setLayout(new BoxLayout(controlTool, BoxLayout.Y_AXIS)); controlTool.add(upButton); controlTool.add(downButton); controlTool.add(stopButton); controlTool.add(delButton); controlTool.add(clearButton); add(controlTool, EAST); } public void startQueue() { ftpClient = frame.getFtpClient(); queueTimer.start(); } /** * 界面上按钮的事件处理方法 */ @Override public void actionPerformed(ActionEvent e) { final String command = e.getActionCommand(); if (command.equals("stop&start")) {// 处理暂停按钮事件 if (stopButton.isSelected()) { stop = true; stopButton.setText("继续"); } else { stop = false; stopButton.setText("暂停"); } } // 处理上移和下移按钮事件 if (command.equals("up") || command.equals("down")) { up_Down_Action(command); // 调用处理上移和下移动作的方法 } if (command.equals("del")) {// 处理删除按钮的事件 int row = queueTable.getSelectedRow(); // 获取显示队列的表格的当前选择行 if (row < 0) return; // 获取选择行的第一个表格单元值 Object valueAt = queueTable.getValueAt(row, 0); // 如果选择内容是File类的对象 if (valueAt instanceof File) { File file = (File) valueAt; int size = localQueue.size(); // 获取上传队列大小 for (int i = 0; i < size; i++) { // 遍历上传队列 if (localQueue.get(i)[0].equals(file)) { localQueue.remove(i); // 从上传队列中删除文件对象 } } } else if (valueAt instanceof String) { // 如果选择的是字符串对象 String fileStr = (String) valueAt; int size = ftpQueue.size(); // 获取上传队列的大小 for (int i = 0; i < size; i++) { // 遍历上传队列 // 获取上传队列中的文件对象 FtpFile ftpFile = (FtpFile) ftpQueue.get(i)[0]; if (ftpFile.getAbsolutePath().equals(fileStr)) { ftpQueue.remove(i); // 从上传队列中删除该文件对象 } } } refreshQueue(); // 刷新队列列表 } if (command.equals("clear")) { // 处理清空按钮的事件 localQueue.clear(); // 调用本地面板的队列的clear()方法 ftpQueue.clear(); // 调用FTP面板的队列的clear()方法 } } /** * 队列任务的上移和下移动作处理方法 * * @param command * 上移或下移命令 */ private void up_Down_Action(final String command) { int row = queueTable.getSelectedRow(); // 获取队列表格的当前选择行号 if (row < 0) return; // 获取当前选择行的第一个单元值 Object valueAt = queueTable.getValueAt(row, 0); // 获取当前选择行的第二个单元值作为判断上传或下载方向的依据 String orientation = (String) queueTable.getValueAt(row, 1); if (orientation.equals("上传")) { // 如果是上传任务 String value = ((File) valueAt).getAbsolutePath(); int size = localQueue.size(); for (int i = 0; i < size; i++) { // 遍历上传队列 Object[] que = localQueue.get(i); File file = (File) que[0]; // 从队列中，遍历到选择的上传任务的文件对象 if (file.getAbsolutePath().equals(value)) { ListSelectionModel selModel = queueTable .getSelectionModel(); // 获取表格的选择模型 selModel // 设置选择模型的单选模式 .setSelectionMode(ListSelectionModel.SINGLE_SELECTION); int dsize = localQueue.size(); // 获取本地上传队列的大小 int drow = queueTable.getSelectedRow();// 获取队列表格的当前选择行号 int queueVal = localQueue.size() - dsize; int next = -1; int selIndex = -1; if (command.equals("up")) { if (i < 1) // 限制选择范围 return; selIndex = drow - queueVal - 1; next = i - 1; } else { if (i >= size - 1) // 限制选择范围 return; selIndex = drow - queueVal + 1; next = i + 1; } // 交换连个队列位置的任务 Object[] temp = localQueue.get(next); localQueue.set(next, que); localQueue.set(i, temp); refreshQueue(); // 刷新队列表格的列表 // 设置表格选择第一行 selModel.setSelectionInterval(0, selIndex); break; } } } else if (orientation.equals("下载")) { // 如果是下载任务 String value = (String) valueAt; int size = ftpQueue.size(); // 获取FTP下载队列的大小 for (int i = 0; i < size; i++) { // 遍历下载队列 Object[] que = ftpQueue.get(i); FtpFile file = (FtpFile) que[0]; // 获取每个下载任务的FTP文件对象 if (file.getAbsolutePath().equals(value)) {// ListSelectionModel selModel = queueTable .getSelectionModel(); // 获取任务队列表格的选择模型 // 设置模型使用单选模式 selModel.setSelectionMode(SINGLE_SELECTION); int dsize = ftpQueue.size(); int drow = queueTable.getSelectedRow(); int queueVal = ftpQueue.size() - dsize; int next = -1; int selIndex = -1; if (command.equals("up")) { if (i < 1) // 限制选择范围 return; selIndex = drow - queueVal - 1; next = i - 1; } else { if (i >= size - 1) // 限制选择范围 return; selIndex = drow - queueVal + 1; next = i + 1; } // 交换连个队列位置的任务内容 Object[] temp = ftpQueue.get(next); ftpQueue.set(next, que); ftpQueue.set(i, temp); refreshQueue(); // 刷新任务队列的表格列表 // 选择表格的第一行 selModel.setSelectionInterval(0, selIndex); break; } } } } /** * 刷新队列的方法 */ private synchronized void refreshQueue() { // 如果自动关机按钮被按下并且上传和下载的队列都有任务 if (frame.getShutdownButton().isSelected() && localQueue.isEmpty() && ftpQueue.isEmpty()) { try { // 执行系统关机命令，延迟30秒钟 Runtime.getRuntime().exec("shutdown -s -t 30"); } catch (IOException e) { e.printStackTrace(); } } // 创建表格的数据模型对象 DefaultTableModel model = new DefaultTableModel(columns, 0); // 获取本地上传队列中的任务 Object[] localQueueArray = localQueue.toArray(); // 遍历本地上传任务 for (int i = 0; i < localQueueArray.length; i++) { Object[] queueValue = (Object[]) localQueueArray[i]; if (queueValue == null) continue; File localFile = (File) queueValue[0]; // 把上传队列的任务添加到表格组件的数据模型中 model.addRow(new Object[] { localFile.getAbsoluteFile(), "上传", ftpClient.getServer(), i == 0 ? "正在上传" : "等待上传" }); } // 获取下载队列的任务 Object[] ftpQueueArray = ftpQueue.toArray(); // 遍历下载队列 for (int i = 0; i < ftpQueueArray.length; i++) { Object[] queueValue = (Object[]) ftpQueueArray[i]; if (queueValue == null) continue; FtpFile ftpFile = (FtpFile) queueValue[0]; // 把下载队列的任务添加到表格组件的数据模型中 model.addRow(new Object[] { ftpFile.getAbsolutePath(), "下载", ftpClient.getServer(), i == 0 ? "正在下载" : "等待下载" }); } queueTable.setModel(model); // 设置表格使用本方法的表格数据模型 } public boolean isStop() { return stop; } }

5.上传队列窗口的实现

package com.oyp.ftp.panel.queue; import java.awt.CardLayout; import javax.swing.JPanel; import javax.swing.JScrollPane; import javax.swing.JTable; import javax.swing.SwingUtilities; import javax.swing.table.DefaultTableModel; import javax.swing.table.TableColumn; import com.oyp.ftp.panel.QueueTableCellRanderer; import com.oyp.ftp.utils.ProgressArg; public class UploadPanel extends JPanel { private JTable uploadTable = new JTable(); // 表格组件 private JScrollPane scrollPane = new JScrollPane(); private DefaultTableModel model; // 表格的数据模型 /** * 构造方法，用于初始化程序界面 */ public UploadPanel() { CardLayout cardLayout = new CardLayout(); setLayout(cardLayout); ProgressArg progressArg = new ProgressArg(-1, -1, -1); model = new DefaultTableModel(new Object[][] { new Object[] { "", "", "", "", progressArg } }, new String[] { "文件名", "大小", "远程文件名", "主机", "状态" }); uploadTable.setModel(model); uploadTable.getTableHeader().setReorderingAllowed(false); uploadTable.setRowSelectionAllowed(false); TableColumn column = uploadTable.getColumn("状态"); column.setCellRenderer(new QueueTableCellRanderer()); scrollPane.setViewportView(uploadTable); cardLayout.layoutContainer(scrollPane); add(scrollPane, "queue"); } /** * 向上传队列的表格组件添加新任务的方法 * * @param values * - 添加到表格的一行数据的数组对象 */ public void addRow(final Object[] values) { Runnable runnable = new Runnable() { public void run() { model.insertRow(0, values); // 向表格的数据模型添加数据 } }; if (SwingUtilities.isEventDispatchThread()) runnable.run(); // 在事件队列执行 else SwingUtilities.invokeLater(runnable); // 或有事件队列调用 } }

6.下载队列窗口的实现

package com.oyp.ftp.panel.queue; import java.awt.CardLayout; import javax.swing.JPanel; import javax.swing.JScrollPane; import javax.swing.JTable; import javax.swing.SwingUtilities; import javax.swing.table.DefaultTableModel; import javax.swing.table.TableColumn; import com.oyp.ftp.panel.QueueTableCellRanderer; import com.oyp.ftp.utils.ProgressArg; public class DownloadPanel extends JPanel { private JTable downloadTable = new JTable(); private JScrollPane scrollPane = new JScrollPane(); private DefaultTableModel model; public DownloadPanel() { CardLayout cardLayout = new CardLayout(); setLayout(cardLayout); ProgressArg progressArg = new ProgressArg(-1, -1, -1); model = new DefaultTableModel(new Object[][] { new Object[] { "", "", "", "", progressArg } }, new String[] { "文件名", "大小", "本地文件名", "主机", "状态" }); downloadTable.setModel(model); downloadTable.getTableHeader().setReorderingAllowed(false); downloadTable.setRowSelectionAllowed(false); TableColumn column = downloadTable.getColumn("状态"); column.setCellRenderer(new QueueTableCellRanderer()); scrollPane.setViewportView(downloadTable); cardLayout.layoutContainer(scrollPane); add(scrollPane, "queue"); } public void addRow(final Object[] values) { Runnable runnable = new Runnable() { public void run() { model.insertRow(0, values); } }; if (SwingUtilities.isEventDispatchThread()) runnable.run(); else SwingUtilities.invokeLater(runnable); } }

下面窗口具体的上传下载后的变化

1.上传任务的添加

2.上传任务的完成

3.下载任务的添加

4.下载任务的完成

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。