while (true)//向客户端发送数据
{
try
{
pw.println(scanner.nextLine());
pw.flush();
}
catch (Exception e)
{
try
{
br.close();
pw.close();
socket.close();
}
catch (IOException e1)
{
e1.printStackTrace();
}
}
}
}
}
class ReadClientMessage extends Thread
{
BufferedReader bReader;
Socket socket;
{
this.bReader = br;
this.socket=s;
start();
}
public void run()
{
String str = "";
while (true)
{
try
{
str = bReader.readLine();
if (str.equals("q"))
{
bReader.close();
socket.close();
break;
}
}
catch (IOException e)
{
e.printStackTrace();
}
System.out.println("Client Message:" + str);
}
}
}
现在就可以实现多客户端和服务器端通信了 ,不过客户端和客户端的通信暂时还没有搞懂,还要继续去学习。