Boost ASIO中的拍卖

如何解决Boost ASIO中的拍卖

我正在使用Boost.Asio在C ++中实现拍卖系统。有一个集中的拍卖人（服务器）和一些连接的投标人（客户）。我以异步方式实现此功能，并且已经实现了投标人与拍卖人之间的基本通信（注册，查验，获取客户列表）。拍卖师的骨架代码如下：

class talkToBidder : public boost::enable_shared_from_this<talkToBidder>
{
// Code for sending and receiving messages,which works fine
};

void on_round_end()
{
  // Choose the best bid and message the winner
  
  if (!itemList.empty())
    timer_reset();
}

void timer_reset()
{
  // Send the item information to the bidders

  // When the round ends,call on_round_end()
  auction_timer.expires_from_Now(boost::posix_time::millisec(ROUND_TIME));
  auction_timer.async_wait(boost::bind(on_round_end));
}

void handle_accept(...)
{
  // Create new bidder...

  acceptor.async_accept(bidder->sock(),boost::bind(handle_accept,bidder,_1));
}


int main()
{
  // Create new bidder and handle accepting it
  talkToBidder::ptr bidder = talkToBidder::new_();
  acceptor.async_accept(bidder->sock(),_1));

  service.run();
}

我的问题是，在开始拍卖之前，我需要等待至少一个竞标者连接，因此，在使用service.run（）之前，我不能简单地调用timer_reset()。 Boost.Asio进行此操作的方法是什么？

解决方法

在异步协议设计中，它有助于绘制消息序列图。 Do include your timers。

现在，代码变得微不足道了。您到达消息应该启动您的计时器时启动计时器。是的，这正在使问题向前发展。这里的重点是，这不是Boost Asio编码问题。在您的情况下，该特定消息似乎是第一个竞标者的登录名，该实现是通过TCP连接（SYN/ACK）实现的，该连接映射到代码中的handle_accept。