代码:
h文件
#include <iostream>
#include <curl/curl.h>
#include <net/if.h>
#include <sys/ioctl.h>
#include <arpa/inet.h>
#include <string.h>
#include <event.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 "eth0"
#define MYHTTPD_SIGNATURE "MoCarHttpd v0.1"
using namespace std;
class RouteTasks{
public:
RouteTasks();
void init();
private:
static void routeTasks(struct evhttp_request *req, void *arg);
string getIp();
int m_port;
int m_timeout;
};
cpp文件
#include "platfromcommunication.h"
RouteTasks::RouteTasks()
{
m_port = 7777;
m_timeout = 120;
}
void RouteTasks::init()
{
//初始化event API
event_init();
//创建一个http server
struct evhttp *httpd;
httpd = evhttp_start(getIp().c_str(), m_port);
evhttp_set_timeout(httpd, m_timeout);
//也可以为特定的URI指定callback
evhttp_set_cb(httpd, "/wayLine/start", &RouteTasks::routeTasks, NULL);
//循环处理events
event_dispatch();
evhttp_free(httpd);
}
void RouteTasks::routeTasks(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 startRouteTasks connection post_data = [%s], len =%ld\n", post_data, post_size);
//解析获得的数据
string task_code;
string stream;
Json::Value jvalue;
Json::Reader jreader;
jreader.parse(request_data, jvalue);
task_code = jvalue["task_code"].asString();
stream = jvalue["stream"].asString();
cout<<"task_code: "<<task_code<<" stream: "<<stream<<"\n-------------------------"<<endl;
//给前段回复一个响应结果
Json::Value root;
Json::FastWriter fastWriter;
root["code"] = Json::Value("0");
root["msg"] = Json::Value("成功");
cout<<"return post"<<fastWriter.write(root)<<endl;
/* 输出到客户端 */
//HTTP header
evhttp_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 "";
}
main文件
#include <iostream>
#include <signal.h>
#include <jsoncpp/json/json.h>
#include <event.h>
#include <unistd.h>
#include "...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 post与get请求:c++ curl post和get请求返回数据解析_c++解析curl返回的json_小鱼仙官的博客-CSDN博客