C++下跨平台websocket库及使用示例

2024-04-28 14:36

本文主要是介绍C++下跨平台websocket库及使用示例,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

websocketpp库使用非常方便,开源,可跨平台,内部实现全部是head文件,无cpp,接口简单易用。源码路径比如 https://github.com/zaphoyd/websocketpp.git

使用方法是,先下载源码包并复制道工程的include目录下。

--include

   --websocketpp

然后在代码#include "utility_client.hpp"即可调用其接口进行websocket通信。以linux为例具体使用的方法代码示例:

websockettalker.h:

#ifndef WEBSOCKETTALKER_H
#define WEBSOCKETTALKER_H
#include "dao.h"
#include "utility_client.hpp"
#include "pthread.h"
#include "vector"using namespace std;
class CloudTalker;
class WebsocketTalker
{
public:WebsocketTalker(CloudTalker* talker, const string& remoteAddr, const string& name);~WebsocketTalker();string GetStatus();string GetMessage();bool Subscribe(const string& deviceId, const string& token);void handleNbData(const string& msg);private:CloudTalker* mTalker;static void* thread_loop(void* pVoid);pthread_t recv_thread;websocket_endpoint mEndpoint;int mId;string addr = "";bool should_exit = false;vector<DevInfo> mImeiTable;DAO* mDevDbDao = NULL;
};#endif // WEBSOCKETTALKER_H

websockettalker.cpp:

