java网络编程相关知识

package com.wangbin.timu5; 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")){ bw.write(this.name+"退出聊天室"); bw.newLine(); bw.flush(); break; } // 像别的客户端发送消息 // 定义一个参数判断@的人存不存在 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); } System.out.println("客户端" + this.name+"退出聊天室"); } catch (IOException e) { // e.printStackTrace(); System.out.println("有一位用户下线"); }finally { try { a.close(); assert bw != null; bw.close(); } catch (IOException e) { // e.printStackTrace(); System.out.println("未知错误"); } } } }