关于网络超时处理~~~ 小弟有难~

Question

用SocketChannel, client.configureBlocking(true);然后这个socketchannel就是阻塞模式的，可以在其他线程中close它，阻塞的线程会收到一个exception.
package closesocket;/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2003</p>
 * <p>Company: </p>
 * @author not attributable
 * @version 1.0
 */
import java.nio.*;
import java.nio.channels.*;
import java.net.*;
import java.io.*;
import java.nio.channels.spi.*;
import java.nio.charset.*;
import java.lang.*;
import javax.swing.*;
import java.awt.event.*;
public class Client extends JFrame
{
  public SocketChannel client = null;
  public InetSocketAddress isa = null;
  public RecvThread rt = null;
  JButton jb=new JButton("close socket");
  public Client()
  {
    this.getContentPane().add(jb);
    jb.addActionListener(new ActionListener()
                         {
                           public void actionPerformed(ActionEvent e)
                               {
                                 try
                                 {
                                   client.close();
                                 }
                                 catch(Exception ioe)
                                 {
                                   ioe.printStackTrace();
                                 }
                               }
                         });
                         setSize(600,400);
setVisible(true);  }  public void makeConnection() {
    int result = 0;
    try {      client = SocketChannel.open();
      isa = new InetSocketAddress("127.0.0.1", 5555);
      client.connect(isa);
      client.configureBlocking(true);
      receiveMessage();
    }
    catch (UnknownHostException e) {
      e.printStackTrace();
    }
    catch (IOException e) {
      e.printStackTrace();
    }
    while ( (result = sendMessage()) != -1) {
    }    try {
      client.close();
      System.exit(0);
    }
    catch (IOException e) {
      e.printStackTrace();
    }
  }  public int sendMessage() {
    System.out.println("Inside SendMessage");
    BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
    String msg = null;
    ByteBuffer bytebuf = ByteBuffer.allocate(1024);
    int nBytes = 0;
    try {
      msg = in.readLine();
      System.out.println("msg is " + msg);
      bytebuf = ByteBuffer.wrap(msg.getBytes());
      nBytes = client.write(bytebuf);
      System.out.println("nBytes is " + nBytes);
      if (msg.equals("quit") || msg.equals("shutdown")) {
        System.out.println("time to stop the client");
        interruptThread();
        try {
          Thread.sleep(5000);
        }
        catch (Exception e) {
          e.printStackTrace();
        }
        client.close();
        return -1;
      }    }
    catch (IOException e) {
      e.printStackTrace();
    }
    System.out.println("Wrote " + nBytes + " bytes to the server");
    return nBytes;
  }  public void receiveMessage() {
    rt = new RecvThread("Receive THread", client);
    rt.start();
  }  public void interruptThread() {
    rt.val = false;
  }  public static void main(String args[]) {
    Client cl = new Client();
    cl.makeConnection();
  }  public class RecvThread
      extends Thread {
    public SocketChannel sc = null;
    public boolean val = true;    public RecvThread(String str, SocketChannel client) {
      super(str);
      sc = client;
    }    public void run() {      System.out.println("Inside receivemsg");
      int nBytes = 0;
      ByteBuffer buf = ByteBuffer.allocate(2048);
      try {
        while (val) {
          while ( (nBytes = nBytes = client.read(buf)) > 0) {
            buf.flip();
            Charset charset = Charset.forName("us-ascii");
            CharsetDecoder decoder = charset.newDecoder();
            CharBuffer charBuffer = decoder.decode(buf);
            String result = charBuffer.toString();
            System.out.println(result);
            buf.flip();
          }
        }
      }
      catch (IOException e) {
        e.printStackTrace();
      }
      System.out.println(this.getClass().getName()+" stopped");
    }
  }
}

Answer 1

package closesocket;/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2003</p>
 * <p>Company: </p>
 * @author not attributable
 * @version 1.0
 */
import java.io.*;
import java.net.*;public class SockServerExam
{
        int portnum = 5555;
        public static void main(String args[])
        {
                new SockServerExam().work();
        }
        void work()
        {
                try
                {
                        ServerSocket server_socket=new ServerSocket(portnum);
                        System.out.println("listen on "+portnum);
                        while(true)
                        {
                                Socket socket = server_socket.accept();
                                System.out.println("New connection accepted " +
                                           socket.getInetAddress() +
                                           ":" + socket.getPort());
                                        RequestHandler rh = new RequestHandler(socket);
                                        Thread th = new Thread(rh);
                                        th.start();                        }
                }
                catch(IOException eio)
                {
                        eio.printStackTrace();
                }        }}
class RequestHandler implements Runnable
{
        Socket conn;
        InputStream input;
    OutputStream output;
    BufferedReader br;
    byte[] buf;
        public RequestHandler(Socket s)
        {
                try
                {
                        conn=s;
                        this.input = conn.getInputStream();
                        this.output = conn.getOutputStream();
                        buf = new byte[256];
                }
                catch(Exception e)
                {
                        e.printStackTrace();
                }
        }
        public void run()
        {
                int receive_count=0;
                int readcount = 1;
                try
                {
                        while(readcount>0)
                        {
                                readcount=input.read(buf);
                                System.out.println("received num:"+readcount);
                                if(readcount>0)
                                        receive_count+=readcount;
                        }
                        System.out.println("connection accepted " +
                                           conn.getInetAddress() +
                                           ":" + conn.getPort()+ " received bytes:" + receive_count);
                        input.close();
                        output.close();
                        conn.close();
                }
                catch(Exception e)
                {
                        e.printStackTrace();
                }        }
}