Boost Asio io_service，从客户端读取消息

Question

我正在尝试使用 Boost ASio 库在 C++ 中创建一个简单的 Tcp 服务器。我写了两个类 TcpConnection 和 TcpServer。

我需要的行为是 Tcp 服务器应该能够向所有连接的客户端发送消息，并且客户端应该能够向服务器注册/注销。

我能够实现从服务器发送消息。我没有成功阅读客户部分。我的客户端是用 java 编写的，使用 apache mina。

服务器代码

message = message + "\r\n"; 
const int bytesToSend = message.length(); 
boost::system::error_code error;
boost::asio::write(socket, boost::asio::buffer(message, bytesToSend), boost::asio::transfer_all(), error);

客户端代码

ConnectFuture future = ioConnector.connect(new InetSocketAddress(Port),
                new TriggerReceiverHandler();
System.out.println("Message Receiver started and listening on port "+ Port);
IoSession session = future.getSession();
session.write(new String("TEst Message From Client"));

在服务器上，读取消息的代码是使用 async_read 完成的

boost::array<char, 1> buf;
    boost::asio::async_read(socket, boost::asio::buffer(buf),
        boost::bind(&TcpConnection::handleRead, this, buf, boost::asio::placeholders::error));


void TcpConnection::handleRead(boost::array<char, 1> buf, const boost::system::error_code& error)
{
    if(!error)
    {
        std::cout << "Message: " << buf.data() << std::endl;
    }
    else
    {
        std::cout << "Error occurred." << std::endl;
    }
}

但是，当我通过从客户端写入会话来触发消息时，不会调用 handleRead。如果我做错了什么，请告诉我。

我将不胜感激。如果需要任何进一步的信息，请告诉我。

提前致谢。

Answer 1

首先这似乎是不正确的！

boost::array<char, 1> buf;

您正在声明一个大小为 1 的数组！我会建议更大的东西！

boost::array<char, 1500> buf;

除了缓冲区之外，我看不出您的代码有任何问题，只需检查您是否没有在同一个套接字上交错 async_read 调用。