server_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 Server_Socket implements ActionListener,Runnable{
    private Frame f;
    private static TextArea ta1,ta2;
    private Label l1;
    private Button b1;

    static final int PORT=8888;
    private Socket socket;
    private static BufferedReader in;
    private static PrintWriter out;



    public void display()throws IOException{
	    f=new Frame("聊天室");
     	f.setSize(470,450);
      	f.setLocation(20,20);
       	f.setBackground(Color.pink);
       	f.setLayout(new FlowLayout(FlowLayout.CENTER));
	    l1=new Label("欢迎您进入【爱★我★该★爱】聊天室",Label.CENTER);
	    ta1=new TextArea();
	    ta2=new TextArea();
	    ta1.setEditable(false);
	    ta2.setEditable(true);
	    f.add(l1);
        f.add(ta1);
        f.add(ta2);
        b1=new Button("回复");
        f.add(b1);
        b1.addActionListener(this);
	    f.addWindowListener(new WinClose());
	    f.setVisible(true);
    }

    public void actionPerformed(ActionEvent e){
        String str;

        SimpleDateFormat sdf=new SimpleDateFormat();
        sdf.applyPattern("HH:mm:ss");
        String timeStr = sdf.format(new Date());
        if((e.getSource())==b1){
            str=ta2.getText();
            out.println("Server:"+str+"  ["+timeStr+"]");
            ta1.append("Server:"+str+"  ["+timeStr+"]\n");
            ta2.setText("");
        }
    }

    public static void main(String[] args)throws IOException{
        Server_Socket server=new Server_Socket();
        server.display();
        ServerSocket s=new ServerSocket(PORT);
        System.out.println("Server Started!");


        Socket socket=s.accept();
        in=new BufferedReader(new InputStreamReader(socket.getInputStream()));
        out=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);

        String str;
        try{
            while(true){
               str=in.readLine();
               ta1.append(str+"\n");
               if(str.equals("END"))
                    break;
             }
        }
        catch(IOException e){
        }
        try{
            socket.close();
            s.close();
        }
        catch(IOException e){
        }
    }
}