1

私はこれを書いた：

#include <vector>
#include <iostream>
#include <sstream>
#include <boost/asio.hpp>
#include <tr1/memory>
#include <boost/bind.hpp>
#include <stdint.h>

    using namespace boost::asio;
    using namespace boost::asio::ip;

class tcpServer{
public:

    class connection{

        tcp::socket socketConnection;

        enum {CONNECTED, CLOSED, CREATED}STATUS;

    public:

        uint32_t addr;
        uint16_t port;

        connection(boost::asio::io_service &ioServ): socketConnection(ioServ){
            STATUS = CREATED;
        }

        void setConnected(bool is) {
            if (is) {
                STATUS = CONNECTED;
                port = socketConnection.remote_endpoint().port();
                addr
                        = socketConnection.remote_endpoint().address().to_v4().to_ulong();
                std::cout << "Connected to "
                        << socketConnection.remote_endpoint().address().to_v4().to_string()
                        << " : " << socketConnection.remote_endpoint().port()
                        << "\n";
            }
        }

        tcp::socket& getSocket(){
            return socketConnection;
        }
    };

    typedef std::tr1::shared_ptr<tcpServer::connection> CONNSHPTR;

private:
    boost::asio::io_service io_service;
    tcp::acceptor tcpAcceptor;
    int localPort;

    void accept(CONNSHPTR connection, const boost::system::error_code& error){
        connection->setConnected(true);
        std::cout.flush();
    }

    void startAccept(){
        CONNSHPTR newConn(new connection(tcpAcceptor.io_service()));

        tcpAcceptor.async_accept(newConn->getSocket(), boost::bind(
                        &tcpServer::accept, this, newConn,
                        boost::asio::placeholders::error));
    }

public:



    tcpServer(int localPort) :
        io_service(), tcpAcceptor(io_service, tcp::endpoint(tcp::v4(),
                localPort)) {
        this->localPort = localPort;

    }

    void start(){
        io_service.run();
        startAccept();
    }
};

int main(int argc, char** argv) {
try{
    tcpServer tp(1033);
    tp.start();
}catch(std::exception &e){
    std::cout << e.what();
}
    sleep(5000);
    return 0;
}

次に、ターミナルに移動し、telnet localhost 1033と記述しました。Telnetは接続されていると言いますが、ハンドラーは呼び出されません（gdbはブレークポイントに到達せず、coutSは効果がありません）。プログラムを強制終了すると、telnetは接続が閉じられたと表示します。接続が安定しているように見えますが、なぜハンドラーが呼び出されないのですか？

編集：

奇妙なことに、start（）でstartAccept（）の後にioservice.run（）を配置すると機能します。なぜこれが機能するのか疑問に思います...実際、後でstart acceptを再度呼び出しても機能しますが、それはioservice.run（）呼び出しの後であります...。

4

1 に答える 1

5

asioドキュメントから：

run（）関数は、すべての作業が終了してディスパッチするハンドラーがなくなるまで、またはio_serviceが停止するまでブロックします。

startAccept（）の前にrun（）が呼び出されると、まだ何もすることがないため、すぐに戻ります。次にstartAccept（）が呼び出され、ソケットが受け入れモードになります（つまり、サーバーでtelnetを実行すると、ネットワークサブシステムがそれを受け入れます）が、run（）は後で呼び出されないため、acceptハンドラーは呼び出されません。

于 2009-12-15T15:15:57.290 に答える