我正在学习提升并且正在弄乱它的服务器和客户端通信,以便创建一个简单的聊天服务器,客户端发送的任何内容都只显示在服务器上。服务器本身不发送任何内容并启动接收部分。这很简单。
服务器代码:
#include <boost\asio\placeholders.hpp>
#include <boost\bind.hpp>
#include <boost\asio\ip\tcp.hpp>
#include <boost\asio\io_context.hpp>
#include <iostream>
class Server
{
private :
boost::asio::ip::tcp::socket server_socket;
boost::asio::ip::tcp::endpoint server_endpoint;
boost::asio::ip::tcp::acceptor acceptor;
std::string msg;
public :
Server(boost::asio::io_context &io) :
server_socket(io),
server_endpoint(boost::asio::ip::make_address("127.0.0.1"), 27015),
acceptor(io, server_endpoint)
{
acceptor.async_accept(server_socket,
boost::bind(&Server::async_acceptor_handler, this,
boost::asio::placeholders::error));
}
void async_acceptor_handler(const boost::system::error_code &ec)
{
if (!ec)
{
std::cout << "One client connected...\n";
server_socket.async_read_some(boost::asio::buffer(msg),
boost::bind(&Server::async_read_some_handler, this,
boost::asio::placeholders::error));
}
else
{
std::cout << "async_acceptor failed with error code : " << ec.value() << std::endl;
std::cout << "Error description : " << ec.message() << std::endl;
}
}
void async_read_some_handler(const boost::system::error_code &ec)
{
if (!ec)
{
std::cout << msg << std::endl;
server_socket.async_read_some(boost::asio::buffer(msg),
boost::bind(&Server::async_read_some_handler, this,
boost::asio::placeholders::error));
}
else
{
std::cout << "async_acceptor failed with error code : " << ec.value() << std::endl;
std::cout << "Error description : " << ec.message() << std::endl;
}
}
};
int main()
{
boost::asio::io_context io;
Server s(io);
io.run();
return 0;
}
在客户端部分,它再次是一个非常简单的代码,只需连接到服务器并开始从用户获取输入并发送到服务器。
客户代码:
#include <boost\asio\placeholders.hpp>
#include <boost\bind.hpp>
#include <boost\asio\ip\tcp.hpp>
#include <boost\asio\io_context.hpp>
#include <iostream>
class Client
{
private :
boost::asio::ip::tcp::socket client_socket;
boost::asio::ip::tcp::endpoint server_endpoint;
std::string msg;
public :
Client(boost::asio::io_context &iocontext) :
client_socket(iocontext),
server_endpoint(boost::asio::ip::make_address("127.0.0.1"), 27015)
{
//connect to server endpoint
client_socket.async_connect(server_endpoint,
boost::bind(&Client::async_connect_handler, this,
boost::asio::placeholders::error));
}
void async_connect_handler(const boost::system::error_code &ec)
{
if (!ec)
{
std::cout << "Connected to chat server...\n";
//wait for user input
std::cin >> msg;
std::cout << "\rC : " << msg << std::endl;
client_socket.async_write_some(boost::asio::buffer(msg),
boost::bind(&Client::async_write_some_handler, this,
boost::asio::placeholders::error));
}
else
{
std::cout << "async_connect failed with error code : " << ec.value() << std::endl;
std::cout << "Error description : " << ec.message() << std::endl;
}
}
void async_write_some_handler(const boost::system::error_code &ec)
{
//wait for user input
std::cin >> msg;
std::cout << "\rC : " << msg << std::endl;
client_socket.async_write_some(boost::asio::buffer(msg),
boost::bind(&Client::async_write_some_handler, this,
boost::asio::placeholders::error));
}
};
int main()
{
boost::asio::io_context io;
Client c(io);
io.run();
return 0;
}
现在的问题是:
它工作正常,并连接到服务器。我在客户端和服务器中的“One client connected ...”中获得了正确的“连接到聊天服务器...”。问题出现在那之后:
问题1可能是我的问题,因为我还没有检查等待功能和其他使服务器等待的调用。如果你可以指导我,那将是非常了不起的。但主要问题是问题的第2部分,因为,我不知道为什么服务器总是从客户端没有收到任何东西。
PS:这是一个不完整的代码,我打算用它来玩一点,所以,如果有一些重大缺陷,请告诉我这样...... :)
服务器端string msg
的大小是多少?它是0.所以服务器总是读取0个字节。当你想读取字符串并调用buffer::asio::buffer
时,字符串必须有一些大小,例如10.这意味着你要将10个字节读入msg
。您可以调用msg.resize(10)
(在启动读取操作之前),然后一些数据将被msg
读入async_read_some
(它可能是1,2个字节,无论如何 - 它是async_read_some
如何工作,但最大读取字符是10)。但这是糟糕的解决方案。
您正在发送文本,因此当您不知道客户端可以有多少字节时,您可以考虑将读取数据用于streambuf
而不是string
。然后你可以用分隔符调用async_read_until - 它可以是例如换行符。
另一种解决方案是使用dynamic buffer。将数据附加到字符串中并且您不关心字符串缓冲区的初始大小。但是动态缓冲区不适用于像async_read_some
这样的socket的成员函数,它可以与async_read
一起用作自由函数。