使用Boost-Asio同时支持服务器和客户端

Question

我是一名57岁的AspNet程序员。因为我是唯一一个在一开始使用C ++的人，我的老板要求我为一个需要具有非常特殊特征的通信代理的客户服务。它可以作为守护进程在多个平台上运行，并且有时既是客户端又是服务器。我知道的还不够多，但我必须解决这个问题，并在Boost / Asio库中找到一个机会。

我是Boost-Asio的新手，在阅读文档时，我创建了一个服务器和一个TCP套接字客户端，它们可以完美地、双向地、全双工地交换消息。

我读了几篇帖子，他们问我想要的东西，但所有的答案都是全双工的，好像这意味着在同一个程序中有一个客户端和一个服务器。但事实并非如此。全双工的定义是指从同一连接写入和读取的能力，默认情况下，每个TCP连接都是全双工的。

我需要使两个程序可以接受对方发起的连接。这两个程序之间不会有永久的连接。有时它们中的一个会请求连接，而另一个则会发出此请求，两者都需要进行侦听、接受连接、交换一些消息并终止连接，直到发出新的请求。

我所做的服务器似乎在侦听端口以查看是否有连接进入的过程中卡住了，并且我无法继续该过程以能够创建套接字并请求与其他程序的连接。我需要线程，但我对它们的了解还不够。

有可能吗？

正如我所说的，我是Boost / Asio的新手，我试着阅读了一些关于线程和协程的文档。然后我将客户端代码放在一种方法中，将服务器放在另一种方法中。

int main(int argc, char* argv[])
{
    try
    {
        boost::thread t1(&server_agent);
        boost::thread t2(&client_agent);

        // wait
        t1.join();
        t2.join();   
        return 0;       
    }
    catch (std::exception& e)
    {
        std::cerr << "Exception: " << e.what() << "\n";
    }    
    return 0;
}

和两个协程：

void client_agent() {
    parameters param;
    param.load();

    boost::asio::io_service io_service1;
    tcp::resolver resolver(io_service1);
    char port[5];
    _itoa(param.getNrPortaServComunic(), port, 10);
    auto endpoint_iterator = resolver.resolve({ param.getIPServComunicPrincipal(), port });
    std::list<client> clients;
    client c(io_service1, endpoint_iterator, param);

    while (true)
    {
        BOOL enviada = FALSE;
        while (true) {
            if (!enviada) {
                std::cout << "sending a message\n";
                int nr = 110;
                message msg(nr, param);
                c.write(msg);
                enviada = TRUE;
            }
        }
    }

    c.close();
}

void server_agent() {

    parameters param;
    param.load();

    boost::asio::io_service io_service1;
    std::list<server> servers;
    tcp::endpoint endpoint(tcp::v4(), param.getNrPortaAgenteServ());
    servers.emplace_back(io_service1, endpoint);
    io_service1.run();
}

我使用一个端口连接到客户端端点，另一个端口连接到服务器端点。这是正确的吗？必需的？

它开始看起来像是要工作了。每个方法都是并发运行的，但是我在io_service1.run ( server_agent方法的最后一行)得到了一个线程分配错误：

boost::exception_detail::clone_impl >在内存位置0x0118C61C。

有什么建议吗？

Answer 1

您正在描述一个UDP客户端/服务器应用程序。但是你的实现一定会失败。可以将asio服务器或客户端视为始终在单个线程中运行。

下面的代码只是为了让你有个概念。我还没有尝试编译它。客户端非常类似，但可能需要一个传输缓冲区，这显然取决于应用程序。

这是一个简短的版本，所以你明白了。在最后一个应用程序中，您可能希望添加接收超时等内容。同样的原则也适用于TCP服务器，增加了async_listen调用。连接的套接字可以存储在shared_ptr中，并被lambdas捕获，几乎可以神奇地销毁。

服务器基本上是一样的，除了没有持续的读取。如果在同一进程中同时运行服务器和客户机，则由于服务器的原因，您可以依赖run()进行循环，但如果不是这样，则必须为每个连接调用run()。run()将在交换结束时退出。

using namespace boost::asio;  // Or whichever way you like to shorten names

class Server
{
  public:
    Server(io_service& ios) : ios_(ios) {}

    void Start()
    {
      //  create socket
      //  Start listening
      Read();
    }

    void Read()
    {
        rxBuffer.resize(1024)
        s_.async_receive_from(
            buffer(rxBuffer),
            remoteEndpoint_,
            [this](error_code ec, size_t n)
        {
            OnReceive(ec, n);  // could be virtual, if done this way
        });
    }

    void OnReceive(error_code ec, size_t n)
    {
        rxBuffer_.resize(n);
        if (ec)
        {
          // error ... stops listen loop
          return;
        }

        // grab data, put in txBuffer_
        Read();
        s_.async_send_to(
            buffer(txBuffer_),
            remoteEndpoint_,
            [this, msg](error_code ec, size_t n)
        {
            OnTransmitDone(ec, n);
        });
    }

  void OnTransmitDone(error_code ec, size_t n)
  {
     // check for error?
     txBuffer_.clear();
  }

  protected:
    io_service& ios_;
    ip::udp::socket s_;   
    ip::udp::endpoint remoteEndpoint_;  // the other's address/port
    std::vector<char> rxBuffer_;        // could be any data type you like
    std::vector<char> txBuffer_;        // idem  All access is in one thread, so only 
                                        // one needed for simple ask/respond ops.
};

int main()
{
  io_service ios;
  Server server(ios);    // could have both server and client run on same thread
                         // on same io service this way.

  Server.Start();

  ios_run();
  // or std::thread ioThread([&](){ ios_.run(); });
  return 0;
}