chatclient.java

采用eclipse实现了聊天室的简单框架功能,能够进行简单的通信

package com.ata.chat;

import java.awt.*;
import java.awt.event.*;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.*;

public class ChatClient extends Frame {
	Socket s = null;
	DataOutputStream dos = null;
	DataInputStream dis=null;
	private boolean bConnected=false;
	Thread tRecv=new Thread(new RecvThread());
	TextField tfTxt = new TextField();
	TextArea taContent = new TextArea();

	public static void main(String[] args) {
		new ChatClient().launchFrame();
	}

	public void launchFrame() {
		setLocation(800, 500);
		this.setSize(400, 300);
		add(tfTxt, BorderLayout.SOUTH);
		add(taContent, BorderLayout.NORTH);
		pack();
		
		this.addWindowListener(new WindowAdapter() {
			public void windowClosing(WindowEvent arg0) {
				System.exit(0);
			}
		});
		
		tfTxt.addActionListener(new KeyEnterListener());
		setVisible(true);
		connect();
		tRecv.run();
	}

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

	public void disconnect() {
		try {
			bConnected=false;
			tRecv.join();
		}  catch (InterruptedException e) {
			e.printStackTrace();
		}finally{
			try{
				dos.close();
				dis.close();
				s.close();
			}catch (IOException e) {
				e.printStackTrace();
			}
		}
	}

	private class KeyEnterListener implements ActionListener {

		public void actionPerformed(ActionEvent arg0) {
			String str = tfTxt.getText().trim();
			taContent.setText(str);
			tfTxt.setText("");
			try {
				dos.writeUTF(str);
				dos.flush();

			} catch (IOException e) {
				e.printStackTrace();
			}

		}

	}

	private class RecvThread implements Runnable{
		public void run(){
			try {
			while(bConnected){
				String str;
				str = dis.readUTF();
				taContent.setText(taContent.getText()+"\n"+str);
//				System.out.println(str);
			}
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
}