webtail——websocket

前面介绍了服务器端如何监听和增量读取文件,这里通过基于boost asio的websocketpp,实现了一个简单的websocket服务端,能够和浏览器进行通信,将读取到的文件通过websocket协议进行实时传送。

关于websocket的简单介绍,可以参考维基百科。websocket协议,在rfc6455中定义。

websocketpp对websocket和简单的http都进行了比较好的封装,只要实现几个handler,就可以完成对连接、消息等的操作和控制。主要需要处理的,可能有以下的handler:
[cce lang="cpp"]
typedef lib::function<void(connection_hdl)> open_handler;
typedef lib::function<void(connection_hdl)> close_handler;
typedef lib::function<void(connection_hdl)> http_handler;
typedef lib::function<void(connection_hdl,message_ptr)> message_handler
[/cce]
分别处理连接创建,连接关闭,http请求和消息请求。其中connection_hdl是连接的weak_ptr。

这里对websocket使用很简单,唯一的需求,就是维护已经建立的连接(既创建连接的时候记录,关闭连接的时候移出),然后通过将自己的回调注册到文件监控类中,实时的将消息推送到websocket客户端。

首先,维护一个set,用来保存当前已经建立的所有连接:
[cce lang="cpp"]
typedef std::set<websocketpp::connection_hdl,boost::owner_less<websocketpp::connection_hdl> > ConnectionSet;
[/cce]
然后在建立连接的时候插入到这个set中:
[cce lang="cpp"]
void WebSocketServer::onOpen ( websocketpp::connection_hdl hdl )
{
boost::lock_guard<boost::mutex> lock(_mutex);
_conns.insert(hdl);
}
[/cce]
在连接关闭的时候,移除连接:
[cce lang="cpp"]
void WebSocketServer::onClose ( websocketpp::connection_hdl hdl )
{
boost::lock_guard<boost::mutex> lock(_mutex);
_conns.erase(hdl);
}
[/cce]
另外,定义一个让filewatcher调用的回调:
[cce lang="cpp"]
void WebSocketServer::write ( const std::string& content )
{
boost::lock_guard<boost::mutex> lock(_mutex);
BOOST_AUTO(it, _conns.begin());
for(; it != _conns.end(); ++it) {
_s.send(*it, content, websocketpp::frame::opcode::text);
}
}
[/cce]
这个回调很简单,就是当有读取到内容的时候,遍历连接集合,向每个连接发送具体的内容。

最后,为了方便用户访问,当发现是标准http请求的时候,我们返回一个简单的html,用于显示和建立websocket连接。如果不指定具体的http_handler,websocketpp在发现请求是http的时候,会返回http的426错误(Upgrade Required)。
[cce lang="cpp"]
void WebSocketServer::httpHandler ( websocketpp::connection_hdl hdl )
{
server::connection_ptr connPtr = _s.get_con_from_hdl(hdl);;

connPtr->set_status(websocketpp::http::status_code::ok);
connPtr->set_body(htmlContent);
}
[/cce]

另外,还有一个小坑。按照websocketpp的example,在启动的时候都是直接调用server的listen函数,而且使用的都是只有端口号的那个实现。实际使用过程中,发现这个只有端口号的实现,直接使用了ipv6协议。虽说如果本机同时支持ipv6和ipv4的情况下,两个协议对应的端口都会监听,但是遇到了服务器上关闭了ipv6,会导致boost asio抛出address_family_not_supported异常,导致应用被迫退出。为了兼容这种方式,对这个异常进行了抓取,重新降级尝试ipv4协议,这样能够很好的在只有ipv4的服务器上进行使用。
[cce lang="cpp"]
try{
_s.listen(port);
} catch(boost::system::system_error const& e) {
if(e.code() == boost::asio::error::address_family_not_supported) {
_s.listen(boost::asio::ip::tcp::v4(), port);
}
} catch (...) {
throw;
}
[/cce]

发表评论

您的电子邮箱地址不会被公开。

此站点使用Akismet来减少垃圾评论。了解我们如何处理您的评论数据