#include "stdio.h"
#include <stdlib.h>
#include <unistd.h>
#include <iostream>
#include "CommonUtils.h"
#include "address.h"
#include "tcpserver.h"
#include "httpserver.h"
#include "httprequest.h"
#include "httpresponse.h"
#include "httpconnection.h"
using namespace std;
using namespace tnet;
using namespace std::placeholders;
//==================================================================//
//全局变量
std::vector<string> vecMessageQueque;
volatile int g_iVarTest = 0;
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
//==================================================================//
void onHandler(const HttpConnectionPtr_t& conn, const HttpRequest& request)
{
printf("HTTP接收数据:%s\n" , request.body.c_str());
g_iVarTest += 1;
printf("变量值地址:%d\n" , g_iVarTest);
//=============================================================//
//构造应答
HttpResponse resp;
resp.statusCode = 200;
resp.setContentType("text/html");
resp.setKeepAlive(true);
resp.enableDate();
resp.body.append("recvdata: success"); //json字符串
conn->send(resp);
//=============================================================//
}
//消息队列调度线程
void* MessageProcThread(void* lpParameter)
{
int i = 0;
char buffer[1024];
while (true)
{
printf("消息处理数量:%d\n" , g_iVarTest);
sleep(1);
}
}
//消息队列调度线程
void* HttpServiceThread(void* lpParameter)
{
TcpServer s;
HttpServer httpd(&s);
printf("HTTP服务启动正常...\n");
httpd.setHttpCallback("/service/", std::bind(&onHandler, _1, _2));
httpd.listen(Address(11181));
s.start(4);
}
int main()
{
//创建消息处理线程
//========================================================//
//传入的时候必须强制转换为void* 类型,即无类型指针
pthread_t hMsgProcThread;
pthread_create(&hMsgProcThread, NULL, MessageProcThread, NULL);
//测试http服务
//========================================================//
pthread_t hHttpServiceThread;
pthread_create(&hHttpServiceThread, NULL, HttpServiceThread, NULL);
//========================================================//
while (true )
{
char ch = getchar();
if (ch =='#') break;
}
return 0;
}
代码如上,g_iVarTest这个值已经改变,MessageProcThread线程访问的结果与onHandler回调的结果不一样,求高手解答以下!