websocket++簡(jiǎn)單使用及實(shí)例分析

2020-01-26 14:34:55

字體：大中小

供稿：網(wǎng)友

前言

html5支持使用websocket協(xié)議與服務(wù)器保持一個(gè)長(zhǎng)連接，方便雙方互相傳輸數(shù)據(jù)，而且服務(wù)器也能主動(dòng)發(fā)送信息給客戶端，而在這之前使用HTTP是很難做到的。下面介紹使用C++實(shí)現(xiàn)的websocket++的簡(jiǎn)單使用。websocket++更詳細(xì)介紹點(diǎn)此。

websocket++需要boost的支持，所以工程中需要包含boost的頭文件和庫(kù)。boost在VS中的如何使用參考此文章。

C++代碼

#include "stdafx.h"#include <iostream>using namespace std;#include <websocketpp/config/asio_no_tls.hpp>#include <websocketpp/server.hpp>typedef websocketpp::server<websocketpp::config::asio> WebsocketServer;typedef WebsocketServer::message_ptr message_ptr;using websocketpp::lib::placeholders::_1;using websocketpp::lib::placeholders::_2;using websocketpp::lib::bind;void OnOpen(WebsocketServer *server, websocketpp::connection_hdl hdl){  cout << "have client connected" << endl;}void OnClose(WebsocketServer *server, websocketpp::connection_hdl hdl){  cout << "have client disconnected" << endl;}void OnMessage(WebsocketServer *server, websocketpp::connection_hdl hdl, message_ptr msg){  string strMsg = msg->get_payload();  cout << strMsg << endl;  string strRespon = "receive: ";  strRespon.append(strMsg);  server->send(hdl, strRespon, websocketpp::frame::opcode::text);}int main(){  WebsocketServer          server;  // Set logging settings  server.set_access_channels(websocketpp::log::alevel::all);  server.clear_access_channels(websocketpp::log::alevel::frame_payload);  // Initialize ASIO  server.init_asio();  // Register our open handler  server.set_open_handler(bind(&OnOpen, &server, ::_1));  // Register our close handler  server.set_close_handler(bind(&OnClose, &server, _1));  // Register our message handler  server.set_message_handler(bind(&OnMessage, &server, _1, _2));  //Listen on port 2152  server.listen(8090);  //Start the server accept loop  server.start_accept();  //Start the ASIO io_service run loop  server.run();  return 0;}

Html代碼

<!DOCTYPE html><html><head><title>Testing websockets</title></head><body> <div>  <input type="submit" value="Start" onclick="start()" /> </div> <div id="messages"></div> <script type="text/javascript">  var webSocket =   new WebSocket('ws://localhost:8090');   webSocket.onerror = function(event) {   onError(event)  };   webSocket.onopen = function(event) {   onOpen(event)  };    webSocket.onclose = function(event) {   onClose(event)  };   webSocket.onmessage = function(event) {   onMessage(event)  };   function onMessage(event) {   document.getElementById('messages').innerHTML    += '<br />' + event.data;  }   function onOpen(event) {   document.getElementById('messages').innerHTML    = 'Connection established';  }    function onClose(event) {   document.getElementById('messages').innerHTML    += '<br />disconnection';  }  function onError(event) {   alert(event.data);  }   function start() {   webSocket.send('hello');   return false;  } </script></body></html>

運(yùn)行結(jié)果