fss.java

局域网传输共享文件

import java.awt.Checkbox;
import java.awt.Color;
import java.awt.Container;
import java.awt.Dialog;
import java.awt.Dimension;
import java.awt.FlowLayout;
import java.awt.GridLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.ItemEvent;
import java.awt.event.ItemListener;
import java.awt.event.MouseEvent;
import java.awt.event.MouseListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketException;
import java.net.UnknownHostException;
import java.util.Date;
import java.util.Hashtable;
import java.util.StringTokenizer;
import java.util.Vector;

import javax.swing.DefaultListModel;
import javax.swing.ImageIcon;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JList;
import javax.swing.JMenu;
import javax.swing.JMenuBar;
import javax.swing.JMenuItem;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import javax.swing.JPasswordField;
import javax.swing.JProgressBar;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
import javax.swing.ListModel;
import javax.swing.ToolTipManager;
import javax.swing.UIManager;
import javax.swing.border.EtchedBorder;

public class FSS extends JFrame implements ActionListener, ItemListener,
		MouseListener {
	/**
	 * 
	 */
	private static final long serialVersionUID = -8585992656874902395L;

	public final static ImageIcon ICON_FOLDER = new ImageIcon("folder.gif");

	public final static ImageIcon ICON_EXPANDEDFOLDER = new ImageIcon(
			"expandedfolder.gif");

	static boolean root = true, next = true;

	private JMenu menu1 = new JMenu("编辑"), menu2 = new JMenu("文件"),
			menu3 = new JMenu("附加功能");

	JMenuItem item4;

	Checkbox ch1 = null;

	static String filepath = "D:\\";

	JFrame rn = new JFrame("选择名字");

	static int indexoffile;

	String yidong = "";

	static String rr[], host, host2;;// 存储当前目录下的文件（一次性）

	private JTextField usert, ip, ip2, tip;// usert：用户名JTextField，idt密码JTextField

	JTextField rnf;

	Dialog it = null;

	private JPasswordField idt;

	private JTextArea path;

	private JList list;// 显示目录

	private ListModel lmodel;// list中的用法

	private String starts = "NO";//

	private static Vector<String> v = new Vector<String>(),
			user = new Vector<String>(), notdeletef = new Vector<String>(),
			downloadedfiles = new Vector<String>(),
			editedfiles = new Vector<String>(), zaixian = new Vector<String>();// （服务器端）存储选择的共享文件/目录

	private JScrollPane pcenter;

	private JProgressBar baaa;

	private Dialog d;// 显示填用户名、密码输入的对话框

	JButton b2, shua, tuichu;

	JMenuItem item5;

	private int pass = 0;// idt的内容

	private Hashtable<String, String> users = new Hashtable<String, String>(),
			write = new Hashtable<String, String>(),
			read = new Hashtable<String, String>(),
			exe = new Hashtable<String, String>();// 存储用户信息（用户名、密码）

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		try {
			UIManager
					.setLookAndFeel("com.sun.java.swing.plaf.windows.WindowsLookAndFeel");
		} catch (Exception evt) {
		}
		new FSS();
	}

	private void f() {
		if (pass == 1) {
			ip.setText(ip2.getText());
			shua.setEnabled(true);
			tuichu.setEnabled(true);
			starts = "YES";
			item4.setEnabled(true);
			b2.setEnabled(true);
			if (starts.equals("YES")) {
				try {
					// 发送请求
					InetAddress add = InetAddress.getByName(ip.getText());
					DatagramSocket start = new DatagramSocket();// add, 7009
					byte[] startb = starts.getBytes();
					DatagramPacket startp = new DatagramPacket(startb,
							startb.length, add, 7009);
					start.send(startp);
					start.close();
					// 接受登录的时显示在list中的目录（即允许操作的共享目录）
					DatagramSocket jishouMoren = new DatagramSocket(7001);
					byte[] jishouMorenb = new byte[40960];
					DatagramPacket jishouMorenp = new DatagramPacket(
							jishouMorenb, jishouMorenb.length);
					jishouMoren.receive(jishouMorenp);
					jishouMoren.close();
					String jishouMorenst = new String(jishouMorenp.getData(),
							0, jishouMorenp.getLength());
					StringTokenizer stn = new StringTokenizer(jishouMorenst,
							"?");
					String first = host;
					path.setText(first);
					rr = new String[stn.countTokens()];
					String[] ss = new String[rr.length];
					for (int i = 0; i < rr.length; i++) {
						rr[i] = stn.nextToken().trim();
						ss[i] = rr[i].substring(0, rr[i].indexOf("{"));
					}
					list = new JList(ss);
					list.addMouseListener(this);
					lmodel = list.getModel();
					pcenter.add(list);
					pcenter.getViewport().setView(list);
					ToolTipManager.sharedInstance().registerComponent(list);
					this.validate();
				} catch (Exception x) {
					System.err.println("Erroe in start.");
				}

			}
		} else {
			JOptionPane.showMessageDialog(this, "登录失败", "Error",
					JOptionPane.ERROR_MESSAGE);
		}
	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see java.awt.event.ActionListener#actionPerformed(java.awt.event.ActionEvent)
	 */
	@SuppressWarnings("deprecation")
	public void actionPerformed(ActionEvent e) {
		String s = e.getActionCommand();

		if (s.equals("确认")) {
			d.dispose();
			String s1 = usert.getText();
			String i1 = idt.getText().trim();
			// 发送登录信息（用户名、密码）
			LogIn login = new LogIn(s1, i1);
			login.start();// 启动发送登录验证信息的String，并接受是否正确
			while (login.isAlive()) {
			}// 等待login的结束后
			if (pass == 1) {
				ip.setText(ip2.getText());
				shua.setEnabled(true);
				tuichu.setEnabled(true);
				starts = "YES";
				item4.setEnabled(true);
				b2.setEnabled(true);
				if (starts.equals("YES")) {
					try {
						// 发送请求
						InetAddress add = InetAddress.getByName(ip.getText());
						DatagramSocket start = new DatagramSocket();// add, 7009
						byte[] startb = starts.getBytes();
						DatagramPacket startp = new DatagramPacket(startb,
								startb.length, add, 7009);
						start.send(startp);
						start.close();
						// 接受登录的时显示在list中的目录（即允许操作的共享目录）
						DatagramSocket jishouMoren = new DatagramSocket(7001);
						byte[] jishouMorenb = new byte[40960];
						DatagramPacket jishouMorenp = new DatagramPacket(
								jishouMorenb, jishouMorenb.length);
						jishouMoren.receive(jishouMorenp);
						jishouMoren.close();
						String jishouMorenst = new String(jishouMorenp
								.getData(), 0, jishouMorenp.getLength());
						StringTokenizer stn = new StringTokenizer(
								jishouMorenst, "?");
						String first = host;
						path.setText(first);
						rr = new String[stn.countTokens()];
						String[] ss = new String[rr.length];
						for (int i = 0; i < rr.length; i++) {
							rr[i] = stn.nextToken().trim();
							ss[i] = rr[i].substring(0, rr[i].indexOf("{"));
						}
						list = new JList(ss);
						list.addMouseListener(this);
						lmodel = list.getModel();
						pcenter.add(list);
						pcenter.getViewport().setView(list);
						ToolTipManager.sharedInstance().registerComponent(list);
						this.validate();
					} catch (Exception x) {
						System.err.println("Erroe in start.");
					}

				}
			} else {
				JOptionPane.showMessageDialog(this, "登录失败", "Error",
						JOptionPane.ERROR_MESSAGE);
			}
		} else if (s.equals("退出")) {// 未实现
			d.dispose();
		} else if (s.equals("退出登录")) {// 未实现
			try {
				InetAddress adds = null;
				adds = InetAddress.getByName(ip.getText());
				pass = 0;
				ip.setText("      (空)");
				menu1.setEnabled(false);
				shua.setEnabled(false);
				tuichu.setEnabled(false);
				item4.setEnabled(false);
				b2.setEnabled(false);
				list = new JList(new String[0]);
				// lmodel = list.getModel();
				pcenter.add(list);
				pcenter.getViewport().setView(list);
				ToolTipManager.sharedInstance().registerComponent(list);
				this.validate();
				DatagramSocket tuichus = new DatagramSocket();
				byte[] tb = "1".getBytes();
				DatagramPacket tuichusp = new DatagramPacket(tb, tb.length,
						adds, 7567);
				tuichus.send(tuichusp);
				tuichus.close();
			} catch (Exception e1) {
				// TODO 自动生成 catch 块
				e1.printStackTrace();
			}
		} else if (s.equals("刷新")) {// 未实现
		} else if (s.equals("确认2")) {
			rn.show(false);
			String filen = rr[indexoffile].substring(0, rr[indexoffile]
					.indexOf("{"));
			String deletefn = path.getText() + "\\" + filen;
			String newname = "";
			if (rnf.getText().trim().length() == 0 || rnf.getText() == null) {
				rnf.setText(filen.trim());
			} else {

			}
			newname = rnf.getText();
			deletefn = deletefn + "{" + newname + "}";
			new DeleteFile(indexoffile, deletefn, "REN", this).start();
		} else if (s.equals("删除")) {
			if (list.getToolTipText().indexOf("写") == -1) {
				JOptionPane.showMessageDialog(this, "无删权限！", "Error",
						JOptionPane.ERROR_MESSAGE);
				return;
			}
			String deletefn = path.getText()
					+ "\\"
					+ rr[indexoffile]
							.substring(0, rr[indexoffile].indexOf("{"));
			new DeleteFile(indexoffile, deletefn, "DEL", this).start();
		} else if (s.equals("拷贝")) {// 未实现
			boolean nb = false;
			if (list.getToolTipText().indexOf("读") == -1) {
				JOptionPane.showMessageDialog(this, "无读权限！", "Error",
						JOptionPane.ERROR_MESSAGE);
				return;
			}
			if (list.getToolTipText().indexOf("目录") != -1) {
				nb = true;
			}

			String copyfn = path.getText().substring(
					path.getText().indexOf("\\") + 1)
					+ "\\"
					+ rr[indexoffile]
							.substring(0, rr[indexoffile].indexOf("{"));
			new Download(copyfn, nb, this).start();
		} else if (s.equals("重命名")) {// 未实现
			if (list.getToolTipText().indexOf("写") != -1) {
				JOptionPane.showMessageDialog(this, "无写权限！", "Error",
						JOptionPane.ERROR_MESSAGE);
			}
			String filen = rr[indexoffile].substring(0, rr[indexoffile]
					.indexOf("{"));
			rnf = new JTextField(30);

			rn.setSize(320, 100);
			rn.validate();
			rnf.setText(filen.trim());
			rn.add(new JLabel("按完确认后按关闭"), "North");
			JPanel rn1 = new JPanel();
			rn1.setLayout(new FlowLayout(FlowLayout.CENTER));
			rn1.add(rnf);
			JButton bbbb = new JButton("确认");
			bbbb.setActionCommand("确认2");
			bbbb.addActionListener(this);
			rn1.add(bbbb);
			rn.add(rn1);
			rn.show(true);
		} else if (s.equals("移动")) {// 未实现
			yidong = path.getText()
					+ "\\"
					+ rr[indexoffile]
							.substring(0, rr[indexoffile].indexOf("{")).trim();
			item5.setEnabled(true);
			if (next) {
				it = new Dialog(this, "说明", true);
				it.setSize(200, 100);
				it.add(new JLabel("选择所选文件夹后按:编辑>>>确定"));
				JPanel p1 = new JPanel();
				p1.setLayout(new FlowLayout());
				ch1 = new Checkbox("以后不再显示本提示");
				p1.add(ch1);
				it.add(p1, "South");
				it.addWindowListener(new WindowAdapter() {
					public void windowClosing(WindowEvent e) {
						if (ch1.getState()) {
							next = false;
						}
						it.dispose();
					}
				});
				it.setVisible(true);
			}
		} else if (s.equals("确定")) {
			if (list.getToolTipText().indexOf("目录") == -1) {
				JOptionPane.showMessageDialog(this, "请选择目录！", "Error",
						JOptionPane.ERROR_MESSAGE);
				return;
			}
			if (list.getToolTipText().indexOf("可执行") == -1) {
				JOptionPane.showMessageDialog(this, "请选择可执行目录！", "Error",
						JOptionPane.ERROR_MESSAGE);
				return;
			}
			yidong = yidong
					+ "{"
					+ path.getText()
					+ "\\"
					+ rr[indexoffile]
							.substring(0, rr[indexoffile].indexOf("{")).trim()
					+ "}";
			item5.setEnabled(false);
			new DeleteFile(indexoffile, yidong, "MOV", this).start();

		} else if (s.equals("下载的文件")) {// 未实现
			final JFrame downf = new JFrame("下载的文件列表");
			downf.setSize(400, 400);
			downf.setVisible(true);
			downf.addWindowListener(new WindowAdapter() {
				public void windowClosing(WindowEvent e) {
					downf.dispose();
				}
			});

			JList dlist = new JList(downloadedfiles);
			JScrollPane dp = new JScrollPane(dlist);
			dp
					.setHorizontalScrollBarPolicy(JScrollPane.HORIZONTAL_SCROLLBAR_AS_NEEDED);
			dp
					.setVerticalScrollBarPolicy(JScrollPane.VERTICAL_SCROLLBAR_AS_NEEDED);
			downf.add(dp);
		} else if (s.equals("QQ,文件传输")) {// 未完全正确实现
			try {
				new SQK(ip.getText()).setVisible(true);
			} catch (Exception x) {
			}
		} else if (s.equals("时钟")) {
			new Clock().start();
		} else if (s.equals("上级目录")) {
			menu1.setEnabled(false);
			try {
				String parentdirname = "PAR" + path.getText().trim();
				InetAddress add = InetAddress.getByName(ip.getText());
				if (path.getText().equals(host)) {// 顶层无父目录，报错
					JOptionPane.showMessageDialog(this, "无上级目录！", "Error",
							JOptionPane.ERROR_MESSAGE);
					menu1.setEnabled(true);
					return;
				}
				// 发送要选择返回父目录的路径名
				byte[] b = parentdirname.getBytes();
				DatagramSocket parentdir = new DatagramSocket();// add, 9871
				DatagramPacket parentdirp = new DatagramPacket(b, b.length,
						add, 9871);
				parentdir.send(parentdirp);
				parentdir.close();