摘要：這里只讀數(shù)據(jù)，未作任何處理讀完成這里我根據(jù)返回值來拋出異常，使得下面的語句塊捕捉并關(guān)閉連接，也可以不拋出異常，直接在里處理。

我這篇文章想講的是編程時如何正確關(guān)閉tcp連接。
首先給出一個網(wǎng)絡(luò)上絕大部分的java nio代碼示例：
服務(wù)端：
1首先實例化一個多路I/O復(fù)用器Selector
2然后實例化一個ServerSocketChannel
3ServerSocketChannel注冊為非阻塞（channel.configureBlocking(false);）
4ServerSocketChannel注冊到Selector，并監(jiān)聽連接事件（serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);）
5Selector開始輪詢，如果監(jiān)聽到了isAcceptable()事件，就建立一個連接，如果監(jiān)聽到了isReadable()事件，就讀數(shù)據(jù)。
6處理完或者在處理每個事件之前將SelectionKey移除出Selector.selectedKeys()
代碼:

package qiuqi.main;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.*;
import java.util.Iterator;

public class NioServer {
    public static void main(String[] args) throws IOException {
        startServer();
    }

    static void startServer() throws IOException {

        Selector selector = Selector.open();
        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
        serverSocketChannel.bind(new InetSocketAddress(999));
        serverSocketChannel.configureBlocking(false);
        serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
        while (selector.select() > 0) {
            Iterator iterator = selector.selectedKeys().iterator();
            while (iterator.hasNext()) {
                SelectionKey sk = iterator.next();
                iterator.remove();

                if (sk.isAcceptable()) {
                    SocketChannel channel = serverSocketChannel.accept();
                    channel.configureBlocking(false);
                    channel.register(selector, SelectionKey.OP_READ);

                } else if (sk.isReadable()) {
                    System.out.println("讀事件!!!");
                    SocketChannel channel = (SocketChannel) sk.channel();
                    try {
                        ByteBuffer byteBuffer = ByteBuffer.allocate(200);
                        //這里只讀數(shù)據(jù)，未作任何處理
                        channel.read(byteBuffer);
          
                    } catch (IOException e) {
                        //手動關(guān)閉channel
                        System.out.println(e.getMessage());
                        sk.cancel();
                        if (channel != null)
                            channel.close();
                    }
                }


            }
        }
    }
}

還有說明一下，為什么在if (sk.isReadable()){}這個里面加上異常捕捉，因為可能讀數(shù)據(jù)的時候客戶端突然斷掉，如果不捕捉這個異常，將會導(dǎo)致整個程序結(jié)束。
而客戶端如果使用NIO編程，那么和服務(wù)端很像，然鵝，我們并不需要使用NIO編程，因為這里我想講的問題和NIO或是普通IO無關(guān)，在我想講的問題上，他倆是一樣的，那么我就用普通socket編程來講解，因為這個好寫:)。

直接給代碼如下：

package qiuqi.main;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.Socket;

public class TraditionalSocketClient {

    public static void main(String[] args) throws IOException {

        startClient();
    }
    static void startClient() throws IOException {
        Socket socket = new Socket();
        socket.connect(new InetSocketAddress(999));
        socket.getOutputStream().write(new byte[100]);
        //要注意這個close方法，這是正常關(guān)閉socket的方法
        //也是導(dǎo)致這個錯誤的根源
        socket.close();
    }
}

我們運行客戶端和服務(wù)端的代碼，輸出的結(jié)果是:
讀事件!!!
讀事件!!!
讀事件!!!
讀事件!!!
讀事件!!!
讀事件!!!
....
讀事件!!!
讀事件!!!
無限個讀事件!!!
why？？？
客戶端正常關(guān)閉，然后顯然客戶端不可能再給服務(wù)端發(fā)送任何數(shù)據(jù)了，服務(wù)端怎么可能還有讀響應(yīng)呢？
我們現(xiàn)在把客戶端代碼的最后一行socket.close();這個去掉，再運行一次！輸出結(jié)果是：
讀事件!!!
讀事件!!!
遠程主機強迫關(guān)閉了一個現(xiàn)有的連接。

然后。。。就正常了(當然代碼里會有異常提示的)，這里的正常指的是不會輸出多余的讀事件!!!了。
這又是怎么回事？
我們知道如果去掉socket.close();那么客戶端是非正常關(guān)閉，服務(wù)端這邊會引發(fā)IOException。
引發(fā)完IOExpection之后，我們的程序在catch{}語句塊中手動關(guān)閉了channel。

既然非正常關(guān)閉會引發(fā)異常，那么正常關(guān)閉呢？什么都不引發(fā)？但是這樣服務(wù)端怎么知道客戶端已經(jīng)關(guān)閉了呢？
顯然服務(wù)端會收到客戶端的關(guān)閉信號(可讀數(shù)據(jù))，而網(wǎng)絡(luò)上絕大多數(shù)代碼并沒有根據(jù)這個關(guān)閉信號來結(jié)束channel。
那么關(guān)閉信號是什么？

channel.read(byteBuffer);

這個語句是有返回值的，大多數(shù)情況是返回一個大于等于0的值，表示將多少數(shù)據(jù)讀入byteBuffer緩沖區(qū)。
然鵝，當客戶端正常斷開連接的時候，它就會返回-1。雖然這個斷開連接信號也是可讀數(shù)據(jù)(會使得isReadable()為true)，但是
這個信號無法被讀入byteBuffer，也就是說一旦返回-1，那么無論再繼續(xù)讀多少次都是-1，并且會引發(fā)可讀事件isReadable()。
因此，這樣寫問題就能得到解決，下面的代碼在try語句塊里。

                    
            SocketChannel channel = (SocketChannel) sk.channel();
            try {
                ByteBuffer byteBuffer = ByteBuffer.allocate(200);
                int num;
                //這里只讀數(shù)據(jù)，未作任何處理
                num = channel.read(byteBuffer);
                if(num == -1)
                    throw new IOException("讀完成");

            } catch (IOException e) {
                System.out.println(e.getMessage());
                sk.cancel();
                if (channel != null)
                    channel.close();
            }

這里我根據(jù)返回值-1來拋出異常，使得下面的catch語句塊捕捉并關(guān)閉連接，也可以不拋出異常，直接在try{}里處理。
還要注意一點的是，假如說bytebuffer已經(jīng)滿了，也就是channel.read(byteBuffer)返回0，那么即使客戶端正常關(guān)閉，也無法收到-1。因此當bytebuffer滿的時候需要及時清空，或者一開始就開一個大一點的bytebuffer。