用async_read_until增加麻烦
Boost asio trouble with async_read_until
我正在制作一个带有boost asio的Irc机器人,我在编译它时遇到了一些问题,而且错误并不是真正可读的。
似乎其中一项async_read_until进展得不是很顺利,但我不知道为什么。
这是 g++ 编译器的错误
mkdir -p build
g++ -std=c++11 -pthread -Wall -Wextra -lboost_system -o build/main.o -c main.cpp
g++ -std=c++11 -pthread -Wall -Wextra -lboost_system -o build/irc.o -c irc.cpp
In file included from irc.hpp:6:0,
from irc.cpp:1:
/usr/include/boost/tokenizer.hpp: In instantiation of ‘boost::tokenizer<TokenizerFunc, Iterator, Type>::tokenizer(const Container&) [with Container = boost::system::error_code; TokenizerFunc = boost::char_separator<char>; Iterator = __gnu_cxx::__normal_iterator<const char*, std::__cxx11::basic_string<char> >; Type = std::__cxx11::basic_string<char>]’:
/usr/include/boost/bind/bind.hpp:319:35: required from ‘void boost::_bi::list2<A1, A2>::operator()(boost::_bi::type<void>, F&, A&, int) [with F = boost::_mfi::mf1<void, Irc, const boost::tokenizer<boost::char_separator<char> >&>; A = boost::_bi::rrlist2<const boost::system::error_code&, const long unsigned int&>; A1 = boost::_bi::value<Irc*>; A2 = boost::arg<1> (*)()]’
/usr/include/boost/bind/bind.hpp:1246:50: required from ‘boost::_bi::bind_t<R, F, L>::result_type boost::_bi::bind_t<R, F, L>::operator()(A1&&, A2&&) [with A1 = const boost::system::error_code&; A2 = const long unsigned int&; R = void; F = boost::_mfi::mf1<void, Irc, const boost::tokenizer<boost::char_separator<char> >&>; L = boost::_bi::list2<boost::_bi::value<Irc*>, boost::arg<1> (*)()>; boost::_bi::bind_t<R, F, L>::result_type = void]’
/usr/include/boost/asio/impl/read_until.hpp:636:9: required from ‘void boost::asio::detail::read_until_delim_string_op<AsyncReadStream, Allocator, ReadHandler>::operator()(const boost::system::error_code&, std::size_t, int) [with AsyncReadStream = boost::asio::basic_stream_socket<boost::asio::ip::tcp>; Allocator = std::allocator<char>; ReadHandler = boost::_bi::bind_t<void, boost::_mfi::mf1<void, Irc, const boost::tokenizer<boost::char_separator<char> >&>, boost::_bi::list2<boost::_bi::value<Irc*>, boost::arg<1> (*)()> >; std::size_t = long unsigned int]’
/usr/include/boost/asio/impl/read_until.hpp:716:35: required from ‘typename boost::asio::async_result<typename boost::asio::handler_type<WriteHandler, void(boost::system::error_code, long unsigned int)>::type>::type boost::asio::async_read_until(AsyncReadStream&, boost::asio::basic_streambuf<Allocator>&, const string&, ReadHandler&&) [with AsyncReadStream = boost::asio::basic_stream_socket<boost::asio::ip::tcp>; Allocator = std::allocator<char>; ReadHandler = boost::_bi::bind_t<void, boost::_mfi::mf1<void, Irc, const boost::tokenizer<boost::char_separator<char> >&>, boost::_bi::list2<boost::_bi::value<Irc*>, boost::arg<1> (*)()> >; typename boost::asio::async_result<typename boost::asio::handler_type<WriteHandler, void(boost::system::error_code, long unsigned int)>::type>::type = void; std::__cxx11::string = std::__cxx11::basic_string<char>]’
irc.cpp:118:2: required from here
/usr/include/boost/tokenizer.hpp:59:47: error: ‘const class boost::system::error_code’ has no member named ‘begin’
: first_(c.begin()), last_(c.end()), f_() { }
^
/usr/include/boost/tokenizer.hpp:59:47: error: ‘const class boost::system::error_code’ has no member named ‘end’
Makefile:17: recipe for target 'irc.o' failed
make: *** [irc.o] Error 1
这是 .hpp 和.cpp文件。我省略了 uninteressant 函数,但如果你想要完整的文件,它就在这里。
IRC.hpp
#ifndef H_IRC
#define H_IRC
#include <vector>
#include <boost/asio.hpp>
#include <boost/tokenizer.hpp>
class Irc
{
public:
Irc(const std::string &server, const std::string &port, const std::function<void()> onConnect);
void connect();
void close();
void user(const std::string &username);
void user(const std::string &username, const std::string &hostname, const std::string &server, const std::string &realname);
void nick(std::string &nickname);
void join(const std::string &chan);
void part(const std::string &chan);
void privmsg(const std::string &to, const std::string &msg);
void command(const std::string &cmd, const std::string &msg);
void command(const std::string &cmd, const std::string &to, const std::string &msg);
void run();
private:
void _read(const boost::system::error_code &error);
void _send(std::string &message);
void _readHandler(const boost::tokenizer<boost::char_separator<char> > &tokenizer);
void _connectHandler(const boost::system::error_code &error);
void _pong(const std::string &ping);
std::string _server;
std::string _port;
std::string _chan;
std::vector<std::function<void (const boost::tokenizer<boost::char_separator<char> >&)>> _readHandlers;
std::function<void()> _onConnect;
boost::asio::streambuf _buffer;
boost::asio::io_service _ios;
boost::asio::ip::tcp::socket _socket;
};
#endif
IRC.cpp
#include "irc.hpp"
#include <iostream>
#include <boost/bind.hpp>
#include <boost/tokenizer.hpp>
Irc::Irc(const std::string &server, const std::string &port, const std::function<void()> onConnect)
: _server(server), _port(port), _onConnect(onConnect), _socket(_ios)
{
// Ping back handler
_readHandlers.push_back([this](const boost::tokenizer<boost::char_separator<char> > &tokenizer) {
std::vector<std::string> tokens(begin(tokenizer), end(tokenizer));
if(tokens[0].compare("PING") == 0)
_pong(tokens[1]);
});
// 451 handler
_readHandlers.push_back([this](const boost::tokenizer<boost::char_separator<char> > &tokenizer) {
std::vector<std::string> tokens(begin(tokenizer), end(tokenizer));
//for(auto &it : tokens)
// if (it.compare("451") == 0) join(_chan);
});
}
void Irc::connect()
{
boost::asio::ip::tcp::resolver resolver(_ios);
boost::asio::ip::tcp::resolver::query query(_server, _port);
boost::asio::ip::tcp::resolver::iterator it = resolver.resolve(query);
boost::asio::ip::tcp::resolver::iterator end;
boost::system::error_code error = boost::asio::error::host_not_found;
while(it != end)
{
if(!error)
break;
std::cout << "Connecting to " << _server << " " << _port << std::endl;
boost::asio::async_connect(_socket, it,
boost::bind(&Irc::_connectHandler, this, error)
);
it++;
if(error)
std::cout << "Error : " << error.message() << std::endl;
}
if(error)
std::cout << "Error connectinf to " << _server << " " << error.message() << std::endl;
else
std::cout << "Connection success" << std::endl;
}
void Irc::close()
{
_socket.close();
_ios.stop();
}
void Irc::command(const std::string &cmd, const std::string &msg)
{
std::string message(cmd + " " + msg + "rn");
_send(message);
}
void Irc::command(const std::string &cmd, const std::string &to, const std::string &msg)
{
std::string message(cmd + " " + to + " " + msg + "rn");
_send(message);
}
void Irc::run()
{
boost::asio::async_read_until(_socket, _buffer, "rn",
boost::bind(&Irc::_readHandler, this,
boost::asio::placeholders::error
)
);
_ios.run();
}
/*
* Private
*/
void Irc::_read(const boost::system::error_code &error)
{
if(error)
{
std::cerr << error.message() << std::endl;
close();
}
else
{
std::string data(buffers_begin(_buffer.data()), buffers_begin(_buffer.data()) + _buffer.size());
std::cout << data << std::endl;
boost::char_separator<char> sep("!@:; ");
boost::tokenizer<boost::char_separator<char> > tokenizer(data, sep);
_readHandler(tokenizer);
boost::asio::async_read_until(_socket, _buffer, "rn",
boost::bind(&Irc::_readHandler, this,
boost::asio::placeholders::error
)
);
}
}
inline void Irc::_send(std::string &message)
{
boost::asio::write(_socket, boost::asio::buffer(message + "rn"));
}
void Irc::_readHandler(const boost::tokenizer<boost::char_separator<char> > &tokenizer)
{
for(auto it : _readHandlers)
it(tokenizer);
}
void Irc::_connectHandler(const boost::system::error_code &error)
{
if(!error)
{
_onConnect();
}
}
多谢!我整个晚上都在研究这个问题。
当你调用async_read_until
时,你试图将_readHandler
绑定为回调函数,但是这个函数没有正确的签名:asio 除了它有boost::system:error_code
作为第一个参数,但在你的情况下它是const boost::tokenizer<boost::char_separator<char> > &tokenizer
。更改其类型,然后相应地修改代码。
相关文章:
- 数组索引的值没有增加
- 为什么我的代码在输出中增加了93天
- 有效地使用std::unordered_map来插入或增加键的值
- C++ 动态数组每次添加时将大小增加 1 - 错误
- 为什么要增加导致崩溃的指针
- 我已经阅读了很多关于 2d 数组的信息,但我在作业中使用它时遇到了麻烦
- 查找奇数平方和时遇到麻烦
- 增加传递地址的值
- 如何增加以前由新运算符分配的 C++ std::list 数组的大小?
- 为什么"i"在循环的每次迭代中都没有增加?(C++)
- std::thread 增加 DLL 引用计数,从而防止卸载 DLL
- 如何在C++中为增加但记住删除先前对象的对象分配唯一标识符
- 将一对插入地图并增加计数?
- 整数类型应该显式转换(例如"int"到"无符号")还是只会增加混乱?
- 我的 c++ 应用程序中的运行时间从 0 增加到 60 太快了(例如一毫秒或一微秒)
- 为什么当通过 TCP 发送的消息速率增加时,请求-响应消息对的延迟会降低?
- 琐碎并发代码的吞吐量不会随着线程数量的增加而增加
- C++:功能在输出前自动使用50减/增加输入数
- 追加位以增加字符的大小
- 用async_read_until增加麻烦