carmanage.java

利用JAVA编写即时聊天通信软件

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

public class CarManage extends WindowAdapter 
implements ActionListener{
	ServerSocket server;
	Socket client;
	boolean flag;
	BufferedReader cin;
	PrintWriter cout;
	TextArea textArea;
	Frame f;
	Button b1;
	TextField tf;
	TextArea ta;
	
	public CarManage(){
		try{
			server = new ServerSocket(5000);
			this.CFrame("电脑端口号："+server.getLocalPort());
			flag = true;
			while(flag){
				client = server.accept();
				System.out.println("连接已建立!");
				InputStream is = client.getInputStream();
				cin = new BufferedReader(new InputStreamReader(is));
				OutputStream os = client.getOutputStream();
				cout = new PrintWriter(os,true);
				String aline;
				while((aline = cin.readLine()) != null){
					ta.append(aline + "\n" );
					if(aline.equals("bye")){flag = false;
					break;
					}
				}
				
				is.close();
				cin.close();
				cout.close();
				client.close();
			}
			
		}catch(Exception e){
			System.out.println(e);
		}
	}
	public void CFrame (String str){
     	f = new Frame("程序"+str);
     	f.setSize(400, 300);
		ta = new TextArea();
		f.add(ta);
		ta.setEnabled(false);
		Panel p = new Panel();
		f.add(p,"South");
		tf = new TextField(20);
		b1 = new Button("发送");
		p.add(tf);
		p.add(b1);
		b1.addActionListener(this);
		tf.addActionListener(this);
		f.setVisible(true);
		f.addWindowListener(this);
	}
	public void actionPerformed(ActionEvent e){
		ta.append(tf.getText()+"\n");
		cout.println(tf.getText());
		tf.setText(" ");
	}
    public static void main(String[] ar){
        new CarManage();   
                                        }
   }