笨笨熊聊天室--一个组播通信的实例源代码

package server; import java.awt.*; import java.awt.event.*; import java.io.*; import java.net.*; import java.text.*; import java.util.*; import javax.swing.*; import java.io.*; import java.util.*; import java.text.SimpleDateFormat; /** * <p>Title:组播聊天程序</p> * * <p>Description: 聊天人员首先设定好自己的用户名和组播组的地址，端口号等等，成功连接后 * 可以通过设定的名字进行聊天，并且正常的进入和离开组播 * 尽量接近IP组播模型。 * 1 组播数据报：JOIN PDU 用户首次连接时的组播数据报 * LEAVE PDU 用户离开时的数据报 * MESSAGE PDU 用户每次发送消息时的数据报 * 2 魔数 每个数据报发送时以一个魔数开头，避免相互冲突。 * 用以解决每个组播与同一组播和端口的使用不同协议的另一应用程序共存 * 魔数可以使任何任何二进制值，本例选择随即64位值。 * 3 IP组播是不可靠传输，因而尽最大努力交付。但是可大大减少服务器和主干网络的带宽需求 * IP组播模型中，任何主机都可以想组播地址发送数据报。 * 4 主机用224.0.0.0~239.255.255.255的D类地址标识。 * </p> * * <p>Copyright: Copyright (c) 2009</p> * * <p>Company: 鲁东大学计算机学院 06网本1班 孙超</p> * * @author not attributable * @version 1.0 */ public class MulticastChatFrame extends JFrame implements ActionListener, WindowListener, MulticastChatEventListener { protected MulticastChat chat; //创建组播聊天 protected JTextArea textArea; //留言板 protected JScrollPane textAreaScrollPane; //留言板的容器面板，存放留言板组件 protected JTextField messageField; //发送消息框 protected JButton sendButton; //发送按钮 protected JLabel jLabel1; JLabel jLabel2 = new JLabel(); SimpleDateFormat matter = new SimpleDateFormat("HH:MM:ss"); //时间的格式化格式 Date date = null; SimpleDateFormat matter1 = null; SimpleDateFormat matter2 = null; File chatRecord; String context = null; File f = null; FileWriter out = null; String temp = null; //构造函数以及初始化 public MulticastChatFrame() { super("MulticastChat (未连接)"); textArea = new JTextArea(); textArea.setEditable(false); textArea.setBorder(BorderFactory.createLoweredBevelBorder()); textAreaScrollPane = new JScrollPane(textArea); getContentPane().add(textAreaScrollPane, BorderLayout.CENTER); JPanel messagePanel = new JPanel(); messagePanel.setLayout(new BorderLayout()); messagePanel.add(new JLabel("消息"), BorderLayout.WEST); messageField = new JTextField(); messageField.addActionListener(this); messagePanel.add(messageField, BorderLayout.CENTER); sendButton = new JButton("发送"); sendButton.addActionListener(this); messagePanel.add(sendButton, BorderLayout.EAST); getContentPane().add(messagePanel, BorderLayout.SOUTH); addWindowListener(this); //将日志以及聊天记录写入文件C：\\笨笨熊聊天室记录 matter1 = new SimpleDateFormat( "'北京时间':yyyy年 MM 月 dd 日 HH 时 mm 分 ss 秒 EE "); matter2 = new SimpleDateFormat( "yyyy年MM月dd日HH时mm分ss秒"); chatRecord = new File("C:\\笨笨熊聊天室记录"); chatRecord.mkdir(); date = new Date(); context = "ChartRecoerd " + matter2.format(date) + ".dat"; try { f = new File(chatRecord, context); if (f.exists()) context = "复件 " + context; f.createNewFile(); out = new FileWriter(f); temp = String.valueOf(matter1.format(date)) + " 创建日志."; out.append(temp + "\r\n"); out.flush(); //out.close(); } catch (IOException ex) { } try { jbInit(); } catch (Exception ex) { ex.printStackTrace(); } } /***************************************************************** ** 函数名称： join() ** ** 功能描述： 加入组播组 ** ** 入 参： String username （用户名） * InetAddress group （多播组） * int port （端口） * int ttl （生存时间） ** ** 出 参： 无 ** ** 返 回 值： 无 /*****************************************************************/ public void join(String username, InetAddress group, int port, int ttl) throws IOException { setTitle("组播 " + username + "@" + group.getHostAddress() + " : " + port + "[TTL= " + ttl + "]"); chat = new MulticastChat(username, group, port, ttl, this); //初始化组播聊天室 out.append("组播 " + username + "@" + group.getHostAddress() + " : " + port + "[TTL= " + ttl + "]" + "\r\n"); out.flush(); } /***************************************************************** ** 函数名称： log() ** ** 功能描述： 用户登陆 ** ** 入 参： final String message （发送的消息） ** ** 出 参： 无 ** ** 返 回 值： 无 /*****************************************************************/ protected void log(final String message) { java.util.Date date = new java.util.Date(); SwingUtilities.invokeLater(new Runnable() { public void run() { textArea.append(message + "\r\n"); try { out.append(message + "\r\n"); out.flush(); } catch (IOException ex) { } textAreaScrollPane.getVerticalScrollBar().setValue( textAreaScrollPane.getVerticalScrollBar().getMaximum()); } }); } /***************************************************************** ** 函数名称： actionPerformed() ** ** 功能描述： 监听器用户的单机按钮操作 ** ** 入 参： ActionEvent （行动事件的监听） ** ** 出 参： 无 ** ** 返 回 值： 无 /*****************************************************************/ public void actionPerformed(ActionEvent e) { if ((e.getSource().equals(messageField)) || (e.getSource().equals(sendButton))) { String message = messageField.getText(); messageField.setText(""); try { chat.sendMessage(message); } catch (IOException ex) { JOptionPane.showMessageDialog(this, "发送错误: " + ex.getMessage(), "出错", JOptionPane.ERROR_MESSAGE); } } } /***************************************************************** ** 函数名称： windowOpened() ** ** 功能描述： 监听器，打开对话框 ** ** 入 参： WindowEvent （行动事件的监听） ** ** 出 参： 无 ** ** 返 回 值： 无 /*****************************************************************/ public void windowOpened(WindowEvent e) { messageField.requestFocus(); } public void windowClosing(WindowEvent e) { try { /* int inf = JOptionPane.showConfirmDialog(this, "确实要退出么？", "确认退出", JOptionPane.YES_NO_OPTION); if (inf == 0) { if(chat != null)*/ chat.terminate(); System.exit(1); this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); // } } catch (Throwable ex) { JOptionPane.showMessageDialog(this, "无法离开组播" + ex.getM