/**

　　* 客户端线程获取控制台输入消息

　　*/

　　static class Sender implements Runnable {

　　private Socket socket;

　　public Sender(Socket socket) {

　　this.socket = socket;

　　}

　　public void run() {

　　try {

　　BufferedReader br = new BufferedReader(new InputStreamReader(

　　System.in));

　　PrintWriter pw = new PrintWriter(socket.getOutputStream(), true);

　　String msg;

　　while (true) {

　　msg = br.readLine();

　　pw.println(msg);

　　if (msg.trim().equals("bye")) {

　　pw.close();

　　br.close();

　　exec.shutdownNow();

　　break;

　　}

　　}

　　} catch (Exception e) {

　　e.printStackTrace();

　　}

　　}

　　}

　　}