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

我這篇文章想講的是編程時(shí)如何正確關(guān)閉tcp連接。
首先給出一個(gè)網(wǎng)絡(luò)上絕大部分的java nio代碼示例：
服務(wù)端：
1首先實(shí)例化一個(gè)多路I/O復(fù)用器Selector
2然后實(shí)例化一個(gè)ServerSocketChannel
3ServerSocketChannel注冊(cè)為非阻塞（channel.configureBlocking(false);）
4ServerSocketChannel注冊(cè)到Selector，并監(jiān)聽連接事件（serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);）
5Selector開始輪詢，如果監(jiān)聽到了isAcceptable()事件，就建立一個(gè)連接，如果監(jiān)聽到了isReadable()事件，就讀數(shù)據(jù)。
6處理完或者在處理每個(gè)事件之前將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) {
                        //手動(dòng)關(guān)閉channel
                        System.out.println(e.getMessage());
                        sk.cancel();
                        if (channel != null)
                            channel.close();
                    }
                }


            }
        }
    }
}

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

直接給代碼如下：

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]);
        //要注意這個(gè)close方法，這是正常關(guān)閉socket的方法
        //也是導(dǎo)致這個(gè)錯(cuò)誤的根源
        socket.close();
    }
}

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

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

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

channel.read(byteBuffer);

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

                    
            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來(lái)拋出異常，使得下面的catch語(yǔ)句塊捕捉并關(guān)閉連接，也可以不拋出異常，直接在try{}里處理。
還要注意一點(diǎn)的是，假如說(shuō)bytebuffer已經(jīng)滿了，也就是channel.read(byteBuffer)返回0，那么即使客戶端正常關(guān)閉，也無(wú)法收到-1。因此當(dāng)bytebuffer滿的時(shí)候需要及時(shí)清空，或者一開始就開一個(gè)大一點(diǎn)的bytebuffer。