java多线程控制台聊天室(转)

时间：2015-03-09 23:41:22 阅读：370 评论：0 收藏：0 [点我收藏+]

用java多线程实现一个控制台聊天室，呵呵，好玩！
聊天室服务器端

Java代码  
package tf.thread;  
  
import java.io.BufferedReader;  
import java.io.IOException;  
import java.io.InputStreamReader;  
import java.io.PrintWriter;  
import java.net.ServerSocket;  
import java.net.Socket;  
import java.util.ArrayList;  
import java.util.List;  
import java.util.concurrent.ExecutorService;  
import java.util.concurrent.Executors;  
  
public class ChatServer {  
    private static final int PORT = 8888; // 端口号  
    private static List<Socket> list = new ArrayList<Socket>(); // 保存连接对象  
    private ExecutorService exec;  
    private ServerSocket server;  
  
    public static void main(String[] args) {  
        new ChatServer();  
    }  
  
    public ChatServer() {  
        try {  
            server = new ServerSocket(PORT);  
            exec = Executors.newCachedThreadPool();  
            System.out.println("服务器已启动！");  
  
            Socket client = null;  
            while (true) {  
                client = server.accept(); // 接收客户连接  
                list.add(client);  
                exec.execute(new ChatTask(client));  
            }  
        } catch (IOException e) {  
            e.printStackTrace();  
        }  
    }  
  
    static class ChatTask implements Runnable {  
        private Socket socket;  
        private BufferedReader br;  
        private PrintWriter pw;  
        private String msg;  
  
        public ChatTask(Socket socket) throws IOException {  
            this.socket = socket;  
            br = new BufferedReader(new InputStreamReader(socket  
                    .getInputStream()));  
            msg = "【" + this.socket.getInetAddress() + "】进入聊天室！当前聊天室有【"  
                    + list.size() + "】人";  
  
            sendMessage();  
        }  
  
        public void run() {  
            try {  
                while ((msg = br.readLine()) != null) {  
                    if (msg.trim().equals("bye")) {  
                        list.remove(socket);  
                        br.close();  
                        pw.close();  
                        msg = "【" + socket.getInetAddress() + "】离开聊天室！当前聊天室有【"  
                                + list.size() + "】人";  
                        socket.close();  
  
                        sendMessage();  
                        break;  
                    } else {  
                        msg = "【" + socket.getInetAddress() + "】说：" + msg;  
                        sendMessage();  
                    }  
                }  
            } catch (IOException e) {  
                e.printStackTrace();  
            }  
        }  
  
        /** 
         * 群发消息给聊天室的所有人 
         */  
        private void sendMessage() throws IOException {  
            System.out.println(msg);  
            for (Socket client : list) {  
                pw = new PrintWriter(client.getOutputStream(), true);  
                pw.println(msg);  
            }  
        }  
    }  
}  

聊天室客户端（输入bye可退出聊天室）

Java代码  
package tf.thread;  
  
import java.io.BufferedReader;  
import java.io.InputStreamReader;  
import java.io.PrintWriter;  
import java.net.Socket;  
import java.util.concurrent.ExecutorService;  
import java.util.concurrent.Executors;  
  
public class ChatClient {  
    private static final int PORT = 8888;  
    private static ExecutorService exec = Executors.newCachedThreadPool();  
  
    public static void main(String[] args) throws Exception {  
        new ChatClient();  
    }  
  
    public ChatClient() {  
        try {  
            Socket socket = new Socket("192.168.1.120", PORT);  
            exec.execute(new Sender(socket));  
            System.out  
                    .println("【" + socket.getInetAddress() + "】您好，欢迎来到阿飞聊天室！");  
  
            BufferedReader br = new BufferedReader(new InputStreamReader(socket  
                    .getInputStream()));  
            String msg;  
            while ((msg = br.readLine()) != null) {  
                System.out.println(msg);  
            }  
        } catch (Exception e) {  
  
        }  
    }  
  
    /** 
     * 客户端线程获取控制台输入消息 
     */  
    static class Sender implements Runnable {  
        private Socket socket;  
  
        public Sender(Socket socket) {  
            this.socket = socket;  
        }  
  
        public void run() {  
            try {  
                BufferedReader br = new BufferedReader(new InputStreamReader(  
                        System.in));  
                PrintWriter pw = new PrintWriter(socket.getOutputStream(), true);  
                String msg;  
  
                while (true) {  
                    msg = br.readLine();  
                    pw.println(msg);  
  
                    if (msg.trim().equals("bye")) {  
                        pw.close();  
                        br.close();  
                        exec.shutdownNow();  
                        break;  
                    }  
                }  
            } catch (Exception e) {  
                e.printStackTrace();  
            }  
        }  
    }  
}  

声明：ITeye文章版权属于作者，受法律保护。没有作者

mina 几句就搞定了的

http://www.iteye.com/topic/365764

java多线程控制台聊天室(转)

原文：http://www.cnblogs.com/softidea/p/4324725.html

踩

(0)

评论一句话评论（0）

分享档案

更多>

2021年09月23日 (328)
2021年09月24日 (313)
2021年09月17日 (191)
2021年09月15日 (369)
2021年09月16日 (411)
2021年09月13日 (439)
2021年09月11日 (398)
2021年09月12日 (393)
2021年09月10日 (160)
2021年09月08日 (222)