Java-在线聊天系统-非线程

import java.io.DataInputStream;
import java.io.EOFException;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.UnknownHostException;


public class ChatServer{
	
	public static void main(String[] args) {
		
		DataInputStream dis = null;
		Socket s = null;
		ServerSocket ss = null;
		boolean started =false;
		
		try {
			ss = new ServerSocket(8888);
		} catch (IOException e1) {
			e1.printStackTrace();
		}
		
		try {
			started = true;
			while(started){
				boolean bConnect = false;
				//!!!!!注意accept()是阻塞性方法，当被readUTF()阻塞时它不会被执行
				s = ss.accept();
System.out.println("a client connect------"+s);
				dis = new DataInputStream(s.getInputStream());
				bConnect = true;
				while(bConnect){
					//!!!!!注意readUTF()是阻塞性方法
					System.out.println(dis.readUTF());
				}
			}
		} catch (EOFException e) {
			System.out.println("客户端已关闭！");
		} catch (IOException e) {
			e.printStackTrace();
		}finally{
			try {
				if(dis != null ) dis.close();
				if(s != null ) s.close();
				if(ss != null ) ss.close();
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}
}

import java.awt.BorderLayout;
import java.awt.Button;
import java.awt.Frame;
import java.awt.TextArea;
import java.awt.TextField;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.KeyEvent;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;


public class ChatClient extends Frame{

	private TextField tfText;
	private TextArea taContent;
//	private Button btnSend;
	private Socket socket;
	private DataOutputStream dos;
	
	public void launchFrame(){
		
		addWindowListener(new WindowAdapter() {
			 public void windowClosing(WindowEvent e) {
				 disconnect();
				 System.exit(0);
			 }
		});
		
		tfText = new TextField();
		taContent = new TextArea();
//		btnSend = new Button("发送");
//		
//		btnSend.addActionListener(new ActionListener() {
//			@Override
//			public void actionPerformed(ActionEvent e) {
//				//taContent.setText(taContent.getText()+"\n\r"+tfText.getText());
//				//tfText.setText("");
//				try {
//					DataOutputStream dos = new DataOutputStream(socket.getOutputStream());
//					dos.writeUTF(tfText.getText());
//					dos.close();
//					socket.close();
//				} catch (IOException e1) {
//					e1.printStackTrace();
//				}
//			}
//		});
		
		tfText.addActionListener(new TFListener());
		
		add(taContent,BorderLayout.NORTH);
		add(tfText,BorderLayout.CENTER);
//		add(btnSend,BorderLayout.SOUTH);
		setLocation(300, 100);
		pack();
		setVisible(true);
		connect("localhost", 8888);
	}
	
	//当调用了此方法，会自动把成员变量给socket连接上server
	public void  connect(String address, int port){
		try {
			socket = new Socket(address, port);
			dos = new DataOutputStream(socket.getOutputStream());
		} catch (UnknownHostException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	
	//退出时释放资源
	public void disconnect(){
		try {
			if(dos != null ) dos.close();
			if(socket != null ) socket.close();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	
	class TFListener implements ActionListener{

		@Override
		public void actionPerformed(ActionEvent e) {
			taContent.setText(taContent.getText().trim()+"\n\r"+tfText.getText());
			
			try {
				dos.writeUTF(tfText.getText());
				dos.flush();
				tfText.setText("");
				//dos.close();
				//socket.close();
			} catch (IOException e1) {
				e1.printStackTrace();
			}
		}
	}
	
	public static void main(String[] args) {
		new ChatClient().launchFrame();
	}
}