JAVA实现的Bad Fox聊天软件 能群聊私聊 上传下载模块 超详细注释

package Help; import java.awt.Font; import java.awt.GridLayout; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.awt.event.KeyAdapter; import java.awt.event.KeyEvent; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.SocketAddress; import java.sql.Date; import java.text.SimpleDateFormat; import java.util.Timer; import java.util.TimerTask; import javax.swing.JButton; import javax.swing.JFileChooser; import javax.swing.JFrame; import javax.swing.JLabel; import javax.swing.JOptionPane; import javax.swing.JPanel; import javax.swing.JScrollPane; import javax.swing.JTextArea; import javax.swing.WindowConstants; public class ImageCanvas extends JFrame{ // 添加属性 private JPanel panel = new JPanel(); private JButton button_send = new JButton("文件发送"); private JButton button_receive = new JButton("另存为"); private JTextArea ta = new JTextArea(); private JScrollPane sp = new JScrollPane(ta); private JTextArea ta_send = new JTextArea(); private JScrollPane sp_send = new JScrollPane(ta_send); private JLabel label_fileState = new JLabel("文件状态", JLabel.CENTER); private JLabel label_feedback = new JLabel("反馈", JLabel.CENTER); // private InetAddress ip = null; private int otherport; private int myport; DatagramSocket socket;// 接收文件来显提示 DatagramSocket socket1;// 接收文件信息 DatagramSocket socket2;// 接收平时的聊天信息 // String filename = null; byte buffer[] = new byte[1024]; int fileLen = 0; int numofBlock = 0; int lastSize = 0; // String str_name; //构造函数 public ImageCanvas(String str_name, String str_ip, int otherport, int myport) { super(str_name); this.str_name = str_name; this.setDefaultCloseOperation(WindowConstants.EXIT_ON_CLOSE); this.setBounds(600, 250, 400, 400); // 添加功能代码 this.setLayout(new GridLayout(5, 1, 7, 7)); ta.setLineWrap(true);// 换行 this.add(sp); ta_send.setLineWrap(true);// 换行 this.add(sp_send); button_send.setFont(new Font("楷体", 1, 20)); button_receive.setFont(new Font("楷体", 1, 20)); panel.add(button_send); panel.add(button_receive); this.add(panel); this.add(label_fileState); this.add(label_feedback); // this.setVisible(true); // this.otherport = otherport; this.myport = myport; // button_send.addActionListener(new ActionListener() {// 发送文件 public void actionPerformed(ActionEvent e) { // 选择要发送的文件 JFileChooser filechooser = new JFileChooser(); int result = filechooser.showOpenDialog(ImageCanvas.this); if (result == JFileChooser.APPROVE_OPTION) { try { File file = filechooser.getSelectedFile(); try { // 将文件名发送过去 String str_filename = file.getName(); String str_tip = "有文件，请处理：" + str_filename; byte[] fileNameBuf = str_tip.getBytes(); DatagramSocket socket = new DatagramSocket(); DatagramPacket packet = new DatagramPacket( fileNameBuf, fileNameBuf.length, ip, ImageCanvas.this.otherport); socket.send(packet); socket.close(); // FileInputStream fis = new FileInputStream( file);// 从文件中取出写入内存 // 将文件长度发送过去 int fileLen = fis.available(); String str_len = "" + fileLen; byte[] fileLenBuf = str_len.getBytes(); socket = new DatagramSocket(); packet = new DatagramPacket(fileLenBuf, fileLenBuf.length, ip, ImageCanvas.this.otherport+1); socket.send(packet); socket.close(); // 发送文件主体 byte[] buf = new byte[1024]; int numofBlock = fileLen / buf.length;// 循环次数（将该文件分成了多少块） int lastSize = fileLen % buf.length;// 最后一点点零头的字节数 socket = new DatagramSocket(); for (int i = 0; i < numofBlock; i++) { fis.read(buf, 0, buf.length);// 写入内存 packet = new DatagramPacket(buf, buf.length, ip, ImageCanvas.this.otherport+1); socket.send(packet); Thread.sleep(1); // 简单的防止丢包现象 } // 发送最后一点点零头 fis.read(buf, 0, lastSize); packet = new DatagramPacket(buf, buf.length, ip, ImageCanvas.this.otherport+1); socket.send(packet); Thread.sleep(1); // 简单的防止丢包现象 // fis.close(); socket.close(); // label_fileState.setText("文件传输完毕！"); ta.append(""); // } catch (Exception ev) { System.out.println(ev); } } catch (Exception ex) { JOptionPane.showMessageDialog(ImageCanvas.this, "打开文档出错！"); } } } }); // ///////////// button_receive.addActionListener(new ActionListener() {// 接收文件 public void actionPerformed(ActionEvent e) { // 选择要接收的文件 JFileChooser filechooser = new JFileChooser(); int result = filechooser.showSaveDialog(ImageCanvas.this); if (result == JFileChooser.APPROVE_OPTION) { try { File file2 = filechooser.getSelectedFile(); try { File file1 = new File("D:\\TT\\" + filename); saveAs(file1, file2); // label_fileState.setText("文件接收完毕！"); ta.append("文件已处理！！\n"); } catch (Exception ex) { System.out.println(ex); } } catch (Exception ex) { JOptionPane.showMessageDialog(ImageCanvas.this, "打开保存出错！"); } } } }); // ta_send.addKeyListener(new KeyAdapter() { public void keyPressed(KeyEvent ke) { String str_chat = ImageCanvas.this.str_name + " 说： " + ta_send.getText(); byte buf[] = str_chat.getBytes(); if (ke.isControlDown() && ke.getKeyCode() == KeyEvent.VK_ENTER) { try { DatagramSocket socket = new DatagramSocket(); DatagramPacket packet = new DatagramPacket(buf, buf.length, ip, ImageCanvas.this.otherport+2); socket.send(packet); ta.append("我说： "+ta_send.getText()+"\n"); ta_send.setText(""); } catch (Exception ex) { System.out.println(ex); } } } }); // try { ip = InetAddress.getByName(str_ip); socket = new DatagramSocket(this.myport); socket1 = new DatagramSocket(this.myport + 1); socket2 = new DatagramSocket(this.myport + 2); Timer timer = new Timer();//定时器，刷新接收消息 timer.schedule(new MyTimerTask_receive(),0, 100); while (socket!=null) { try { // byte filetipBuf[] = new byte[256];// 防止文件名字过