package Server;
import java.io.*;
import java.net.*;
import message.MessageType;
//该线程用于和客服端进行通信,是一个线程类
public class ServerClientComunicationThread extends Thread{
Socket s=null;
ObjectInputStream ois=null;
MessageType mt=null;
ObjectOutputStream oos=null;
public ServerClientComunicationThread(Socket s){
this.s=s;
}
public void run(){
//不停地从socket里面读取数据
while(true){
try {
ois=new ObjectInputStream(s.getInputStream());
mt=(MessageType)ois.readObject();
System.out.println("服务器读取到的信息");
System.out.println(mt.getContent()+" "+mt.getGetter()+" "+
mt.getMessagetype()+mt.getSendTime());
//将读取到的数据转发给对应的客服端
System.out.println("从集合里面可以找到用户压迫将数据发送给"+ ManageOnlineUser.hm.get(mt.getGetter()));
oos=new ObjectOutputStream(( ManageOnlineUser.hm.get(mt.getGetter())).getOutputStream());
oos.writeObject(mt);
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
将链接过来的socket保存,需要广播时遍历发送:
在server主类中定义private static List
public ServerThread(Socket s,List
this.s=s;
this.ships=ships;
ss.setSos(s);
}
需要广播时:
List
Iterator
Socket temps=null;
while(i.hasNext()){
temps=(Socket)i.next();
os=new PrintWriter(temps.getOutputStream());
os.println(mess);
os.flush();
}