Làm thế nào để phát hiện khi một ổ cắm tăng tcp ngắt kết nối

Question

Giả sử tôi có một ổ cắm:

std::shared_ptr<tcp::socket> socket(new tcp::socket(acceptor.get_io_service())); 
acceptor.async_accept(*socket, std::bind(handleAccept, this, std::placeholders::_1, socket, std::ref(acceptor))); 

Và tôi lưu trữ một weak_ptr để các ổ cắm cho biết trong một container. Tôi cần điều này vì tôi muốn cho phép khách hàng yêu cầu danh sách các ứng dụng khách khác, vì vậy họ có thể gửi tin nhắn cho nhau.

clients_.insert(socket); // pseudocode 

Sau đó, tôi chạy một số hoạt động async

socket->async_receive(boost::asio::buffer(&(*header), sizeof(Header)) 
    , 0 
    , std::bind(handleReceiveHeader, this, std::placeholders::_1, std::placeholders::_2, header, socket)); 

Làm thế nào để phát hiện khi kết nối được đóng để tôi có thể loại bỏ ổ cắm của tôi từ container?

clients_.erase(socket); // pseudocode 

Answer 1

Một ổ cắm ngắt kết nối TCP thường được báo hiệu trong asio bởi một eof hoặc một connection_reset. Ví dụ.

void async_receive(boost::system::error_code const& error, 
        size_t bytes_transferred) 
    { 
    if ((boost::asio::error::eof == error) || 
     (boost::asio::error::connection_reset == error)) 
    { 
     // handle the disconnect. 
    } 
    else 
    { 
     // read the data 
    } 
    } 

Tôi sử dụng boost::signals2 để báo hiệu ngắt kết nối mặc dù bạn luôn có thể chuyển con trỏ đến hàm đến cấp ổ cắm của bạn và sau đó gọi.

Hãy cẩn thận về tuổi thọ ổ cắm và cuộc gọi lại của bạn, xem: boost-async-functions-and-shared-ptrs

Answer 2

Có rất nhiều lựa chọn, một số trong số đó là:

1. Như bạn lưu trữ weak_ptr trong container - nó sẽ không kéo dài tuổi thọ của ổ cắm, nên khi xử lý của bạn sẽ nhận được boost::asio::error::eof (hoặc bất kỳ) , nó sẽ không làm sao chép/di chuyển của shared_ptr, và ổ cắm sẽ bị xóa (nếu bạn không có bất kỳ người nào khác shared_ptr s với nó). Vì vậy, bạn có thể làm điều gì đó như: if(socket.expired()) clients_.erase(socket);

2. Kiểm tra mã lỗi trong trình xử lý của bạn - nó sẽ cho biết khi nào kết nối bị đóng. Sử dụng thông tin này - bạn có thể gọi clients_.erase từ bộ xử lý.

Could you give an example of #2?

Nó sẽ là một cái gì đó như:

socket->async_receive 
(
    boost::asio::buffer(&(*header), sizeof(Header)), 0, 
    [=, &clients_](const system::error_code& error, size_t bytes_transferred) 
    { 
     if(error) // or some specific code 
     { 
      clients_.erase(socket); // pseudocode 
     } 
     else 
     { 
      // continue, launch new operation, etc 
     } 
    } 
);