chatclient.java

简易的局域网聊天工具

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

public class ChatClient extends Frame {
	Socket s = null;

	DataOutputStream dos = null;

	DataInputStream dis = null;

	private boolean bConnected = false;

	TextField tfTxt = new TextField();

	TextArea taContent = new TextArea();
	
	Thread tRece = new Thread(new ReceThread());
	
	public static void main(String[] args) {
		new ChatClient().launchFrame();
	}

	/*
	 * 聊天界面
	 */
	public void launchFrame() {
		setTitle("多人聊天程序");
		setLocation(400, 300);
		this.setSize(300, 300);
		add(tfTxt, BorderLayout.SOUTH);
		add(taContent, BorderLayout.NORTH);
		pack();
		this.addWindowListener(new WindowAdapter() {

			public void windowClosing(WindowEvent arg0) {
				disconnect();
				System.exit(0);
			}

		});
		tfTxt.addActionListener(new TFListener());
		setVisible(true);

		connect();

		tRece.start();
	}

	public void connect() {

		try {
			s = new Socket("127.0.0.1", 8888);
			dos = new DataOutputStream(s.getOutputStream());
			dis = new DataInputStream(s.getInputStream());
			System.out.println("connected!");
			bConnected = true;
		} catch (UnknownHostException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}

	}

	public void disconnect() {
		try{
			if(dos != null) dos.close();
			if(dis != null) dis.close();
			if(s != null) s.close();
		}catch(IOException e){
			e.printStackTrace();
		}
		/*try {
			bConnected = false;
			tRece.join();
		} catch(InterruptedException e){
			e.printStackTrace();
		}finally{
			try{
				if(dos != null) dos.close();
				if(dis != null) dis.close();
				if(s != null) s.close();
			}catch(IOException e){
				e.printStackTrace();
			}
		}
		*/

	}

	private class TFListener implements ActionListener {

		public void actionPerformed(ActionEvent e) {
			String str = tfTxt.getText().trim();
			tfTxt.setText("");

			try {
				// System.out.println(str);
				dos.writeUTF(str);
				dos.flush();
			} catch (IOException e1) {
				e1.printStackTrace();
			}
		}

	}

	private class ReceThread implements Runnable {

		public void run() {
			try {
				while (bConnected) {
					String str = dis.readUTF();
					taContent.setText(taContent.getText() + str + "\n");
				}
			} catch(SocketException e){
				System.out.println("退出");
				//System.exit(0);
			}catch(EOFException e){
				System.out.println("已退出!");
			} catch (IOException e) {
				e.printStackTrace();
			}

		}
	}
}