import java.io.*;
import java.net.Socket;
import java.util.List;
public class ClientThread extends Thread{
List<user> list;//保存线程对象
user us;
public ClientThread(user us,List<user> list)
{
this.us=us;
this.list=list;
}
public void run()
{
try {
int l=Integer.parseInt(us.getBr().readLine());//想要聊天的线程
System.out.println();
while(true)
{
String str=us.getBr().readLine();//服务器一直得到信息
if(str.equals("exit"))
{
break;
}
System.out.println(str);
sendToClient(l,str);//把服务器消息逐条发送到想要的客户端去
}
} catch (IOException e) {}
finally
{
try {
us.getBr().close();//关闭服务器输入流
us.getSocket();//关闭客户端线程
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
public void sendToClient(int id2, String str) {
for(user us1:list)
{
if(us1.getId()==id2)//如果想要到达的线程号在线程集合里，即id相同,
{
try {
PrintWriter pw=us1.getPr();//服务器起消息到客户端
pw.println(str);
pw.flush();
}catch (Exception e) {
// TODO: handle exception
}
}
}
}
}
