基本信息

---

下载

   友情提示：（无需注册或充值，赞助后即可获取资源下载链接）

---

     嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：813200300

本次赞助数额为： 2 元　

支付宝支付

微信支付

   源码介绍

---

C 基于mongoose实现HTTP Server

// GEM_http_test.cpp : 定义控制台应用程序的入口点。
//

#include "stdafx.h"
#include "mongoose.h"
#include <string>

using namespace std;

static const char *s_http_port = "21129";
static const char* filename = "RecvData.txt";
static struct mg_serve_http_opts s_http_server_opts;
static const struct mg_str g_get_method = MG_MK_STR("GET");
static const struct mg_str g_post_method = MG_MK_STR("POST");

static const struct mg_str api_prefix_event_report_post = MG_MK_STR("/api/Vehiclefind/ParkState");
static const struct mg_str api_prefix_event_report_get = MG_MK_STR("/EventReportGet");

//判断前缀
int has_prefix(const struct mg_str *uri, const struct mg_str *prefix) 
{
if(uri->len == prefix->len)
{
if( memcmp(uri->p, prefix->p, prefix->len) == 0)
return 1;
}
return 0;
}
//判断相同
int is_equal(const struct mg_str *s1, const struct mg_str *s2) 
{
return s1->len == s2->len && memcmp(s1->p, s2->p, s2->len) == 0;
}

//发送body信息
void mgSendBody(struct mg_connection *nc, const char *content) 
{
mg_send_head(nc, 200, strlen(content), "Content-Type: text/plain\r\nConnection: close");
mg_send(nc, content, strlen(content));
nc->flags |= MG_F_SEND_AND_CLOSE;
}

//发送文件，文件的位置是相对于s_http_server_opts.document_root的路径
void mgSendFile(struct mg_connection *nc, struct http_message *hm, const char* filePath) 
{
mg_http_serve_file(nc, hm, filePath, mg_mk_str("text/plain"), mg_mk_str(""));
}

HRESULT handle_request(void *nc, void *p)
{
struct mg_connection *ncstruc = (struct mg_connection *)nc;
struct http_message *msg = (struct http_message *)p;

//校验前缀
if(is_equal(&msg->method, &g_post_method))
{
char *recvBuf = NULL;
long systembyte=0;

///========================================/
///校验并执行指令
///========================================/
if(has_prefix(&msg->uri, &api_prefix_event_report_post))
{
recvBuf = new char [msg->body.len 1];
memset(recvBuf, 0, msg->body.len 1);
memcpy(recvBuf, msg->body.p, msg->body.len);

printf(recvBuf);
printf("\r\n");


FILE* fp = NULL;
fp = fopen(filename,"r");
unsigned char plain[4096];
int plainlen = 0;
memset(plain,0,sizeof(plain)/sizeof(char));


if (fp == NULL)
{
printf("fopen error");
mgSendBody(ncstruc, "ERROR:file doesn't exist\r\n\r\n");
}
else
{
while(!feof(fp))
{
plainlen = fread(plain,1,4096,fp);
}
const char *senddata = (char *)plain;
mgSendBody(ncstruc, senddata);
fclose(fp);
}

if(recvBuf)
{
delete recvBuf;
recvBuf = NULL;
}
}
}
else if (is_equal(&msg->method, &g_get_method))
{
char *recvBuf = NULL;
long systembyte=0;

///========================================/
///校验并执行指令
///========================================/
if(has_prefix(&msg->uri, &api_prefix_event_report_post))
{
recvBuf = new char [msg->body.len 1];
memset(recvBuf, 0, msg->body.len 1);
memcpy(recvBuf, msg->body.p, msg->body.len);

printf(recvBuf);
printf("\r\n");


FILE* fp = NULL;
fp = fopen(filename,"r");
unsigned char plain[4096];
int plainlen = 0;
memset(plain,0,sizeof(plain)/sizeof(char));


if (fp == NULL)
{
printf("fopen error");
mgSendBody(ncstruc, "ERROR:file doesn't exist\r\n\r\n");
}
else
{
while(!feof(fp))
{
plainlen = fread(plain,1,4096,fp);
}
const char *senddata = (char *)plain;
mgSendBody(ncstruc, senddata);
fclose(fp);
}

if(recvBuf)
{
delete recvBuf;
recvBuf = NULL;
}
}
}

return 0;
}

static void ev_handler(struct mg_connection *nc, int ev, void *p) {

struct mbuf *io = &nc->recv_mbuf;
std::string sHeader, sContent;

double result = 21.2122;
switch (ev) {
case MG_EV_RECV:
break;
case MG_EV_HTTP_REQUEST:
handle_request(nc, (struct http_message *)p);

break;
default:
break;
}

}

int _tmain(int argc, _TCHAR* argv[])
{
struct mg_mgr mgr;
struct mg_connection *nc;

mg_mgr_init(&mgr, NULL);
printf("Starting web server on port %s\n", s_http_port);
nc = mg_bind(&mgr, s_http_port, ev_handler);
if (nc == NULL) {
printf("Failed to create listener\n");
return 1;
}

// Set up HTTP server parameters
mg_set_protocol_http_websocket(nc);
s_http_server_opts.document_root = ".";  // Serve current directory
s_http_server_opts.enable_directory_listing = "yes";

while(1) 
{
mg_mgr_poll(&mgr, 50);
}
mg_mgr_free(&mgr);

return 0;
}