• <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 陳碩 閱讀(3381) 評論(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
            你可以先單步跟蹤一下。  回復  更多評論   

            <2025年5月>
            27282930123
            45678910
            11121314151617
            18192021222324
            25262728293031
            1234567

            導航

            統計

            常用鏈接

            隨筆分類

            隨筆檔案

            相冊

            搜索

            最新評論

            閱讀排行榜

            評論排行榜

            品成人欧美大片久久国产欧美| 99久久精品费精品国产一区二区 | 婷婷五月深深久久精品| 午夜精品久久久久久久| 久久精品国产精品国产精品污| 久久久久国色AV免费观看| 亚洲va中文字幕无码久久不卡| 狠狠色丁香久久综合五月| 狠狠色丁香久久婷婷综合图片| 精品久久久久久亚洲精品 | 精品永久久福利一区二区| 一本久久久久久久| 麻豆亚洲AV永久无码精品久久 | 中文成人久久久久影院免费观看| 久久av无码专区亚洲av桃花岛| 韩国三级中文字幕hd久久精品| 久久久一本精品99久久精品66| 亚洲国产成人久久综合一区77 | 久久婷婷五月综合国产尤物app| 成人久久综合网| 亚洲精品无码久久千人斩| 亚洲日本久久久午夜精品| 久久99精品久久久久久齐齐| aaa级精品久久久国产片| 人人妻久久人人澡人人爽人人精品| segui久久国产精品| 久久精品一区二区| 国产欧美久久一区二区| 一本一本久久a久久综合精品蜜桃| 久久久精品国产Sm最大网站| 国产精品嫩草影院久久| 91超碰碰碰碰久久久久久综合 | 久久久久亚洲AV无码专区桃色 | 国内精品久久久久久久coent| 久久夜色精品国产欧美乱| 亚洲国产精品无码久久一线| 日韩精品久久无码中文字幕| 人人狠狠综合久久88成人| 久久精品亚洲日本波多野结衣| 精品永久久福利一区二区| 午夜不卡888久久|