client.java

本程序是专门为局域网而建立的聊天程序,它功能有限只能用于局域网聊天当中

package It;

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

public class Client extends Frame implements Runnable {
	private TextField nameBox = new TextField("请在这里输入您的名字");

	private TextArea msgView = new TextArea();

	private TextField sendBox = new TextField();

	private BufferedReader reader;

	private PrintWriter writer;

	private Socket socket;

	public Client(String title) {
		super(title);
		msgView.setEditable(false);
		add(nameBox, "North");
		add(msgView, "Center");
		add(sendBox, "South");
		sendBox.addActionListener(new ActionListener() {
			public void actionPerformed(ActionEvent ae) {
				try {
					writer.println(nameBox.getText() + ":" + sendBox.getText());
					sendBox.setText("");
				} catch (Exception ie) {
				}
			}
		});
		pack();
	}

	public void run() {
		while (true) {
			try {
				msgView.append(reader.readLine() + "\n");
			} catch (IOException ie) {
			}
		}
	}

	private void connect() {
		try {
			msgView.append("和服务器套接字连接\n");
			socket = new Socket("127.0.0.1", 2554);
			msgView.append("聊天就绪\n");
			//从字符输入流中读取文本
			reader = new BufferedReader(new InputStreamReader(socket
					.getInputStream()));
			//向文本输出流打印对象的格式化表示形式
			writer = new PrintWriter(socket.getOutputStream(), true);
			new Thread(this).start();
		} catch (Exception e) {
			msgView.append("连接失败");
		}
	}

	public static void main(String[] args) {
		Client client = new Client("聊天（按回车发送信息）");
		client.setVisible(true);
		client.connect();
		client.addWindowListener(new   WindowAdapter(){
			  public   void   windowClosing(WindowEvent   e)   
			  {   
			  System.exit(0);   
			  }
		});
	}
}