6

以下は、boost asio を使用したソケット サーバーのサンプル コードです。

このサーバーは、クライアントが接続するのをポート 10001 で待機します。いずれかのクライアントが接続すると、スレッドを開始してそのクライアントから読み取り、別のクライアントを待ちます。しかし、クライアントがサーバーソケットを切断するとどうなりますかmy_socket->close()?

また、新しいクライアントがサーバーに接続しようとすると、クラッシュします。

g++ (Ubuntu 4.4.3-4ubuntu5.1) 4.4.3を使用しています 

#include <ctime>
#include <iostream>
#include <string>
#include <boost/asio.hpp>
#include <sys/socket.h>
#include <unistd.h>
#include <string>
#include <boost/bind.hpp>
#include <boost/thread.hpp>
#include <boost/date_time.hpp>

using namespace std;
using boost::asio::ip::tcp;

void run(boost::shared_ptr<tcp::socket> my_socket)
{
    while (1)
    {
        char buf[128];
        boost::system::error_code error;

        size_t len = my_socket->read_some(boost::asio::buffer(buf, 128), error);
        std::cout << "len : " << len << std::endl;

        if (error == boost::asio::error::eof)
        {
            cout << "\t(boost::asio::error::eof)" << endl;
            if (my_socket->is_open())
            {
                boost::system::error_code ec;
                cout << "\tSocket closing" << endl;
                my_socket->shutdown(boost::asio::ip::tcp::socket::shutdown_both, ec);
                cout << "\tShutdown " << ec.message() << endl;
//                cout << "normal close : " << ::close(my_socket->native_handle()) << endl;
                my_socket->close(ec);
                cout << "\tSocket closed" << endl;
            }
            break; // Connection closed cleanly by peer.
        }
        else if (error)
        {
            std::cout << "Exception : " << error.message() << std::endl;
            break;
        }
        else
        {
            for (unsigned int i = 0; i < len; i++)
                printf("%02x ", buf[i] & 0xFF);
            printf("\n");
        }
    }
}

int main()
{
    const int S = 1000;
    vector<boost::shared_ptr<boost::thread> > arr_thr(S);

    try
    {
        for (uint32_t i = 0;; i++)
        {
            boost::asio::io_service io_service;

            tcp::endpoint endpoint(tcp::v6(), 10001);

            boost::shared_ptr<tcp::socket> my_socket(new tcp::socket(io_service));
            tcp::endpoint end_type;

            tcp::acceptor acceptor(io_service, endpoint);

            std::cout << "before accept" << endl;
            acceptor.accept(*my_socket, end_type);

            std::cout << "connected... hdl : " << my_socket->native_handle() << std::endl;

            boost::asio::ip::address addr = end_type.address();
            std::string sClientIp = addr.to_string();

            std::cout << "\tclient IP : " << sClientIp << std::endl;
            arr_thr[i] = boost::shared_ptr<boost::thread>(new boost::thread(&run, my_socket));
        }
    } catch (std::exception& e)
    {
        std::cerr << e.what() << std::endl;
    }

    return 0;
}
4

1 に答える 1

11

スレッドを開始した後run、メインの for ループが再び開始され、ローカルio_service変数が破棄されて再初期化されますが、ソケットの次のイベントは古い io_service オブジェクトを引き続き想定し、クラッシュにつながります。

のインスタンスを 1 つだけ使用する必要がありますio_service。

また、boost::asio が提供する や などの非同期関数を確認する必要がありますasync_accept 。async_readたとえば、次の例を参照してください: http://www.boost.org/doc/libs/1_52_0/doc/html/boost_asio/example /chat/chat_server.cpp

于 2013-01-11T08:33:03.497 に答える