java实现局域网互发消息

package WindosUI; import java.awt.BorderLayout; import java.awt.Dimension; import javax.swing.JFrame; import javax.swing.JPanel; import javax.swing.JButton; import javax.swing.JTextArea; import java.awt.Rectangle; import javax.swing.JTextField; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.io.*; import java.net.*; import java.util.*; import Business.*; import java.awt.event.WindowEvent; import java.awt.event.WindowAdapter; import javax.swing.JScrollBar; import javax.swing.JScrollPane; import javax.swing.JOptionPane; import javax.swing.JLabel; import javax.swing.Box; public class FrmMessage2 extends JFrame { JPanel contentPane; JTextArea txaSend = new JTextArea(); JButton btnSend = new JButton(); JTextArea txtReceivedMessage = new JTextArea(); JButton btnReceive = new JButton(); JTextField txtIP = new JTextField(); private LinkedList msgs; //消息队列 //发送接收消息的必要方法 private ReceiveMessage rm = new ReceiveMessage(); private SendMessage sm = new SendMessage(); JScrollPane jScrollPane1 = new JScrollPane(); JTextField txtSenderName = new JTextField(); JLabel jLabel1 = new JLabel(); JLabel jLabel2 = new JLabel(); public FrmMessage2() { try { setDefaultCloseOperation(EXIT_ON_CLOSE); jbInit(); //开始接收消息 startReceive(); ListenMessage l = new ListenMessage(); l.start(); } catch (Exception exception) { exception.printStackTrace(); } } /** * Component initialization. * * @throws java.lang.Exception */ private void jbInit() throws Exception { contentPane = (JPanel) getContentPane(); contentPane.setLayout(null); setSize(new Dimension(381, 429)); setTitle("发送接受消息"); this.addWindowListener(new FrmMessage2_this_windowAdapter(this)); txaSend.setText("在此写下要发的消息"); txaSend.setBounds(new Rectangle(31, 169, 314, 92)); btnSend.setBounds(new Rectangle(31, 359, 111, 32)); btnSend.setText("send"); btnSend.addActionListener(new Frame1_btnSend_actionAdapter(this)); txtReceivedMessage.setEditable(false); txtReceivedMessage.setLineWrap(true); txtReceivedMessage.setRows(5); btnReceive.setBounds(new Rectangle(233, 360, 111, 32)); btnReceive.setEnabled(false); btnReceive.setMaximumSize(new Dimension(57, 23)); btnReceive.setMinimumSize(new Dimension(57, 23)); btnReceive.setPreferredSize(new Dimension(57, 23)); btnReceive.setText("receive"); btnReceive.addActionListener(new Frame1_btnReceive_actionAdapter(this)); txtIP.setText("127.0.0.1"); txtIP.setBounds(new Rectangle(219, 276, 117, 27)); jScrollPane1.setBounds(new Rectangle(31, 33, 317, 119)); txtSenderName.setText("小夏"); txtSenderName.setBounds(new Rectangle(219, 313, 117, 27)); jLabel1.setText("目标机器名或者IP地址"); jLabel1.setBounds(new Rectangle(29, 287, 120, 15)); jLabel2.setText("发送人姓名"); jLabel2.setBounds(new Rectangle(31, 318, 69, 21)); contentPane.add(jScrollPane1); jScrollPane1.getViewport().add(txtReceivedMessage); contentPane.add(jLabel1); contentPane.add(btnSend); contentPane.add(txaSend); contentPane.add(jLabel2); contentPane.add(txtIP); contentPane.add(txtSenderName); contentPane.add(btnReceive); } public void btnSend_actionPerformed(ActionEvent e) { try { this. sm.send( (txtSenderName.getText()+": "+txaSend.getText()), txtIP.getText()); } catch (IOException ex) { JOptionPane.showConfirmDialog(this,ex.getMessage()); } catch (Exception ex) { JOptionPane.showConfirmDialog(this,ex.getMessage()); } } public void btnReceive_actionPerformed(ActionEvent e) { try { String str = rm.getMessageOnce(); if (str != null) { this.txtReceivedMessage.append(str); } } catch (Exception ex) { JOptionPane.showConfirmDialog(this,ex.getMessage()); } } //开始接收消息 private void startReceive() { try { rm.beginReceive(); } catch (SocketException ex) { JOptionPane.showMessageDialog(this,ex.getMessage()); } catch (IOException ex) { JOptionPane.showMessageDialog(this,ex.getMessage()); } } public void this_windowClosing(WindowEvent e) { } //自动接收消息 class ListenMessage extends Thread { public void run() { while (true) { try { sleep(1000); } catch (InterruptedException ex1) { break; } if (rm.getMessageCount() > 0) { try { String str = rm.getMessageOnce(); if (str != null) { txtReceivedMessage.append(str+"\n"); } } catch (Exception ex) { throw new RuntimeException(ex.getMessage()); } } } }//End run method }//End inner class thread } //End class class FrmMessage2_this_windowAdapter extends WindowAdapter { private FrmMessage2 adaptee; FrmMessage2_this_windowAdapter(FrmMessage2 adaptee) { this.adaptee = adaptee; } public void windowClosing(WindowEvent e) { adaptee.this_windowClosing(e); } } class Frame1_btnReceive_actionAdapter implements ActionListener { private FrmMessage2 adaptee; Frame1_btnReceive_actionAdapter(FrmMessage2 adaptee) { this.adaptee = adaptee; } public void actionPerformed(ActionEvent e) { adaptee.btnReceive_actionPerformed(e); } } class Frame1_btnSend_actionAdapter implements ActionListener { private FrmMessage2 adaptee; Frame1_btnSend_actionAdapter(FrmMessage2 adaptee) { this.adaptee = adaptee; } public void actionPerformed(ActionEvent e) { adaptee.btnSend_actionPerformed(e); } }