ubuntu c++ http服务端event使用

程序：

#ifndef PLATFROMCOMMUNICATION_H
#define PLATFROMCOMMUNICATION_H#include <iostream>
#include <fstream>
#include <unistd.h>
#include <curl/curl.h>#include <net/if.h>
#include <sys/ioctl.h>
#include <arpa/inet.h>
#include <string.h>#include <event.h>
#include <event2/event.h>
#include <event2/buffer.h>
#include <event2/http.h>
#include <event2/http_struct.h>
#include <event2/http_compat.h>
#include <event2/util.h>#include <jsoncpp/json/json.h>#define ETH_NAME "ens33"
#define MYHTTPD_SIGNATURE   "MoCarHttpd v0.1"using namespace std;class RouteTasks{
public:RouteTasks();void init();private:static void login(struct evhttp_request *req, void *arg);string getIp();int m_port;int m_timeout;
};#endif // PLATFROMCOMMUNICATION_H

#include "platfromcommunication.h"RouteTasks::RouteTasks()
{m_port = 9000;m_timeout = 120;
}void RouteTasks::init()
{//服务端//初始化event APIevent_init();//创建一个http serverstruct evhttp *httpd;httpd = evhttp_start(getIp().c_str(), m_port);evhttp_set_timeout(httpd, m_timeout);//也可以为特定的URI指定callbackevhttp_set_cb(httpd, "/cgi-bin/entry.cgi/system/login", &RouteTasks::login, NULL);//循环处理eventsevent_dispatch();evhttp_free(httpd);
}void RouteTasks::login(evhttp_request *req, void *arg)
{char request_data[4096] = {0};//获取POST方法的数据size_t post_size = EVBUFFER_LENGTH(req->input_buffer);char *post_data = (char *) EVBUFFER_DATA(req->input_buffer);memcpy(request_data, post_data, post_size);printf("got control_device_start_stop connection post_data = %s, len =%ld\n", post_data, post_size);//解析获得的数据string deviceCode;string ptz;Json::Value jvalue;Json::Reader jreader;jreader.parse(request_data, jvalue);deviceCode = jvalue["sUserName"].asString();ptz = jvalue["sPassword"].asString();cout<<"============================\n"<<"deviceCode: "<<deviceCode<<" ptz: "<<ptz<<"\n-------------------------\n"<<endl;//给前段回复一个响应结果Json::Value root;Json::FastWriter fastWriter;root["code"] = Json::Value("200");root["msg"] = Json::Value("成功");cout<<"return post"<<fastWriter.write(root)<<endl;/* 输出到客户端 *///HTTP headerevhttp_add_header(req->output_headers, "Server", MYHTTPD_SIGNATURE);evhttp_add_header(req->output_headers, "Content-Type", "application/json; charset=UTF-8");evhttp_add_header(req->output_headers, "Connection", "close");//输出的内容struct evbuffer *buf;buf = evbuffer_new();evbuffer_add_printf(buf, "%s", fastWriter.write(root).c_str());//将封装好的evbuffer 发送给客户端evhttp_send_reply(req, HTTP_OK, "OK", buf);evbuffer_free(buf);
}string RouteTasks::getIp()
{struct sockaddr_in sin;struct ifreq ifr;int sockfd = socket(AF_INET, SOCK_DGRAM, 0);if(sockfd == -1) {perror("socket error");return "";}strncpy(ifr.ifr_name, ETH_NAME, IFNAMSIZ);if(ioctl(sockfd, SIOCGIFADDR, &ifr) == 0) {memcpy(&sin, &ifr.ifr_addr, sizeof (ifr.ifr_addr));cout<<ETH_NAME<<" ip : "<<inet_ntoa(sin.sin_addr)<<endl;return inet_ntoa(sin.sin_addr);}return "";
}

