基本信息

---

下载

   友情提示：（无需注册或充值，赞助后即可获取资源下载链接）

---

     嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：813200300

本次赞助数额为： 10 元　

支付宝支付

微信支付

   源码介绍

---

基于P2P的局域网即时通信系统

private class ClientServiceThread extends Thread { 

        private Socket socket; 

        private User user; 

        private BufferedReader reader; 

        private PrintWriter writer; 

        private boolean isRunning; 

 

        private synchronized boolean init() { 

            try { 

                reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); 

                writer = new PrintWriter(socket.getOutputStream()); 

 

                String info = reader.readLine(); 

                StringTokenizer tokenizer = new StringTokenizer(info, "@"); 

                String type = tokenizer.nextToken(); 

                if (!type.equals("LOGIN")) { 

                    sendMessage("ERROR@MESSAGE_TYPE"); 

                    return false; 

                } 

                user = new User(tokenizer.nextToken()); 

                sendMessage("LOGIN@SUCCESS@" user.description() "与服务器连接成功！"); 

                int clientNum = clientServiceThreads.size(); 

                if (clientNum > 0) { 

                    //告诉该客户端还有谁在线 

                    StringBuffer buffer = new StringBuffer(); 

                    buffer.append("@"); 

                    for (Map.Entry<String, ClientServiceThread> entry : clientServiceThreads.entrySet()) { 

                        ClientServiceThread serviceThread = entry.getValue(); 

                        buffer.append(serviceThread.getUser().description() "@"); 

                        //告诉其他用户此用户在线 

                        serviceThread.sendMessage("USER@ADD@" user.description()); 

                    } 

                    sendMessage("USER@LIST@" clientNum buffer.toString()); 

                } 

                return true; 

            } catch(Exception e) { 

                e.printStackTrace(); 

                return false; 

            } 

        } 

        public ClientServiceThread(Socket socket) { 

            this.socket = socket; 

            this.isRunning = init(); 

            if (!this.isRunning) { 

                logMessage("服务线程开启失败！"); 

            } 

        } 

        public void run() { 

            while (isRunning) { 

                try { 

                    String message = reader.readLine(); 

                   // System.out.println("recieve message: " message); 

                    if (message.equals("LOGOUT")) { 

                        logMessage(user.description() "下线..."); 

 

                        int clientNum = clientServiceThreads.size(); 

                         

                        //告诉其他用户该用户已经下线 

                        for (Map.Entry<String, ClientServiceThread> entry : clientServiceThreads.entrySet()) { 

                            entry.getValue().sendMessage("USER@DELETE@" user.description()); 

                        } 

                        //移除该用户以及服务器线程 

                        listModel.removeElement(user.getName()); 

                        clientServiceThreads.remove(user.description()); 

                        close(); 

                        return; 

                    } else {  //发送消息

                        dispatchMessage(message); 

                    } 

                } catch(Exception e) { 

                    e.printStackTrace(); 

                } 

            } 

        } 

        public void dispatchMessage(String message) { 

            StringTokenizer tokenizer = new StringTokenizer(message, "@"); 

            String type = tokenizer.nextToken(); 

            if (!type.equals("MSG")) { 

                sendMessage("ERROR@MESSAGE_TYPE");  

                return; 

            } 

            String to = tokenizer.nextToken(); 

            String from = tokenizer.nextToken(); 

            String content = tokenizer.nextToken(); 

            logMessage(from "->" to ": " content); 

            if (to.equals("ALL")) { 

                //send to everyone 

                for (Map.Entry<String, ClientServiceThread> entry : clientServiceThreads.entrySet()) { 

                    entry.getValue().sendMessage(message); 

                } 

            } else { 

                //发送给某一个人 

                if (clientServiceThreads.containsKey(to)) { 

                    clientServiceThreads.get(to).sendMessage(message); 

                } else { 

                    sendMessage("ERROR@INVALID_USER"); 

                } 

            } 

        }  

        public void close() throws IOException { 

            this.isRunning = false; 

            this.reader.close(); 

            this.writer.close(); 

            this.socket.close(); 

             

        }  

        public void sendMessage(String message) { 

            writer.println(message); 

            writer.flush(); 

        } 

        public User getUser() { 

            return user; 

        } 

    }