如何将此Boost ASIO示例应用于我的应用程序

我建议在您的连接类中保持与套接字的所有通信，使其尽可能保持通用。

你想怎么做，你的选择几乎是无限的。我所做的是将我的"消息处理"类的shared_ptr传递给每个新连接，并像您一样创建一个会话，但我将每个连接的副本传递给会话和所有相关信息。因此，当有新消息传入时，每个单独的会话都可以通知程序，并且我可以在每个会话中存储任何我想要的东西。

当连接终止时，请注意通知会话，因为您现在将它存储在某个地方，而不仅仅是通过回调保持智能指针的活动。

typedef boost::shared_ptr<class Connection> connectionPtr;
void Server::handle_accept(sessionPtr new_connection, const boost::system::error_code& error)
{
if (!error)
{
   cout << "New connection detected." << endl;
   string sessionID = misc::generateSessionID();
   string IPaddress = new_connection->socket().remote_endpoint().address().to_string();
   mSessionManager_->AddSession(new_connection, IPaddress, sessionID);
   // session manager now has a copy of the connection and
   //  can reference this by the sessioNID or IPAddress
   new_connection->start();
   connectionPtr NEWER_CONNECTION(new Connection(_io_service, _loginList, _mMessageHandlerClass));
   cout << "Awaiting next connection..." << endl;
   acceptor_.async_accept(newer_session->socket(),
   boost::bind(&Server::handle_accept, this, NEWER_CONNECTION, 
              boost::asio::placeholders::error));
}
else
{
  new_connection.reset();
}

}

这里只是一个如何处理消息的示例。显然，totalbytesremaining需要从标题中提取，我没有包括在示例中。

void Session::handle_body(const boost::system::error_code& error, size_t bytes_transferred)
if(!error)
    {
        totalBytesRemaining -= bytes_transferred;
        if (totalBytesRemaining == 0)
            {
            if (incompleteToggle = true)
            {
                tempMessage+=string(readMsg.body());
                messageHandlerClass->Process(sessionID,tempMessage);
                tempMessage = "";
                tempMessageToggle = false;
            }
            else
            {
                tempMessage += string(readMsg.body());
                std::cout << "Incomplete receive:  This is our message So far.nn" << tempMessage << "n" << endl;
                tempMessageToggle = true;
            }
        }
    handle_message();
    }
else
{
    removeSession();
}

现在我可以从SessionManager类访问所有的session

void SessionManager::listConnectedIP()
{
    for (int x = 0; x < sessionBox.size(); x++)
    {
        cout << sessionBox[x]->IPaddress() << endl;
    }
}
void SessionManager::massSendMessage(const std::string &message)
{
    for (int x = 0; x < sessionBox.size(); x++)
    {
        sessionBox[x]->connectionPtr->pushMessage(message);
    }
}

处理消息的Connection类是这样的。消息只保留缓冲区，并对报头进行编码和解码。这是我在boost示例网站上发现的另一个修改类。

void Connection::pushMessage(const string& message)
{
 // boost async_write will return instantly, but guarantees to
 // either error or send all requested bytes.
 // there is no need to check if all bytes get sent in the callback.
    Message writeMsg;
    writeMsg.body_length( strlen(msg.c_str()) );
    memcpy( writeMsg.body(), msg.c_str(), writeMsg.body_length() );
    writeMsg.encode_header();
    boost::asio::async_write(socket_, boost::asio::buffer(writeMsg.data(), writeMsg.length()),
    boost::bind(&Session::handle_write, this, boost::asio::placeholders::error,
    boost::asio::placeholders::bytes_transferred));
}