• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>

            陳碩的Blog

            為什么 muduo 的 shutdown() 沒有直接關閉 TCP 連接?

            陳碩 (giantchen_AT_gmail)

            Blog.csdn.net/Solstice

            Muduo 全系列文章列表: http://blog.csdn.net/Solstice/category/779646.aspx

             

            今天收到一位網友來信:

            在 simple 中的 daytime 示例中,服務端主動關閉時調用的是如下函數序列,這不是只是關閉了連接上的寫操作嗎,怎么是關閉了整個連接?

               1: void DaytimeServer::onConnection(const muduo::net::TcpConnectionPtr& conn)
               2: {
               3:   if (conn->connected())
               4:   {
               5:     conn->send(Timestamp::now().toFormattedString() + "\n");
               6:     conn->shutdown();
               7:   }
               8: }
               9:  
              10: void TcpConnection::shutdown()
              11: {
              12:   if (state_ == kConnected)
              13:   {
              14:     setState(kDisconnecting);
              15:     loop_->runInLoop(boost::bind(&TcpConnection::shutdownInLoop, this));
              16:   }
              17: }
              18:  
              19: void TcpConnection::shutdownInLoop()
              20: {
              21:   loop_->assertInLoopThread();
              22:   if (!channel_->isWriting())
              23:   {
              24:     // we are not writing
              25:     socket_->shutdownWrite();
              26:   }
              27: }
              28:  
              29: void Socket::shutdownWrite()
              30: {
              31:   sockets::shutdownWrite(sockfd_);
              32: }
              33:  
              34: void sockets::shutdownWrite(int sockfd)
              35: {
              36:   if (::shutdown(sockfd, SHUT_WR) < 0)
              37:   {
              38:     LOG_SYSERR << "sockets::shutdownWrite";
              39:   }
              40: }

            陳碩答復如下:

            Muduo TcpConnection 沒有提供 close,而只提供 shutdown ,這么做是為了收發數據的完整性。

            TCP 是一個全雙工協議,同一個文件描述符既可讀又可寫, shutdownWrite() 關閉了“寫”方向的連接,保留了“讀”方向,這稱為 TCP half-close。如果直接 close(socket_fd),那么 socket_fd 就不能讀或寫了。

            用 shutdown 而不用 close 的效果是,如果對方已經發送了數據,這些數據還“在路上”,那么 muduo 不會漏收這些數據。換句話說,muduo 在 TCP 這一層面解決了“當你打算關閉網絡連接的時候,如何得知對方有沒有發了一些數據而你還沒有收到?”這一問題。當然,這個問題也可以在上面的協議層解決,雙方商量好不再互發數據,就可以直接斷開連接。

            等于說 muduo 把“主動關閉連接”這件事情分成兩步來做,如果要主動關閉連接,它會先關本地“寫”端,等對方關閉之后,再關本地“讀”端。練習:閱讀代碼,回答“如果被動關閉連接,muduo 的行為如何?” 提示:muduo 在 read() 返回 0 的時候會回調 connection callback,這樣客戶代碼就知道對方斷開連接了。

            Muduo 這種關閉連接的方式對對方也有要求,那就是對方 read() 到 0 字節之后會主動關閉連接(無論 shutdownWrite() 還是 close()),一般的網絡程序都會這樣,不是什么問題。當然,這么做有一個潛在的安全漏洞,萬一對方故意不不關,那么 muduo 的連接就一直半開著,消耗系統資源。

            完整的流程是:我們發完了數據,于是 shutdownWrite,發送 TCP FIN 分節,對方會讀到 0 字節,然后對方通常會關閉連接,這樣 muduo 會讀到 0 字節,然后 muduo 關閉連接。(思考題:在 shutdown() 之后,muduo 回調 connection callback 的時間間隔大約是一個 round-trip time,為什么?)

            另外,如果有必要,對方可以在 read() 返回 0 之后繼續發送數據,這是直接利用了 half-close TCP 連接。muduo 會收到這些數據,通過 message callback 通知客戶代碼。

            那么 muduo 什么時候真正 close socket 呢?在 TcpConnection 對象析構的時候。TcpConnection 持有一個 Socket 對象,Socket 是一個 RAII handler,它的析構函數會 close(sockfd_)。這樣,如果發生 TcpConnection 對象泄漏,那么我們從 /proc/pid/fd/ 就能找到沒有關閉的文件描述符,便于查錯。

            muduo 在 read() 返回 0 的時候會回調 connection callback,然后把 TcpConnection 的引用計數減一,如果 TcpConnection 的引用計數降到零,它就會析構了。

            參考:

            《TCP/IP 詳解》第一卷第 18.5 節,TCP Half-Close。

            《UNIX 網絡編程》第一卷第三版第 6.6 節, shutdown() 函數。

            posted on 2011-02-25 21:30 陳碩 閱讀(3382) 評論(3)  編輯 收藏 引用 所屬分類: muduo

            評論

            # re: 為什么 muduo 的 shutdown() 沒有直接關閉 TCP 連接?[未登錄] 2011-02-27 12:59 vincent

            可能我問的很膚淺,當一段決定關閉TCP連接的時候,還去保證繼續可以接到一些信息的意義在哪,沒有上層邏輯,數據神馬用都沒有啊  回復  更多評論   

            # re: 為什么 muduo 的 shutdown() 沒有直接關閉 TCP 連接? 2014-03-19 18:16 lys86_1205

            如果套接字可寫的話
            void TcpConnection::shutdownInLoop()
            {
            loop_->assertInLoopThread();
            if (!channel_->isWriting())
            {
            // we are not writing
            socket_->shutdownWrite();
            }
            }
            你這個函數的意思是不關閉, 也就是不調用socket_->shutdownWrite();
            那豈不是沒有關閉寫?  回復  更多評論   

            # re: 為什么 muduo 的 shutdown() 沒有直接關閉 TCP 連接? 2014-04-15 02:33 陳碩

            @lys86_1205
            你可以先單步跟蹤一下。  回復  更多評論   

            <2012年1月>
            25262728293031
            1234567
            891011121314
            15161718192021
            22232425262728
            2930311234

            導航

            統計

            常用鏈接

            隨筆分類

            隨筆檔案

            相冊

            搜索

            最新評論

            閱讀排行榜

            評論排行榜

            久久久久久亚洲Av无码精品专口| 99久久精品免费看国产| 欧美激情精品久久久久久久九九九| 四虎国产精品免费久久久| 狠狠色丁香婷婷综合久久来来去| 久久综合成人网| 久久精品国产亚洲av日韩| 国产精品欧美亚洲韩国日本久久| 久久伊人精品青青草原日本| 色综合久久久久综合体桃花网| 久久久久四虎国产精品| 99久久这里只精品国产免费| 久久精品嫩草影院| 狠狠精品久久久无码中文字幕 | 国产视频久久| 日韩精品久久无码中文字幕| 国产精品激情综合久久| 欧洲精品久久久av无码电影| 青青草原综合久久大伊人导航| 久久精品人成免费| 久久久久亚洲AV无码观看| 日韩一区二区久久久久久| 漂亮人妻被黑人久久精品| 久久久久亚洲AV无码专区桃色| 久久99精品国产自在现线小黄鸭| 欧美粉嫩小泬久久久久久久| 久久精品成人免费看| 久久99精品久久久久久动态图| 香蕉久久夜色精品国产2020| 国内精品久久久久影院网站| 国内精品久久久久影院日本 | 少妇无套内谢久久久久| 99精品伊人久久久大香线蕉| 精品国产VA久久久久久久冰| 欧美亚洲国产精品久久高清| 亚洲欧美一级久久精品| 久久一区二区免费播放| 久久综合伊人77777| 思思久久99热免费精品6| 性做久久久久久久久| 亚洲国产精品无码久久青草|