クライアントごとの送信キューは、Boost Asio の Async_write インターリーブをどのように解決できますか?

boost asio での非同期書き込みとクライアント インタラクション

boost asio を使用した非同期プログラミングでは、同時クライアント インタラクションの管理が課題となる可能性があります。具体的には、複数のクライアントがメッセージを急速に送信するときに、async_write 呼び出しのインターリーブが発生する可能性があります。

問題: 非同期書き込みのインターリーブ

クライアント A がクライアントにメッセージを送信するシナリオを考えてみましょう。 B. サーバーはこれらのメッセージを非同期で処理し、指定されたデータ量を読み取り、クライアント A からのさらなるデータを待ちます。情報が処理されると、サーバーはasync_write を介してクライアント B に応答を送信します。

ただし、クライアント A が速いペースでメッセージを送信する場合、前のメッセージの完了ハンドラーが呼び出される前に、これらのメッセージに対する async_write 操作がインターリーブされる可能性があります。

解決策: クライアントごとの送信キュー

これに対処するにはこの問題が発生した場合は、クライアントごとに送信キューを実装することを検討してください。 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::struct は、クライアントごとの送信ボックス キューへの同時アクセスを保護します。
• write() メソッドはパブリックであるため、writeImpl() ハンドラーから呼び出されます。

クライアントごとの送信キューを実装することで、async_write 呼び出しのインターリーブを効果的に防止し、メッセージが意図したとおりに処理されるようにすることができます。注文します。

以上がクライアントごとの送信キューは、Boost Asio の Async_write インターリーブをどのように解決できますか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。