client_socket.java

用Java编写的基于Socket的聊天室小程序！

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

public class Client_Socket implements ActionListener,Runnable{
    Frame f;
	TextField tf;
	Button b1,b2;
	Label l1;
	static TextArea ta1,ta2;
	String IpAddr;
	Socket socket;
	static BufferedReader in;
	PrintWriter out;
	BufferedReader wt;
	String message;

    Thread readThread;
    boolean isTrue=true;

public void display(){               //显示客户端界面
	f=new Frame("欢迎您进入【爱★我★该★爱】聊天室");
	f.setSize(500,450);
	f.setLocation(500,100);
	f.setBackground(Color.pink);
	f.setLayout(new FlowLayout(FlowLayout.CENTER));
	tf=new TextField("在此输入服务器的IP地址",25);
	tf.setEditable(true);
	f.add(tf);
	b1=new Button("连接");
	b2=new Button("发送");
	f.add(b1);
	l1=new Label("消息");
	ta1=new TextArea();
	ta1.setEditable(false);
	ta2=new TextArea();
	f.add(ta1);
	f.add(l1);
	f.add(ta2);
	f.add(b2);
	b1.addActionListener(this);
	b2.addActionListener(this);
	f.addWindowListener(new WinClose());
	f.setVisible(true);
}

public void actionPerformed(ActionEvent e){           //响应发送按钮

	if((e.getSource())==b1){
        IpAddr=tf.getText();
        try{
            getConnection(IpAddr);
        }
        catch(IOException e1){
        }

    }

	if((e.getSource())==b2){
        try{
            sendMessage();
        }
	    catch(IOException e2){
        }
	}

}

public void sendMessage()throws IOException{         //发送消息


    SimpleDateFormat sdf=new SimpleDateFormat();
    sdf.applyPattern("HH:mm:ss");

    String timeStr = sdf.format(new Date());
    message=ta2.getText();
    ta2.setText("");
    out.println(message+"  ["+timeStr+"]");
    if(message.equals("END"))
        System.exit(0);
}

public void processMsg(String msg){
    ta1.append(msg);
    ta1.append("\n");
}

public void getConnection(String Ipaddr)throws IOException{         //建立连接
    String str;
    InetAddress addr=InetAddress.getByName(IpAddr);
    System.out.println("addr="+addr);
    socket=new Socket(addr,8888);
    System.out.println("socket="+socket);
    in=new BufferedReader(new InputStreamReader(socket.getInputStream()));
    out=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);
    readThread=new Thread(this);
    readThread.start();
}

public void run(){                           //聊天机制
    String msg;
    isTrue=true;
    while(isTrue){
        try{
            msg=in.readLine();
            if(msg.equals("Server exit!")){
                processMsg(msg);
                isTrue=false;
            }
            else if(msg!=null){
                 processMsg(msg);
            }
            Thread.sleep(1000);
        }catch(IOException e){
           processMsg(e.toString());
        }catch(InterruptedException ei){
          processMsg(ei.toString());
        }
  }

  try{
   socket.close();
   in.close();
   out.close();
  }catch(IOException ioe){}
 }

public static void main(String[] args)throws IOException{

    Client_Socket cs=new Client_Socket();
    cs.display();
 }
}