클라이언트별 아웃바운드 대기열이 Boost Asio에서 Async_write 인터리빙을 어떻게 해결할 수 있습니까?

boost asio의 비동기 쓰기 및 클라이언트 상호 작용

boost asio를 사용하는 비동기 프로그래밍에서는 동시 클라이언트 상호 작용을 관리하는 것이 어려울 수 있습니다. 특히, 여러 클라이언트가 메시지를 빠르게 보낼 때 async_write 호출의 인터리빙이 발생할 수 있습니다.

문제: 비동기 쓰기 인터리빙

클라이언트 A가 클라이언트에게 메시지를 보내는 시나리오를 생각해 보세요. B. 서버는 이러한 메시지를 비동기식으로 처리하여 지정된 데이터 양을 읽고 클라이언트 A로부터 추가 데이터를 기다립니다. 정보가 처리되면 서버는 클라이언트 B에 응답을 보냅니다. async_write를 통해.

그러나 클라이언트 A가 빠른 속도로 메시지를 보내는 경우 이전 메시지에 대한 완료 핸들러가 호출되기 전에 이러한 메시지에 대한 async_write 작업이 인터리브될 수 있습니다.

A 해결 방법: 클라이언트별 아웃바운드 대기열

이 문제를 해결하려면 각 클라이언트에 대해 나가는 대기열 구현을 고려하십시오. 고객. async_write 완료 핸들러에서 큐 크기를 확인하여 서버는 추가 메시지를 보낼 수 있는지 확인할 수 있습니다. 그렇다면 또 다른 async_write 작업이 트리거됩니다.

코드 예

다음 코드 조각은 보낼 편지함 대기열을 사용하여 가능한 구현을 보여줍니다.

class Connection {
public:
    ...
private:
    void writeImpl(const std::string& message) {
        _outbox.push_back(message);
        if (_outbox.size() > 1) {
            // Outstanding async_write
            return;
        }
        this->write();
    }

    void write() {
        ... // Asynchronous write operation
    }

    void writeHandler(const boost::system::error_code& error, const size_t bytesTransferred) {
        _outbox.pop_front();
        if (error) {
            // Handle error
            ...
        }
        if (!_outbox.empty()) {
            // More messages to send
            this->write();
        }
    }

private:
    typedef std::deque<std::string> Outbox;

private:
    boost::asio::io_service& _io_service;
    boost::asio::io_service::strand _strand;
    boost::asio::ip::tcp::socket _socket;
    Outbox _outbox;
};

열쇠 포인트

• boost::asio::io_service::strand는 클라이언트별 보낼 편지함 대기열에 대한 동시 액세스를 보호합니다.
• write() 메서드는 writeImpl() 핸들러는 공개이기 때문입니다.

클라이언트별 발신 구현 대기열을 사용하면 async_write 호출의 인터리브를 효과적으로 방지하여 메시지가 의도한 순서대로 처리되도록 할 수 있습니다.

위 내용은 클라이언트별 아웃바운드 대기열이 Boost Asio에서 Async_write 인터리빙을 어떻게 해결할 수 있습니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!