#include <iostream>
#include "platfromcommunication.h"using namespace std;//当向进程发出SIGTERM/SIGHUP/SIGINT/SIGQUIT的时候，终止event的事件侦听循环
void signal_handler(int sig) {switch (sig) {case SIGTERM:case SIGHUP:case SIGQUIT:case SIGINT:event_loopbreak();  //终止侦听event_dispatch()的事件侦听循环，执行之后的代码break;}
}int main()
{cout<<"hello world"<<endl;signal(SIGHUP, signal_handler);signal(SIGTERM, signal_handler);signal(SIGINT, signal_handler);signal(SIGQUIT, signal_handler);RouteTasks rt;rt.init();while (1) {sleep(1);}return 0;
}

编译： -levent

由于在ubuntu中https服务端event是阻塞式运行的，所以在正式项目中，可以将其放入线程中，这样不会阻塞程序运行，具体方式如下：上程序

#ifndef PLATFROMCOMMUNICATION_H
#define PLATFROMCOMMUNICATION_H#include <iostream>
#include <fstream>
#include <unistd.h>
#include <curl/curl.h>#include <net/if.h>
#include <sys/ioctl.h>
#include <arpa/inet.h>
#include <string.h>#include <event.h>
#include <event2/event.h>
#include <event2/buffer.h>
#include <event2/http.h>
#include <event2/http_struct.h>
#include <event2/http_compat.h>
#include <event2/util.h>#include <jsoncpp/json/json.h>
#include <boost/thread.hpp>#define ETH_NAME "ens33"
#define MYHTTPD_SIGNATURE   "MoCarHttpd v0.1"using namespace std;class RouteTasks{
public:RouteTasks();~RouteTasks();void init();private:static void login(struct evhttp_request *req, void *arg);static void init_thread(void *arg);void init_sub();string getIp();int m_port;int m_timeout;//创建一个http serverstruct evhttp *httpd;
};#endif // PLATFROMCOMMUNICATION_H

#include "platfromcommunication.h"RouteTasks::RouteTasks()
{m_port = 7777;m_timeout = 120;//初始化event APIevent_init();
}RouteTasks::~RouteTasks()
{evhttp_free(httpd);
}void RouteTasks::init()
{boost::thread t(&RouteTasks::init_thread, this);
}void RouteTasks::login(evhttp_request *req, void *arg)
{char request_data[4096] = {0};//获取POST方法的数据size_t post_size = EVBUFFER_LENGTH(req->input_buffer);char *post_data = (char *) EVBUFFER_DATA(req->input_buffer);memcpy(request_data, post_data, post_size);printf("got control_device_start_stop connection post_data = %s, len =%ld\n", post_data, post_size);//解析获得的数据string deviceCode;string ptz;Json::Value jvalue;Json::Reader jreader;jreader.parse(request_data, jvalue);deviceCode = jvalue["sUserName"].asString();ptz = jvalue["sPassword"].asString();cout<<"============================\n"<<"deviceCode: "<<deviceCode<<" ptz: "<<ptz<<"\n-------------------------\n"<<endl;//给前段回复一个响应结果Json::Value root;Json::FastWriter fastWriter;root["code"] = Json::Value("200");root["msg"] = Json::Value("成功");cout<<"return post"<<fastWriter.write(root)<<endl;/* 输出到客户端 *///HTTP headerevhttp_add_header(req->output_headers, "Server", MYHTTPD_SIGNATURE);evhttp_add_header(req->output_headers, "Content-Type", "application/json; charset=UTF-8");evhttp_add_header(req->output_headers, "Connection", "close");//输出的内容struct evbuffer *buf;buf = evbuffer_new();evbuffer_add_printf(buf, "%s", fastWriter.write(root).c_str());//将封装好的evbuffer 发送给客户端evhttp_send_reply(req, HTTP_OK, "OK", buf);evbuffer_free(buf);
}void RouteTasks::init_thread(void *arg)
{RouteTasks* rt = (RouteTasks*)arg;rt->init_sub();
}void RouteTasks::init_sub()
{//服务端
//    //初始化event API
//    event_init();//    //创建一个http server
//    struct evhttp *httpd;httpd = evhttp_start(getIp().c_str(), m_port);evhttp_set_timeout(httpd, m_timeout);//也可以为特定的URI指定callbackevhttp_set_cb(httpd, "/cgi-bin/entry.cgi/system/login", &RouteTasks::login, NULL);//循环处理eventsevent_dispatch();//    evhttp_free(httpd);
}string RouteTasks::getIp()
{struct sockaddr_in sin;struct ifreq ifr;int sockfd = socket(AF_INET, SOCK_DGRAM, 0);if(sockfd == -1) {perror("socket error");return "";}strncpy(ifr.ifr_name, ETH_NAME, IFNAMSIZ);if(ioctl(sockfd, SIOCGIFADDR, &ifr) == 0) {memcpy(&sin, &ifr.ifr_addr, sizeof (ifr.ifr_addr));cout<<ETH_NAME<<" ip : "<<inet_ntoa(sin.sin_addr)<<endl;return inet_ntoa(sin.sin_addr);}return "";
}

