• <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

            導航

            統計

            常用鏈接

            隨筆分類

            隨筆檔案

            相冊

            搜索

            最新評論

            閱讀排行榜

            評論排行榜

            亚洲午夜久久久久久久久久| 91久久精品电影| 久久亚洲精品无码AV红樱桃| 久久夜色精品国产噜噜噜亚洲AV| 亚洲va久久久噜噜噜久久狠狠 | 国产精品毛片久久久久久久 | 久久精品a亚洲国产v高清不卡| 国产精品福利一区二区久久| 久久精品国产亚洲Aⅴ香蕉| 久久天天躁狠狠躁夜夜avapp| 久久99久久99精品免视看动漫| 国产精品久久久久久吹潮| 国产精品99久久久久久www| 亚洲国产天堂久久久久久| 久久香蕉国产线看观看精品yw| 精品久久综合1区2区3区激情| AV无码久久久久不卡蜜桃| 久久午夜无码鲁丝片午夜精品| 色偷偷偷久久伊人大杳蕉| 欧美大战日韩91综合一区婷婷久久青草| 久久久久久精品无码人妻| 国产精品无码久久久久| 久久国产精品无码HDAV| 伊人久久大香线蕉AV一区二区| 99久久国产综合精品成人影院| 无码国内精品久久人妻| 老男人久久青草av高清| 亚洲精品午夜国产VA久久成人| 久久99国产精品成人欧美| 国产美女久久精品香蕉69| 久久中文字幕人妻丝袜| 久久综合色区| 热综合一本伊人久久精品| 91精品国产91久久| 亚洲国产精品热久久| 欧美久久精品一级c片片| 久久99久久99小草精品免视看| 成人综合伊人五月婷久久| 久久人人爽人人爽人人片av高请| 色欲综合久久躁天天躁蜜桃| 精品人妻伦九区久久AAA片69|