服务器和客户端同时使用BOOST-ASIO

Server and Client at same time with Boost-Asio

本文关键字:BOOST-ASIO 客户端 服务器      更新时间:2023-10-16

我是57岁的ASPNET程序员。因为我是唯一一开始就与C 一起工作的人,所以我的老板要求我为需要一个具有非常具体特征的通信代理的客户服务。它可以在多个平台上作为守护程序运行,并有时是客户端和服务器。我不太了解,但是我必须解决这个问题,并在Boost/asio库中找到了机会。

我是Boost-Asio的新手,并且阅读了我创建的服务器和TCP套接字客户端的文档,该客户端可以完美交换消息,并且双向,完整的双工。

我阅读了几篇文章,他们要求提供我想要的相同内容,但是所有答案都建议完整的双工,就像这意味着在同一程序中拥有客户端和服务器。事实并非如此。完整双工的定义是指从相同连接编写和读取的能力,默认情况下每个TCP连接都是完整的双工。

我需要制作两个程序可以接受另一个程序引发的连接。这两个程序之间将没有永久性的联系。有时,其中一个会要求建立连接,而在其他时候,另一个会提出此请求,两者都需要聆听,接受连接,交换一些消息并终止连接直到建立新请求。

我所做的服务器似乎陷入了聆听端口的过程中,以查看连接是否进入,我无法继续进行该过程以创建插座并请求与其他程序的连接。我需要线程,但我对它们了解不足。

有可能吗?

正如我所说,我是Boost/asio的新手,我试图遵循一些线程和coroutines的文档。然后,我将客户端代码放入一种方法中,将服务器放在另一种方法中。:

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;
}

和两个coroutines:

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 messagen";
                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。

任何建议?

您正在描述UDP客户端/服务器应用程序。但是您的实施注定会失败。想想在单个线程中运行的ASIO服务器或客户端。

以下代码只是为了使您有一个想法。我没有试图编译它。客户端非常相似,但可能需要发送缓冲区,这显然取决于应用。

这是一个缩短版本,因此您可以理解。在最终应用程序中,您想添加接收超时等。TCP服务器具有相同的原理,并带有添加的async_listen调用。连接的插座可以存储在shared_ptr中,并被兰伯达(Lambdas(捕获,几乎会神奇地破坏。

服务器基本上是相同的,除了没有持续的读数正在进行。如果在同一过程中同时运行服务器和客户端,则可以依靠运行((由于服务器而循环,但是如果没有,则必须为每个连接调用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;
}