socketclient.java

Socket提高（Socket通信的客户端）

package socketclient;

import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
import java.net.*;
import java.io.*;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: </p>
 * @author not attributable
 * @version 1.0
 */

public class SocketClient
    extends JFrame
    implements Runnable {
  JPanel contentPane;
  JScrollPane jScrollPane1 = new JScrollPane();
  JTextArea jTextArea1 = new JTextArea();
  JTextField jTextField1 = new JTextField();
  JButton jButton1 = new JButton();
  JButton jButton2 = new JButton();
  JButton jButton3 = new JButton();

  Socket socket;
  BufferedReader bufferedReader;
  PrintWriter printWriter;

  //Construct the frame
  public SocketClient() {
    enableEvents(AWTEvent.WINDOW_EVENT_MASK);
    try {
      jbInit();
    }
    catch (Exception e) {
      e.printStackTrace();
    }
  }

  //Component initialization
  private void jbInit() throws Exception {
    contentPane = (JPanel)this.getContentPane();
    contentPane.setLayout(null);
    this.setSize(new Dimension(324, 275));
    this.setTitle("客户端");
    jScrollPane1.setBounds(new Rectangle(23, 21, 276, 134));
    jTextField1.setText("");
    jTextField1.setBounds(new Rectangle(22, 174, 277, 23));
    jTextField1.addKeyListener(new SocketClient_jTextField1_keyAdapter(this));
    jButton1.setBounds(new Rectangle(22, 210, 65, 25));
    jButton1.setText("连接");
    jButton1.addActionListener(new SocketClient_jButton1_actionAdapter(this));
    jButton2.setBounds(new Rectangle(123, 210, 65, 25));
    jButton2.setEnabled(false);
    jButton2.setSelected(false);
    jButton2.setText("发送");
    jButton2.addActionListener(new SocketClient_jButton2_actionAdapter(this));
    jButton3.setBounds(new Rectangle(230, 210, 65, 25));
    jButton3.setSelected(false);
    jButton3.setText("退出");
    jButton3.addActionListener(new SocketClient_jButton3_actionAdapter(this));
    jTextArea1.setText("");
    contentPane.add(jScrollPane1, null);
    contentPane.add(jTextField1, null);
    contentPane.add(jButton1, null);
    contentPane.add(jButton2, null);
    contentPane.add(jButton3, null);
    jScrollPane1.getViewport().add(jTextArea1, null);
  }

  //Overridden so we can exit when window is closed
  protected void processWindowEvent(WindowEvent e) {
    super.processWindowEvent(e);
    if (e.getID() == WindowEvent.WINDOW_CLOSING) {
      System.exit(0);
    }
  }

  void jButton1_actionPerformed(ActionEvent e) {
    Thread t = new Thread(this);
    t.start();
  }

  public void run() {
    /**@todo Implement this java.lang.Runnable method*/
    try {
      socket = new Socket("client", 1001);
      bufferedReader = new BufferedReader(new InputStreamReader(socket.
          getInputStream()));
      printWriter = new PrintWriter(socket.getOutputStream());
      jButton2.setEnabled(true);
      GetInfo getInfo = new GetInfo();
      Thread t = new Thread(getInfo);
      t.start();
      jTextArea1.append("客户端已加入！\n");
      jButton1.setEnabled(false);
    }
    catch (Exception e) {
      jTextArea1.append(e.toString() + "\n");
    }
  }

  private class GetInfo
      implements Runnable {
    public void run() {
      String str;
      try {
        str = bufferedReader.readLine(); //从bufferedReader读入一行
        while (str != "客户端退出！") {
          jTextArea1.append("客户端信息：" + str + "\n");
          str = bufferedReader.readLine(); //继续读入客户端信息
        }
        bufferedReader.close(); //关闭缓冲区
        printWriter.close();
        socket.close(); //关闭socket
      }
      catch (Exception e) {
        jButton2.setEnabled(false);
        jTextArea1.append(e.toString() + "\n");
      }
    }
  }

  void jButton2_actionPerformed(ActionEvent e) {
    printWriter.println(jTextField1.getText());
    printWriter.flush();
    jTextArea1.append("客户端信息：" + jTextField1.getText() + "\n");
    jTextField1.setText("");
  }

  void jButton3_actionPerformed(ActionEvent e) {
    try {
      printWriter.println("客户端退出！");
      printWriter.flush();
    }
    catch (Exception err) {
      jTextArea1.append(err.toString() + "\n");
    }
    finally {
      System.exit(0);
    }
  }

  void jTextField1_keyPressed(KeyEvent e) {
    if (e.getKeyChar() == KeyEvent.VK_ENTER) {
      printWriter.println(jTextField1.getText());
      printWriter.flush();
      jTextArea1.append("客户端信息：" + jTextField1.getText() + "\n");
      jTextField1.setText("");
    }
  }

}

class SocketClient_jButton1_actionAdapter
    implements java.awt.event.ActionListener {
  SocketClient adaptee;

  SocketClient_jButton1_actionAdapter(SocketClient adaptee) {
    this.adaptee = adaptee;
  }

  public void actionPerformed(ActionEvent e) {
    adaptee.jButton1_actionPerformed(e);
  }
}

class SocketClient_jButton2_actionAdapter
    implements java.awt.event.ActionListener {
  SocketClient adaptee;

  SocketClient_jButton2_actionAdapter(SocketClient adaptee) {
    this.adaptee = adaptee;
  }

  public void actionPerformed(ActionEvent e) {
    adaptee.jButton2_actionPerformed(e);
  }
}

class SocketClient_jButton3_actionAdapter
    implements java.awt.event.ActionListener {
  SocketClient adaptee;

  SocketClient_jButton3_actionAdapter(SocketClient adaptee) {
    this.adaptee = adaptee;
  }

  public void actionPerformed(ActionEvent e) {
    adaptee.jButton3_actionPerformed(e);
  }
}

class SocketClient_jTextField1_keyAdapter
    extends java.awt.event.KeyAdapter {
  SocketClient adaptee;

  SocketClient_jTextField1_keyAdapter(SocketClient adaptee) {
    this.adaptee = adaptee;
  }

  public void keyPressed(KeyEvent e) {
    adaptee.jTextField1_keyPressed(e);
  }
}