#include <iostream>
#include "platfromcommunication.h"using namespace std;//当向进程发出SIGTERM/SIGHUP/SIGINT/SIGQUIT的时候，终止event的事件侦听循环
void signal_handler(int sig) {switch (sig) {case SIGTERM:case SIGHUP:case SIGQUIT:case SIGINT:event_loopbreak();  //终止侦听event_dispatch()的事件侦听循环，执行之后的代码break;}
}int main()
{cout<<"hello world"<<endl;signal(SIGHUP, signal_handler);signal(SIGTERM, signal_handler);signal(SIGINT, signal_handler);signal(SIGQUIT, signal_handler);RouteTasks rt;rt.init();while (1) {sleep(1);}return 0;
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/web/51623.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

【HarmonyOS NEXT开发】鸿蒙开发环境准备，ArkTS基础语法入门

【HarmonyOS NEXT开发】鸿蒙开发环境准备，ArkTS基础语法入门

文章目录 鸿蒙开发环境准备&#xff0c;ArkTS基础语法入门大纲简介DevEco Studio简介运行环境要求 安装与配置开发工具下载Harmony OS 和 OpenHarmony 的区别Previewer汉化插件的配置 ArkTS基础快速入门1. 解释说明2. 变量与常量3. 变量命名规则4. 数组5. 函数定义函数调用函数…
阅读更多...
Win10 安装 Rabbitmq

Win10 安装 Rabbitmq

参考文档&#xff1a;https://www.rabbitmq.com/docs/install-windows 一、安装 Erlang 语言 安装 RabbitMQ 需要该语言的支持才能安装 下载地址&#xff1a;https://erlang.org/download/otp_versions_tree.html 点击这里下载最新版本&#xff1a;27.0.1 直接默认 next 更…
阅读更多...
2d像素游戏基本架构

2d像素游戏基本架构

目录 2D像素游戏的基本架构通常包括以下几个关键部分 Unity和虚幻引擎在2D游戏开发中的性能比较 Unity的2D工具设计复杂的地图和场景 创建和管理地图资源&#xff1a; 使用TileMap工具&#xff1a; 构建复杂场景&#xff1a; 添加碰撞体和物理效果&#xff1a; 优化和…
阅读更多...
DNS工作流程

DNS工作流程

DNS&#xff08;域名系统&#xff09; DNS&#xff08;域名系统&#xff09;的工作流程是将人类可读的域名&#xff08;如 www.example.com&#xff09;转换为机器可读的IP地址&#xff08;如 192.0.2.1&#xff09;&#xff0c;以便计算机能够相互通信。DNS查询过程可以分为递…
阅读更多...
企业微信自动回复机器人：提升客户服务与工作效率的智能新篇章

企业微信自动回复机器人：提升客户服务与工作效率的智能新篇章

在快节奏的现代商业环境中&#xff0c;企业如何高效、准确地响应客户需求&#xff0c;成为了衡量其竞争力的重要指标之一。企业微信作为企业内部沟通与客户服务的重要平台&#xff0c;其自动回复机器人的出现&#xff0c;无疑为企业带来了革命性的变革。本文将深入探讨企业微信…
阅读更多...
Android settings命令讲解和实战

Android settings命令讲解和实战

1&#xff0c;简介 在Android系统中&#xff0c;settings命令用于管理设备设置。这些命令可以与Settings提供者&#xff08;Settings provider&#xff09;交互&#xff0c;后者是一个用于存储和检索系统设置的系统服务。Settings provider在Android系统中可以被看作是一个特殊…
阅读更多...
接口测试用例设计：关键步骤与注意事项

接口测试用例设计：关键步骤与注意事项

接口测试是软件测试中至关重要的一部分，它主要验证不同系统或组件之间的数据交换是否准确无误。相比于UI测试，接口测试更早发现问题，因为它直接验证系统的核心逻辑和数据处理。本文将从接口测试用例设计的关键步骤和注意事项展开讨论，并通过具体案例帮助大家更好地理解如何…
阅读更多...
携程：从MySQL迁移OceanBase的数据库发布系统实践

携程：从MySQL迁移OceanBase的数据库发布系统实践

作者简介&#xff1a;杨晓军 现就职于携程的数据库团队&#xff0c;主要负责携程数据库的研发与管理&#xff0c;专注于提升数据库的稳定性。 自分布式关系型数据库OceanBase开源以来&#xff0c;携程已经在线上环境中进行了广泛的应用&#xff0c;取代了原先以MySQL为主力的业…
阅读更多...
Mysql，sqllite表结构对比

Mysql，sqllite表结构对比

本代码用C#实现&#xff0c;对比有差异的字段 &#xff0c;调用类方法Comare 即可获取结果。 public class CompareDataBaseHelper { string mysqlConnectionString "Server127.0.0.1;Databasetestdb;Uidroot;Pwd123456;charsetutf8;"; string sqliteCo…
阅读更多...
组件通信 Vue3

组件通信 Vue3

1.props 1.child <template><div class"child"><h3>子组件</h3><h4>玩具&#xff1a;{{ toy }}</h4><h4>父给的车&#xff1a;{{ car }}</h4><button click"sendToy(toy)">把玩具给父亲</butt…
阅读更多...
通过visual studio进行dump文件调试和分析

通过visual studio进行dump文件调试和分析

0、前言 很多时候程序crash之后需要分析原因。对于C/C程序&#xff0c;一般最常见的场景和方法就是根据dump文件进行分析。 1、分析的前提条件 进行dump文件分析&#xff0c;需要以下文件&#xff1a; 进程crash时产生的dump文件程序源码进程对应的程序exe文件编译exe文件时产…
阅读更多...
【赵渝强老师】MongoDB的存储引擎

【赵渝强老师】MongoDB的存储引擎

存储引擎&#xff08;Storage Engine&#xff09;是MongoDB的核心组件&#xff0c;它负责管理数据如何存储在硬盘&#xff08;Disk&#xff09;和内存&#xff08;Memory&#xff09;上。从MongoDB 3.2 版本开始&#xff0c;MongoDB支持多种类型的数据存储引擎。 视频讲解如下&…
阅读更多...
【ubuntu24.04】腾达U12 8812au无线网卡成功安装

【ubuntu24.04】腾达U12 8812au无线网卡成功安装

U12是腾达2019年的产品 参考：台式机Ubuntu20.04系统下安装Tenda U12 无线网卡驱动当时不支持6.x的内核。官方的ubuntu驱动看起来不能用了。ipconfig /all 查看 Wireless LAN adapter WLAN 2:Connection-specific DNS Suffix . :Description . . . . .
阅读更多...
linux-----内核（Kernel）与文件系统（File System）

linux-----内核（Kernel）与文件系统（File System）

一、内核作用 1.资源管理&#xff1a; 内核负责管理系统资源&#xff0c;包括CPU、内存、设备驱动和网络通信等。它为用户空间提供了一组接口&#xff0c;使得应用程序能够访问底层硬件&#xff0c;而不需要直接与硬件交互。 2.进程管理 内核负责进程的创建、调度、终止等操作…
阅读更多...
使用twilio向手机发短信做监控报警

使用twilio向手机发短信做监控报警

最近遇到个需求&#xff0c;就是夜班HW希望有个监控系统指标&#xff0c;如果异常就向监控人手机打电话的需求。在考察以后&#xff0c;发现目前由于国内防电信诈骗的原因&#xff0c;所以想要使用云通讯功能必须由企业去申请&#xff0c;但作为一个个人的监控项目来说太大了。…
阅读更多...
Python | Leetcode Python题解之第384题打乱数组

Python | Leetcode Python题解之第384题打乱数组

题目&#xff1a; 题解&#xff1a; class Solution:def __init__(self, nums: List[int]):self.nums numsself.original nums.copy()def reset(self) -> List[int]:self.nums self.original.copy()return self.numsdef shuffle(self) -> List[int]:for i in range(l…
阅读更多...
极光推送（JPush）赋能登虹科技，打造智慧视觉云平台新体验

极光推送（JPush）赋能登虹科技，打造智慧视觉云平台新体验

近日&#xff0c;中国领先的客户互动和营销科技服务商极光&#xff08;Aurora Mobile&#xff0c;纳斯达克股票代码&#xff1a;JG&#xff09;与杭州登虹科技有限公司&#xff08;以下简称“登虹科技&#xff08;Closeli&#xff09;”&#xff09;达成合作&#xff0c;借助极…
阅读更多...
Mybatis部分笔记二——Spring：

Mybatis部分笔记二——Spring：

Spring spring是轻量级的&#xff0c;IOC和AOP的一站式java开发框架&#xff0c;简化企业级开发。 其中&#xff1a; 轻量级&#xff1a;框架体积小(核心模块), IOC&#xff1a;Inversion of Control(控制反转),把创建对象的控制权&#xff0c;反转给Spring框架。 以前程序…
阅读更多...
Debian Linux上安装Jumpserver

Debian Linux上安装Jumpserver

1.安装 Debian并配置 登录www.debian.io,下载网络版安装&#xff0c;安装很快&#xff0c;但完成后修改IP就遇到问题vi /etc/network/interfaces auto eth0 #设置开机自动连接网络 iface lo inet loopback allow-hotplug eth0 iface eth0 inet static #static表示使用固定I…
阅读更多...
数分基础（03-3）客户特征分析--Tableau

数分基础（03-3）客户特征分析--Tableau

文章目录 客户特征分析 - Tableau1. 说明2. 思路与步骤3. 数据准备和导入3.1 用EXCEL初步检查和处理数据3.1.1 打开3.1.2 初步检查&#xff08;1&#xff09;缺失值检查缺失值处理 &#xff08;2&#xff09;格式化日期字段&#xff08;3&#xff09;其他字段数据类型 &#xf…
阅读更多...
最新文章

Copyright @ 2022~2023