java网络编程相关知识2

package com.wangbin.timu4; import java.io.*; import java.net.Socket; import java.util.Set; public class ThreadDemo implements Runnable{ private Socket a; private static int i=0; private String name; public ThreadDemo(Socket a,String name) { this.a = a; this.name=name; } @Override public void run() { BufferedWriter bw = null; try { BufferedReader br = new BufferedReader(new InputStreamReader(a.getInputStream())); // while (true){ Set<String> strings1 = ServerDemo.hm.keySet(); for(String sss:strings1){ if(!sss.equals(this.name)){ Socket socket = ServerDemo.hm.get(sss); bw=new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); bw.write(this.name+"已上线"); bw.newLine(); bw.flush(); } } String s; // 别的客户端发送消息 while ((s = br.readLine()) != null) { if(s.equals("exit")){ ServerDemo.hm.remove(this.name); Set<String> strings = ServerDemo.hm.keySet(); for(String sss:strings){ Socket socket =ServerDemo.hm.get(sss); bw=new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); bw.write(this.name+"下线了"); bw.newLine(); bw.flush(); } // bw.write(this.name+"退出聊天室"); // bw.newLine(); // bw.flush(); continue; } // 像别的客户端发送消息 // 定义一个参数判断@的人存不存在 boolean flag=false; Set<String> strings = ServerDemo.hm.keySet(); for(String sss:strings){ // 单独发送 // 判断是否有私聊情况 if(s.indexOf("@")==0){ String use = s.substring(1); // 测试 if(use.substring(0,sss.length()).equals(sss)){ Socket socket = ServerDemo.hm.get(sss); bw=new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); bw.write(this.name+"给你偷偷发了一句>>"); //获取@+姓名后面的信息 String ss = s.substring(1+sss.length()); bw.write(ss); bw.newLine(); bw.flush(); } }else if(!sss.equals(this.name)){ Socket socket = ServerDemo.hm.get(sss); bw=new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); bw.write(this.name+":"); bw.write(s); bw.newLine(); bw.flush(); } } System.out.println("来自" + this.name+ "的消息>>" + s); } } catch (IOException e) { try { a.close(); } catch (IOException ioException) { System.out.println("未知错误"); } try { bw.close(); } catch (IOException ioException) { System.out.println("未知错误"); } System.out.println("未知错误，服务器已关闭"); } } }