# dbtcpserver **Repository Path**: guanzhi0319/dbtcpserver ## Basic Information - **Project Name**: dbtcpserver - **Description**: 物联网tcpserver，视频数据库server，视频数据库 - **Primary Language**: C++ - **License**: GPL-2.0 - **Default Branch**: master - **Homepage**: None - **GVP Project**: No ## Statistics - **Stars**: 3 - **Forks**: 3 - **Created**: 2018-09-24 - **Last Updated**: 2023-09-04 ## Categories & Tags **Categories**: Uncategorized **Tags**: None ## README 2023-6-4 删除了所有无用项目，开始编写视频数据库，数据索引，增加对应AI特征 #db 增加db ，准备编写db程序 # iot_tcpserver 从json配置文件中读取不同的tcp 头部设置，可以适应不同的协议 中达物联网tcpserver,非业务层,高并发接受数据传送到node it can work now 已经验证 tcpClient_8051 2023-3-12 更新 增加视频数据库的状态读取 2018-10-07 更新 增加httpserver 的httpparse 2018-10-07 更新 获取设备id号，增加httpclient post 和 get协议，不用加载其他httpclient 使用libuv直接发送http，接收不能超过4096字节，后期优化 项目介绍 物联网接收从各个传感器与摄像头的数据 1 传感器数据 可以配置为传感器数据的服务器，接收传感器4g modbus协议或者自定义协议 2 摄像头数据 准备接收推流flv，手机端，android和ios端两种硬编码数据流。两个手机端将逐步开放 3 iot_tcpserver 本身也将可以配置成为流媒体server。 作为httpflv和fmp4流媒体server 软件架构 cs 与 bs 架构结合 架构说明将会上传word文档和ppt 安装教程 1 把config_805x.json 放入到bin文件夹中 2. 程序读取配置 不同的协议头部使用不同的config文件 3. 启动等待数据 类说明： 从tcp_server 继承 得到三个基本事件 1 on_headers_complete 2 on message_complete 3 on_data 和message_complete 功能类似，但是有直接的数据指针和长度 class tcp_server1 :public tcp_server { //所有客戶端，用四字节整形数作为hash key std::map _map_c; public: int on_headers_complete(void *param) { client_t * pclient = (client_t*)param; printf("the header len is %d\n", pclient->recvlen); return 0; } int on_message_complete(void *param) { client_t * pclient = (client_t*)param; tcp_unit * data = pclient->buffer_data; char * buf = data->data; int len = data->tlen; printf("the total len is %d\n", pclient->buffer_data->tlen); #ifdef _DEBUG for (size_t i = 0; i < len; i++) { printf("%02x ",(uint8_t) buf[i]); } printf("\n"); #endif return 0; } int on_data(uint8_t * data, int len) { printf("the thread pid is %d\n", _getpid()); return 0; } }; 程序单个线程接收后将使用线程池处理数据，后期会加入多进程方式处理数据 程序初步完成测试 启动服务器后，测试程序 tcpClient_8051.js 使用 node tcpClient_8051.js 启动客户端程序，服务器端打印相应的数据信息。 启动文件说明： { "urls": [ { "url": "http://192.168.1.23/postdata" }, { "url": "http://192.168.1.223/postdata" } ], "data": { "test": "1" }, "head":{"offset":1,"len":1, content:"0x69"}, "deviceid": { "offset": 1, "len": 4 }, "cmd": { "offset": 5, "len": 1 }, "contentlen": { "offset": 6, "len": 1, "includeht": 0 }, "crclen": 2, "end_start": 1, "end": 22, "bl": 0 } 说明: urls: 发送数据的httpserver地址 data：回送数据 head：接收的头部字节 offset 以0 为开始 deviceid ：设备id cmd :命令 contentlen: 表明内容长度字节 ， includeht，长度是否包含头部字节 crclen: 是否有crc校验 0 为无，有则为crc校验长度 end_start:是否有结尾字节 end:结尾字节是多少，22 为0x16 ，end_start 为0时跳过 todolist 1 视频httpflv 下一步 2 协议为字符，且\r\n为结束等方式的物联网发送 下一步 3 验证8052 8053 正在进行 7 数据库存储 正在进行 5 http协议发送， 正在进行 4 多进程方式 规划中 5 分布式分发服务 规划中 6 存储服务 规划中 参与贡献 qianbo