#include "websockettalker.h"
#include "cloudtalker.h"
#include "udptalker.h"
#include <boost/algorithm/string.hpp>using namespace boost;
#define JSON_PATH_DEV "path/to/devDB.json"
WebsocketTalker::WebsocketTalker(CloudTalker* talker, const string& remoteAddr, const string& name)
{string messageclient;addr = "ws://" + remoteAddr + ":8081/webSocketServer?" + name; //格式为cout <<"full address is:" <<addr <<endl;mTalker = talker;mDevDbDao = new DAO();pthread_create(&recv_thread, nullptr, thread_loop, this);
}/***********************************************************
* 描述: 处理数据
* 入参: wholeMsg - 要处理的数据
* 出参: 无
* 返回: 无
************************************************************/
void WebsocketTalker::handleData(const string& wholeMsg)
{cout <<endl;}/***********************************************************
* 描述: websocket通信线程
* 入参: pVoid - WebsocketTalker指针
* 出参: 无
* 返回: 无
************************************************************/
void* WebsocketTalker::thread_loop(void* pVoid)
{WebsocketTalker* p = (WebsocketTalker*) pVoid;string status = "";string wholeMsg = "";int cont = 0;unsigned int len = 0;while(!p->should_exit){p->mImeiTable.clear();printf("WEBSOCKET WANT TO CREATE CONNECT FOR NBIOT DATA\n");p->mDevDbDao->getNBAndShareImeiAll(JSON_PATH_DEV, p->mImeiTable);len = p->mImeiTable.size();if(len == 0){int cnt = 0;printf("nb/share dev list is zero\n");while(!p->should_exit && cnt++ <4){usleep(500000);}cnt = 0;continue;}p->mId = p->mEndpoint.connect(p->addr);if (p->mId == -1){cout << "Created connection failed! mId=" << p->mId<< endl;}else{while(!p->should_exit){usleep(50000);status = p->GetStatus();if(status.length() && status != "Connecting")break;}if(p->should_exit){printf("exit 1\n");break;}for(unsigned int i=0; i<len; i++){cout<<"subscribe dev: " << p->mImeiTable[i].IMEi<< "with token: "<<p->mImeiTable[i].Token<<endl;p->Subscribe(p->mImeiTable[i].IMEi, p->mImeiTable[i].Token);cont = 0;while(!p->should_exit){usleep(50000);status = p->GetStatus();if(status == "Message")break;if(cont++ > 40){printf("websocket data receive subscribe status timeout\n");//cont = 0;break;}}if(p->should_exit || cont > 40){printf("exit 2\n");break;}wholeMsg = p->GetMessage();printf("[%s(%d)%s] msg=%s\n", __FUNCTION__, __LINE__, __TIME__, wholeMsg.data());cont = 0;/*循环接收消息 */while(!p->should_exit){if(cont++ > 40){printf("websocket data receive timeout\n");//cont = 0;break;}status = p->GetStatus();//printf("get status: %s\n", status.c_str());if(status == "Message"){wholeMsg = p->GetMessage();printf("[%s(%d)%s;] GOT SUBSCRIBED DATA, msg=%s\n", __FUNCTION__, __LINE__, __TIME__, wholeMsg.data());p->handleNbData(wholeMsg);cont = 0;break;}usleep(50000);}if(p->should_exit){printf("exit 3\n");break;}}p->mEndpoint.close(p->mId, websocketpp::close::status::normal, "close");if(p->should_exit){printf("exit 3\n");break;}}usleep(2000000);//sleep long time could be.}return NULL;
}
string WebsocketTalker::GetStatus()
{return mEndpoint.get_metadata(mId)->get_status();
}string WebsocketTalker::GetMessage()
{return mEndpoint.get_metadata(mId)->get_message();
}bool WebsocketTalker::Subscribe(const string& deviceId, const string& token)
{string str;str = "{\"type\":\"address\",\"msg\":\"" + deviceId + "\",\"token\":\"" + token +"\"}";printf("[%s(%d)] %s\n", __FUNCTION__, __LINE__, str.data());mEndpoint.send(mId, str);return true;
}WebsocketTalker::~WebsocketTalker()
{printf("exit wstalker\n");if(mDevDbDao != NULL){delete mDevDbDao;}should_exit = true;pthread_join(recv_thread, NULL);printf("exit wstalker done\n");
}

 dao.h:

#ifndef DAO_H
#define DAO_H#include <iostream>
#include <fstream>
#include <string>
#include <vector>
#include "json/json.h"#ifndef UNUSED
#define UNUSED(x) (void)(x)
#endifusing namespace std;typedef struct
{string IMEi;string Type;string Token;
}DevInfo;class DAO{public:DAO(){}// 10. get device information transform to <vector> from json, "device information contain {IMEI, type, token, index}"int getNBAndShareImeiAll(const char* dfile_path, vector<DevInfo>& imeiTable){fstream dev_f;dev_f.open(dfile_path, ios::in | ios::out);if (!dev_f.is_open()){cout << "Open file error !" << endl;}Json::Value val;Json::Value root_arr;JSONCPP_STRING errs;//bool did;DevInfo devInfo;Json::CharReaderBuilder rbuilder;rbuilder["collectComments"] = false;bool parse_ok = Json::parseFromStream(rbuilder, dev_f, &root_arr, &errs);if(!parse_ok){cout << "Parse json file error !" << endl;}else{const Json::Value arrayObj = root_arr;cout << " ------ Printf Device information: ------ " << endl;try{for (unsigned int i = 0; i < arrayObj.size(); i++){if(arrayObj[i]["Type"].asString() == "LORA"){devInfo ={arrayObj[i]["IMEi"].asString(),arrayObj[i]["Type"].asString(),arrayObj[i]["Token"].asString()};imeiTable.push_back(devInfo);}}}catch (const Json::LogicError &ex){cout << " Parse json string error!" << endl;}}dev_f.close();return 0;}};#endif // DAO_H

 devDB.json:

[{"IMEi" : "6789999","Token" : "jfkl","Type" : "LORA"},{"IMEi" : "00124b00","Token" : "0","Type" : "xxx"},]

json的解析使用jsoncpp库,可自行安装。 

这篇关于C++下跨平台websocket库及使用示例的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/943506

相关文章

使用Navicat工具比对两个数据库所有表结构的差异案例详解

《使用Navicat工具比对两个数据库所有表结构的差异案例详解》:本文主要介绍如何使用Navicat工具对比两个数据库test_old和test_new,并生成相应的DDLSQL语句,以便将te... 目录概要案例一、如图两个数据库test_old和test_new进行比较:二、开始比较总结概要公司存在多

JavaWeb-WebSocket浏览器服务器双向通信方式

《JavaWeb-WebSocket浏览器服务器双向通信方式》文章介绍了WebSocket协议的工作原理和应用场景,包括与HTTP的对比,接着,详细介绍了如何在Java中使用WebSocket,包括配... 目录一、概述二、入门2.1 POM依赖2.2 编写配置类2.3 编写WebSocket服务2.4 浏

MySQL数据库函数之JSON_EXTRACT示例代码

《MySQL数据库函数之JSON_EXTRACT示例代码》:本文主要介绍MySQL数据库函数之JSON_EXTRACT的相关资料,JSON_EXTRACT()函数用于从JSON文档中提取值,支持对... 目录前言基本语法路径表达式示例示例 1: 提取简单值示例 2: 提取嵌套值示例 3: 提取数组中的值注意

CSS3中使用flex和grid实现等高元素布局的示例代码

《CSS3中使用flex和grid实现等高元素布局的示例代码》:本文主要介绍了使用CSS3中的Flexbox和Grid布局实现等高元素布局的方法,通过简单的两列实现、每行放置3列以及全部代码的展示,展示了这两种布局方式的实现细节和效果,详细内容请阅读本文,希望能对你有所帮助... 过往的实现方法是使用浮动加

如何使用Spring boot的@Transactional进行事务管理

《如何使用Springboot的@Transactional进行事务管理》这篇文章介绍了SpringBoot中使用@Transactional注解进行声明式事务管理的详细信息,包括基本用法、核心配置... 目录一、前置条件二、基本用法1. 在方法上添加注解2. 在类上添加注解三、核心配置参数1. 传播行为(

css渐变色背景|<gradient示例详解

《css渐变色背景|<gradient示例详解》CSS渐变是一种从一种颜色平滑过渡到另一种颜色的效果,可以作为元素的背景,它包括线性渐变、径向渐变和锥形渐变,本文介绍css渐变色背景|<gradien... 使用渐变色作为背景可以直接将渐China编程变色用作元素的背景,可以看做是一种特殊的背景图片。(是作为背

在Java中使用ModelMapper简化Shapefile属性转JavaBean实战过程

《在Java中使用ModelMapper简化Shapefile属性转JavaBean实战过程》本文介绍了在Java中使用ModelMapper库简化Shapefile属性转JavaBean的过程,对比... 目录前言一、原始的处理办法1、使用Set方法来转换2、使用构造方法转换二、基于ModelMapper

c++中std::placeholders的使用方法

《c++中std::placeholders的使用方法》std::placeholders是C++标准库中的一个工具,用于在函数对象绑定时创建占位符,本文就来详细的介绍一下,具有一定的参考价值,感兴... 目录1. 基本概念2. 使用场景3. 示例示例 1:部分参数绑定示例 2:参数重排序4. 注意事项5.

使用C++将处理后的信号保存为PNG和TIFF格式

《使用C++将处理后的信号保存为PNG和TIFF格式》在信号处理领域,我们常常需要将处理结果以图像的形式保存下来,方便后续分析和展示,C++提供了多种库来处理图像数据,本文将介绍如何使用stb_ima... 目录1. PNG格式保存使用stb_imagephp_write库1.1 安装和包含库1.2 代码解

JAVA调用Deepseek的api完成基本对话简单代码示例

《JAVA调用Deepseek的api完成基本对话简单代码示例》:本文主要介绍JAVA调用Deepseek的api完成基本对话的相关资料,文中详细讲解了如何获取DeepSeekAPI密钥、添加H... 获取API密钥首先,从DeepSeek平台获取API密钥,用于身份验证。添加HTTP客户端依赖使用Jav