使我的函数调用async_read异步Boost::asio

Question

我正在构建一个网络应用程序，作为Boost asio和整个网络的新手，我有这个疑问，这可能是微不足道的。我有这个应用程序，它从文件中读取并相应地调用api。我正在阅读json(示例(：

test.json

{
"commands":
[
{
"type":"login",
"Username": 0,
"Password": "kk"
}
]
}

我的主程序如下：

int main() {
ba::io_service ios;
tcp::socket s(ios);
s.connect({{},8080});
IO io;
io.start_read(s);
io.interact(s);

ios.run();
}
void start_read(tcp::socket& socket) {
char buffer_[MAX_LEN];
socket.async_receive(boost::asio::null_buffers(),
[&](const boost::system::error_code& ec, std::size_t bytes_read) {
(void)bytes_read;
if (likely(!ec)) {
boost::system::error_code errc;
int br = 0;
do {
br = socket.receive(boost::asio::buffer(buffer_, MAX_LEN), 0, errc);
if (unlikely(errc)) {
if (unlikely(errc != boost::asio::error::would_block)) {
if (errc != boost::asio::error::eof)
std::cerr << "asio async_receive: error " << errc.value() << " ("
<< errc.message() << ")" << std::endl;
interpret_read(socket,nullptr, -1);
//close(as);
return;
}
break; // EAGAIN
}
if (unlikely(br <= 0)) {
std::cerr << "asio async_receive: error, read " << br << " bytes" << std::endl;
interpret_read(socket,nullptr, br);
//close(as);
return;
}
interpret_read(socket,buffer_, br);
} while (br == (int)MAX_LEN);
} else {
if (socket.is_open())
std::cerr << "asio async_receive: error " << ec.value() << " (" << ec.message() << ")"
<< std::endl;
interpret_read(socket,nullptr, -1);
//close(as);
return;
}
start_read(socket);
});
}
void interpret_read(tcp::socket& s,const char*  buf, int len) {
if(len<0)
{
std::cout<<"some error occured in reading"<<"n";
}
const MessageHeaderOutComp *obj = reinterpret_cast<const MessageHeaderOutComp *>(buf);
int tempId = obj->TemplateID;
//std::cout<<tempId<<"n";
switch(tempId)
{
case 10019: //login
{
//const UserLoginResponse *obj = reinterpret_cast<const UserLoginResponse *>(buf);
std::cout<<"*********[SERVER]: LOGIN ACKNOWLEDGEMENT RECEIVED************* "<<"n";
break;
}
}
std::cout << "RX: " << len << " bytesn";
if(this->input_type==2)
interact(s);
}
void interact(tcp::socket& s)
{
if(this->input_type == -1){
std::cout<<"what type of input you want ? option 1 : test.json / option 2 : manually through command line :";
int temp;
std::cin>>temp;
this->input_type = temp;
}
if(this->input_type==1)
{
//std::cout<<"reading from filen";
std::ifstream input_file("test.json");
Json::Reader reader;
Json::Value input;
reader.parse(input_file, input);
for(auto i: input["commands"])
{
std::string str = i["type"].asString();
if(str=="login")
this->login_request(s,i);
}
std::cout<<"File read completely!! n Do you want to continue or exit?: ";
}
}

发送工作正常，消息被发送，服务器以正确的方式做出响应，但我需要理解的是，为什么控件没有转到on_sand_completed(打印发送的x字节(。它也不会打印消息[SERVER]：LOGIN ACKNOWLEDGEMENT RECEIVED，我知道我遗漏了一些基本内容或做错了什么，请纠正我。

login_request函数：

void login_request(tcp::socket& socket,Json::Value o) {

/*Some buffer being filled*/
async_write(socket, boost::asio::buffer(&info, sizeof(info)), on_send_completed);
}

提前感谢！！

Answer 1

粗略地扫描一下，您似乎重新定义了buffer_，它已经是(可能是IO的(类成员。

它被start_read中的local隐藏，这既是UB(因为生存期在异步读取操作完成之前结束(，也是不使用成员_buffer的原因。

不过，我看到了很多令人困惑的代码。为什么要从完成处理程序中进行同步读取？

我认为您可能正在寻找组合的ooperation reads(boost:：asio:：async_read和boost:：asic:：async _until(