0

ドメインソケット経由で接続を受信するサーバーを作成しようとしています。サーバーを起動すると、ファイルシステムにソケットが作成されていることがわかります。しかし、 socat経由で接続しようとするたびに、次のエラーが発生します。

2015/03/02 14:00:10 socat[62720] E connect(3, LEN=19 AF=1 "/var/tmp/rpc.sock", 19): Connection refused

これは私の Asio コードです (.cpp ファイルのみ)。記事のタイトルにも関わらず、私は Asio の Boost-free バージョンを使用していますが、それが問題になるとは思いません。

namespace myapp {

  DomainListener::DomainListener(const string& addr) : socket{this->service}, Listener{addr} {
    remove(this->address.c_str());
    stream_protocol::endpoint ep(this->address);
    stream_protocol::acceptor acceptor(this->service, ep);
    acceptor.async_accept(this->socket, ep, bind(&DomainListener::accept_callback, this, _1));
  }

  DomainListener::~DomainListener() {
    this->service.stop();
    remove(this->address.c_str());
  }

  void DomainListener::accept_callback(const error_code& ec) noexcept {
    this->socket.async_read_some(asio::buffer(this->data), bind(&DomainListener::read_data, this, _1, _2));
  }

  void DomainListener::read_data(const error_code& ec, size_t length) noexcept {
    //std::cerr << "AAA" << std::endl;
    //std::cerr << this->data[0] << std::endl;
    //std::cerr << "BBB" << std::endl;
  }

} 



Listener::Listener(const string& addr) : work{asio::io_service::work(this->service)} {
    this->address = addr;
  }

  void Listener::listen() {
    this->service.run();
  }

  Listener::~Listener() {
  }

これらのクラスを使用するコードではlisten()、接続のためにソケットのリッスンを開始するたびに呼び出します。

これをlibuvで動作させ、Asioに変更したのは、コードが読みやすくなると思ったからですが、ドキュメントが非常に曖昧であることがわかりました。

4

1 に答える 1

2

問題は、おそらく の寿命ですacceptor。

コンストラクターのacceptor自動変数ですDomainListener。DomainListenerコンストラクターが完了すると、がacceptor破棄され、アクセプターがクローズされ、async_accept操作などの未処理の操作が取り消されます。キャンセルされた操作には のエラー コードが提供され、asio::error::operation_aborted内での遅延呼び出しがスケジュールされますio_service。したがって、ドメイン ソケットへの接続を試みるときに、アクティブなリスナーが存在しない場合があります。IO オブジェクトの破棄の影響の詳細については、この回答を参照してください。

DomainListener::DomainListener(const string&) : /* ... */
{
  // ...
  stream_protocol::acceptor acceptor(...);
  acceptor.async_accept(..., bind(accept_callback, ...));
} // acceptor destroyed, and accept_callback likely cancelled

これを解決するにはacceptor、 のデータ メンバーにして、 の有効期間を延長することを検討してDomainListenerください。さらに、error_code提供された非同期操作を確認すると、非同期呼び出しチェーンをより深く理解できます。

Asio でドメイン ソケットを使用する完全な最小限の例を次に示します。

#include <cstdio>
#include <iostream>
#include <boost/array.hpp>
#include <boost/asio.hpp>
#include <boost/bind.hpp>

/// @brief server demonstrates using domain sockets to accept
///        and read from a connection.
class server
{
public:
  server(
    boost::asio::io_service& io_service,
    const std::string& file)
    : io_service_(io_service),
      acceptor_(io_service_, 
        boost::asio::local::stream_protocol::endpoint(file)),
      client_(io_service_)
  {
    std::cout << "start accepting connection" << std::endl;
    acceptor_.async_accept(client_,
      boost::bind(&server::handle_accept, this,
        boost::asio::placeholders::error));
  }

private:

  void handle_accept(const boost::system::error_code& error)
  {
    std::cout << "handle_accept: " << error.message() << std::endl;
    if (error) return;

    std::cout << "start reading" << std::endl;
    client_.async_read_some(boost::asio::buffer(buffer_),
      boost::bind(&server::handle_read, this,
        boost::asio::placeholders::error,
        boost::asio::placeholders::bytes_transferred));
  }

  void handle_read(
    const boost::system::error_code& error,
    std::size_t bytes_transferred)
  {
    std::cout << "handle_read: " << error.message() << std::endl;
    if (error) return;

    std::cout << "read: ";
    std::cout.write(buffer_.begin(), bytes_transferred);
    std::cout.flush();
  }

private:
  boost::asio::io_service& io_service_;
  boost::asio::local::stream_protocol::acceptor acceptor_;
  boost::asio::local::stream_protocol::socket client_;
  std::array<char, 1024> buffer_;
};

int main(int argc, char* argv[])
{
  if (argc != 2)
  {
    std::cerr << "Usage: <file>\n";
    return 1;
  }

  // Remove file on startup and exit.
  std::string file(argv[1]);
  struct file_remover
  {
    file_remover(std::string file): file_(file) { std::remove(file.c_str()); }
    ~file_remover() { std::remove(file_.c_str()); }
    std::string file_;
  } remover(file);

  // Create and run the server.
  boost::asio::io_service io_service;
  server s(io_service, file);
  io_service.run();
}

Coliru には socat がインストールされていないため、次のコマンドは OpenBSD netcat を使用して「asio domain socket example」をドメイン ソケットに書き込みます。

export SOCKFILE=$PWD/example.sock
./a.out $SOCKFILE &
sleep 1
echo "asio domain socket example" | nc -U $SOCKFILE

どの出力:

start accepting connection
handle_accept: Success
start reading
handle_read: Success
read: asio domain socket example
于 2015-03-02T16:56:12.767 に答える