利用java.net.*编写广播聊天室

张谊 — Mon, 01 Sep 2008 12:57:00 GMT

Client：

package Chat;
import java.io.*;
import java.net.*;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;

import javax.swing.*;

public class Client {
    JTextArea jta;
    JTextField jtf;
    BufferedReader in;
    PrintWriter out;
    private void initGui(){
        JFrame f=new JFrame("Client");
        f.setSize(400,300);
        f.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        jta=new JTextArea();
        jta.setEditable(false);
        f.add(new JScrollPane(jta));
        jtf=new JTextField();
        f.add(jtf,"South");
        f.setVisible(true);
        jtf.addActionListener(new ActionListener(){
            public void actionPerformed(ActionEvent arg0) {
                String text=jtf.getText();
                jtf.setText("");
                out.println(text);
                out.flush();
            }
        });
    }
    private void initNet(){
        try {
            Socket s=new Socket("127.0.0.1",8888);
            out=new PrintWriter(s.getOutputStream());
            in=new BufferedReader(
                    new InputStreamReader(s.getInputStream()));
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    private void receive(){
        try {
            while(true){
                String str = in.readLine();
                if(str==null){
                    return ;
                }
                jta.append("说"+str+"\n");
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    public Client(){
        initGui();
        initNet();
    }

    public static void main(String[] args) throws Exception{
        Client c=new Client();
        c.receive();
    }
}

Server：

package ChatIV;
import java.net.*;
import java.io.*;
import java.util.*;

public class Server {
    public static void main(String args[]){
        try {
            ServerSocket ss = new ServerSocket(8888);
            List sockets = new ArrayList();
            while(true){
                Socket s = ss.accept();
                sockets.add(s);
                Thread t1 = new ChatThread(s,sockets);
                t1.start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}
class ChatThread extends Thread{
    Socket s;
    List sockets;
    public ChatThread(Socket s,List sockets){
        this.s=s;
        this.sockets=sockets;
    }
    public void run(){
        try {
            BufferedReader in = new BufferedReader(new InputStreamReader(s.getInputStream()));
            while(true){
                String str = in.readLine();
                for(int i=0;i<sockets.size();i++){
                    Socket s2 = (Socket)sockets.get(i);
                    PrintWriter out = new PrintWriter(s2.getOutputStream());
                    out.println(str);
                    out.flush();
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally{
            try {
                s.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

张谊 2008-09-01 20:57 发表评论

语源科技BlogJava-誼's Blog|J2EE|

利用java.net.*编写广播聊天室