c++ - 服务器和客户端同时使用 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 中，并被 lambda 捕获，几乎会神奇地销毁。

服务器基本相同，只是没有持续读取。如果在同一个进程中同时运行服务器和客户端，您可以依赖 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;
}