1
This commit is contained in:
aozhiwei
parent
9ea0b6fb22
commit
bdd60d2aa3
23
.gitignore
vendored
Normal file
23
.gitignore
vendored
Normal file
@ -0,0 +1,23 @@
|
|||||||
|
*.*\~
|
||||||
|
*.*~
|
||||||
|
*.*\#
|
||||||
|
*.*#
|
||||||
|
\#*
|
||||||
|
\.\#*
|
||||||
|
~*.*
|
||||||
|
\#*.*
|
||||||
|
*.pb.*
|
||||||
|
CMakeCache.txt
|
||||||
|
cmake_install.cmake
|
||||||
|
CMakeFiles
|
||||||
|
Makefile
|
||||||
|
server/bin
|
||||||
|
__pycache__
|
||||||
|
*pb2.py
|
||||||
|
*.pyc
|
||||||
|
*.out
|
||||||
|
.vs
|
||||||
|
.user
|
||||||
|
game.py
|
||||||
|
*.cxx
|
||||||
|
compile_commands.json
|
||||||
117
server/textserver/CMakeLists.txt
Normal file
117
server/textserver/CMakeLists.txt
Normal file
@ -0,0 +1,117 @@
|
|||||||
|
project(textserver)
|
||||||
|
cmake_minimum_required(VERSION 2.8)
|
||||||
|
|
||||||
|
set(GAME_ID 9006)
|
||||||
|
|
||||||
|
if (${RELEASE})
|
||||||
|
set(CMAKE_BUILD_TYPE "Release")
|
||||||
|
message("release mode")
|
||||||
|
else()
|
||||||
|
set(CMAKE_BUILD_TYPE "Debug")
|
||||||
|
message("debug mode")
|
||||||
|
endif()
|
||||||
|
set(CMAKE_CXX_FLAGS_RELEASE "-O3 -Wall -g -std=gnu++11 -DNDEBUG -DGAME_ID=${GAME_ID} ")
|
||||||
|
set(CMAKE_CXX_FLAGS_DEBUG "-Wall -g -std=gnu++11 -DDEBUG -DGAME_ID=${GAME_ID} ")
|
||||||
|
|
||||||
|
include_directories(
|
||||||
|
AFTER
|
||||||
|
../../third_party/a8engine
|
||||||
|
/usr/include/mysql
|
||||||
|
/usr/include/jsoncpp
|
||||||
|
/usr/include/hiredis
|
||||||
|
/usr/include/eigen3
|
||||||
|
/usr/include/glm
|
||||||
|
../../third_party
|
||||||
|
../../third_party/behaviac/inc
|
||||||
|
../../third_party/recastnavigation/Recast/Include
|
||||||
|
../../third_party/recastnavigation/Detour/Include
|
||||||
|
../../third_party/recastnavigation/DetourTileCache/Include
|
||||||
|
.
|
||||||
|
)
|
||||||
|
|
||||||
|
link_directories(
|
||||||
|
/usr/lib64/mysql
|
||||||
|
/usr/local/lib
|
||||||
|
../../third_party/behaviac/lib
|
||||||
|
)
|
||||||
|
|
||||||
|
aux_source_directory(../../third_party/a8engine/a8
|
||||||
|
SRC_LIST
|
||||||
|
)
|
||||||
|
|
||||||
|
aux_source_directory(../../third_party/framework/cpp
|
||||||
|
SRC_LIST
|
||||||
|
)
|
||||||
|
|
||||||
|
aux_source_directory(../../third_party/recastnavigation/Detour/Source
|
||||||
|
SRC_LIST
|
||||||
|
)
|
||||||
|
|
||||||
|
aux_source_directory(../../third_party/recastnavigation/Recast/Source
|
||||||
|
SRC_LIST
|
||||||
|
)
|
||||||
|
|
||||||
|
aux_source_directory(../../third_party/recastnavigation/DetourTileCache/Source
|
||||||
|
SRC_LIST
|
||||||
|
)
|
||||||
|
|
||||||
|
aux_source_directory(.
|
||||||
|
SRC_LIST
|
||||||
|
)
|
||||||
|
|
||||||
|
execute_process(
|
||||||
|
COMMAND touch -a metatable.pb.h
|
||||||
|
COMMAND touch -a metatable.pb.cc
|
||||||
|
)
|
||||||
|
add_executable(
|
||||||
|
textserver ${SRC_LIST}
|
||||||
|
)
|
||||||
|
|
||||||
|
add_custom_target(script_pb_protocol ALL)
|
||||||
|
add_custom_command(TARGET script_pb_protocol
|
||||||
|
PRE_BUILD
|
||||||
|
COMMAND python ../../third_party/tools/scripts/construct/build_pb.py --cpp_out=. --pb_files=metatable
|
||||||
|
)
|
||||||
|
add_dependencies(textserver script_pb_protocol)
|
||||||
|
|
||||||
|
set(EXECUTABLE_OUTPUT_PATH
|
||||||
|
${PROJECT_BINARY_DIR}/../bin
|
||||||
|
)
|
||||||
|
|
||||||
|
if (CMAKE_BUILD_TYPE STREQUAL "Debug")
|
||||||
|
target_link_libraries(
|
||||||
|
textserver
|
||||||
|
pthread
|
||||||
|
mysqlclient
|
||||||
|
protobuf
|
||||||
|
rt
|
||||||
|
dl
|
||||||
|
util
|
||||||
|
crypto
|
||||||
|
ssl
|
||||||
|
jsoncpp
|
||||||
|
curl
|
||||||
|
hiredis
|
||||||
|
tinyxml2
|
||||||
|
behaviac_gcc_debug
|
||||||
|
)
|
||||||
|
else()
|
||||||
|
target_link_libraries(
|
||||||
|
textserver
|
||||||
|
pthread
|
||||||
|
mysqlclient
|
||||||
|
protobuf
|
||||||
|
rt
|
||||||
|
dl
|
||||||
|
util
|
||||||
|
crypto
|
||||||
|
ssl
|
||||||
|
jsoncpp
|
||||||
|
curl
|
||||||
|
hiredis
|
||||||
|
tinyxml2
|
||||||
|
tcmalloc
|
||||||
|
behaviac_gcc_release
|
||||||
|
)
|
||||||
|
endif()
|
||||||
|
|
||||||
429
server/textserver/app.cc
Executable file
429
server/textserver/app.cc
Executable file
@ -0,0 +1,429 @@
|
|||||||
|
#include "precompile.h"
|
||||||
|
|
||||||
|
#include <signal.h>
|
||||||
|
#include <string.h>
|
||||||
|
#include <unistd.h>
|
||||||
|
#include <mutex>
|
||||||
|
#include <condition_variable>
|
||||||
|
|
||||||
|
#include <a8/redis.h>
|
||||||
|
#include <a8/timer.h>
|
||||||
|
#include <a8/uuid.h>
|
||||||
|
|
||||||
|
#include "framework/cpp/netmsghandler.h"
|
||||||
|
|
||||||
|
#include "app.h"
|
||||||
|
#include "jsondatamgr.h"
|
||||||
|
#include "handlermgr.h"
|
||||||
|
#include "perfmonitor.h"
|
||||||
|
#include "metamgr.h"
|
||||||
|
|
||||||
|
#include "ss_msgid.pb.h"
|
||||||
|
#include "ss_proto.pb.h"
|
||||||
|
|
||||||
|
#include "framework/cpp/msgqueue.h"
|
||||||
|
#include "framework/cpp/tglog.h"
|
||||||
|
|
||||||
|
struct MsgNode
|
||||||
|
{
|
||||||
|
SocketFrom_e sockfrom;
|
||||||
|
int sockhandle;
|
||||||
|
unsigned short msgid;
|
||||||
|
unsigned int seqid;
|
||||||
|
long ip_saddr;
|
||||||
|
char* buf;
|
||||||
|
int buflen;
|
||||||
|
MsgNode* next;
|
||||||
|
};
|
||||||
|
|
||||||
|
struct IMMsgNode
|
||||||
|
{
|
||||||
|
unsigned short msgid;
|
||||||
|
a8::XParams params;
|
||||||
|
IMMsgNode* next = nullptr;
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
const char* const PROJ_LOG_ROOT_FMT = "/data/logs/%s/logs";
|
||||||
|
const char* const PROJ_LOG_FILENAME_FMT = "log_$pid_%Y%m%d.log";
|
||||||
|
|
||||||
|
void App::Init(int argc, char* argv[])
|
||||||
|
{
|
||||||
|
nowtime = time(nullptr);
|
||||||
|
signal(SIGPIPE, SIG_IGN);
|
||||||
|
this->argc = argc;
|
||||||
|
this->argv = argv;
|
||||||
|
|
||||||
|
if (!ParseOpt()) {
|
||||||
|
terminated = true;
|
||||||
|
if (instance_id <= 0) {
|
||||||
|
a8::XPrintf("friend_rankserver启动失败,缺少-i参数\n", {});
|
||||||
|
} else if (instance_id > MAX_INSTANCE_ID) {
|
||||||
|
a8::XPrintf("friend_rankserver启动失败,-i参数不能大于%d\n", {MAX_INSTANCE_ID});
|
||||||
|
}
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
a8::XPrintf("rankserver starting instance_id:%d pid:%d\n", {instance_id, getpid()});
|
||||||
|
|
||||||
|
loop_mutex_ = new std::mutex();
|
||||||
|
loop_cond_ = new std::condition_variable();
|
||||||
|
msg_mutex_ = new std::mutex();
|
||||||
|
im_msg_mutex_ = new std::mutex();
|
||||||
|
|
||||||
|
srand(time(nullptr));
|
||||||
|
InitLog();
|
||||||
|
HandlerMgr::Instance()->Init();
|
||||||
|
a8::Timer::Instance()->Init();
|
||||||
|
PerfMonitor::Instance()->Init();
|
||||||
|
f8::MsgQueue::Instance()->Init();
|
||||||
|
f8::TGLog::Instance()->Init(a8::Format(PROJ_NAME_FMT, {}), false);
|
||||||
|
JsonDataMgr::Instance()->Init();
|
||||||
|
uuid.SetMachineId(instance_id);
|
||||||
|
MetaMgr::Instance()->Init();
|
||||||
|
|
||||||
|
a8::UdpLog::Instance()->Info("rankserver starting instance_id:%d pid:%d", {instance_id, getpid()});
|
||||||
|
}
|
||||||
|
|
||||||
|
void App::UnInit()
|
||||||
|
{
|
||||||
|
if (terminated) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
MetaMgr::Instance()->UnInit();
|
||||||
|
JsonDataMgr::Instance()->UnInit();
|
||||||
|
f8::MsgQueue::Instance()->UnInit();
|
||||||
|
PerfMonitor::Instance()->UnInit();
|
||||||
|
a8::Timer::Instance()->UnInit();
|
||||||
|
HandlerMgr::Instance()->UnInit();
|
||||||
|
f8::TGLog::Instance()->UnInit();
|
||||||
|
UnInitLog();
|
||||||
|
|
||||||
|
A8_SAFE_DELETE(im_msg_mutex_);
|
||||||
|
A8_SAFE_DELETE(msg_mutex_);
|
||||||
|
A8_SAFE_DELETE(loop_cond_);
|
||||||
|
A8_SAFE_DELETE(loop_mutex_);
|
||||||
|
}
|
||||||
|
|
||||||
|
int App::Run()
|
||||||
|
{
|
||||||
|
if (terminated) {
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
int ret = 0;
|
||||||
|
a8::UdpLog::Instance()->Info("rankserver running", {});
|
||||||
|
last_run_tick_ = a8::XGetTickCount();
|
||||||
|
int delta_time = 0;
|
||||||
|
while (!terminated) {
|
||||||
|
a8::tick_t begin_tick = a8::XGetTickCount();
|
||||||
|
nowtime = time(nullptr);
|
||||||
|
QuickExecute(delta_time);
|
||||||
|
SlowerExecute(delta_time);
|
||||||
|
Schedule();
|
||||||
|
a8::tick_t end_tick = a8::XGetTickCount();
|
||||||
|
if (end_tick - begin_tick > PerfMonitor::Instance()->max_run_delay_time) {
|
||||||
|
PerfMonitor::Instance()->max_run_delay_time = end_tick - begin_tick;
|
||||||
|
}
|
||||||
|
delta_time = end_tick - begin_tick;
|
||||||
|
}
|
||||||
|
return ret;
|
||||||
|
}
|
||||||
|
|
||||||
|
void App::AddSocketMsg(SocketFrom_e sockfrom,
|
||||||
|
int sockhandle,
|
||||||
|
long ip_saddr,
|
||||||
|
unsigned short msgid,
|
||||||
|
unsigned int seqid,
|
||||||
|
const char *msgbody,
|
||||||
|
int bodylen)
|
||||||
|
{
|
||||||
|
MsgNode *p = (MsgNode*) malloc(sizeof(MsgNode));
|
||||||
|
memset(p, 0, sizeof(MsgNode));
|
||||||
|
p->sockfrom = sockfrom;
|
||||||
|
p->ip_saddr = ip_saddr;
|
||||||
|
p->sockhandle = sockhandle;
|
||||||
|
p->msgid = msgid;
|
||||||
|
p->seqid = seqid;
|
||||||
|
p->buf = nullptr;
|
||||||
|
p->buflen = bodylen;
|
||||||
|
if (bodylen > 0) {
|
||||||
|
p->buf = (char*)malloc(bodylen);
|
||||||
|
memmove(p->buf, msgbody, bodylen);
|
||||||
|
}
|
||||||
|
msg_mutex_->lock();
|
||||||
|
if (bot_node_) {
|
||||||
|
bot_node_->next = p;
|
||||||
|
bot_node_ = p;
|
||||||
|
} else {
|
||||||
|
top_node_ = p;
|
||||||
|
bot_node_ = p;
|
||||||
|
}
|
||||||
|
++msgnode_size_;
|
||||||
|
msg_mutex_->unlock();
|
||||||
|
NotifyLoopCond();
|
||||||
|
}
|
||||||
|
|
||||||
|
void App::AddIMMsg(unsigned short imcmd, a8::XParams params)
|
||||||
|
{
|
||||||
|
IMMsgNode *p = new IMMsgNode;
|
||||||
|
p->msgid = imcmd;
|
||||||
|
p->params = params;
|
||||||
|
p->next = nullptr;
|
||||||
|
im_msg_mutex_->lock();
|
||||||
|
if (im_bot_node_) {
|
||||||
|
im_bot_node_->next = p;
|
||||||
|
im_bot_node_ = p;
|
||||||
|
} else {
|
||||||
|
im_top_node_ = p;
|
||||||
|
im_bot_node_ = p;
|
||||||
|
}
|
||||||
|
im_msg_mutex_->unlock();
|
||||||
|
NotifyLoopCond();
|
||||||
|
}
|
||||||
|
|
||||||
|
void App::QuickExecute(int delta_time)
|
||||||
|
{
|
||||||
|
ProcessIMMsg();
|
||||||
|
DispatchMsg();
|
||||||
|
a8::Timer::Instance()->Update();
|
||||||
|
}
|
||||||
|
|
||||||
|
void App::SlowerExecute(int delta_time)
|
||||||
|
{
|
||||||
|
}
|
||||||
|
|
||||||
|
void App::NotifyLoopCond()
|
||||||
|
{
|
||||||
|
std::unique_lock<std::mutex> lk(*loop_mutex_);
|
||||||
|
loop_cond_->notify_all();
|
||||||
|
}
|
||||||
|
|
||||||
|
void App::Schedule()
|
||||||
|
{
|
||||||
|
#if 1
|
||||||
|
{
|
||||||
|
std::unique_lock<std::mutex> lk(*loop_mutex_);
|
||||||
|
loop_cond_->wait_for(lk, std::chrono::milliseconds(1));
|
||||||
|
}
|
||||||
|
#else
|
||||||
|
std::unique_lock<std::mutex> lk(*loop_mutex_);
|
||||||
|
if (!HasTask()) {
|
||||||
|
int sleep_time = a8::Timer::Instance()->GetIdleableMillSeconds();
|
||||||
|
loop_cond_->wait_for(lk, std::chrono::milliseconds(sleep_time));
|
||||||
|
if (sleep_time > perf.max_timer_idle) {
|
||||||
|
perf.max_timer_idle = sleep_time;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
#endif
|
||||||
|
}
|
||||||
|
|
||||||
|
bool App::HasTask()
|
||||||
|
{
|
||||||
|
{
|
||||||
|
if (!im_work_node_) {
|
||||||
|
im_msg_mutex_->lock();
|
||||||
|
if (!im_work_node_ && im_top_node_) {
|
||||||
|
im_work_node_ = im_top_node_;
|
||||||
|
im_top_node_ = nullptr;
|
||||||
|
im_bot_node_ = nullptr;
|
||||||
|
}
|
||||||
|
im_msg_mutex_->unlock();
|
||||||
|
}
|
||||||
|
if (im_work_node_) {
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
{
|
||||||
|
if (!work_node_) {
|
||||||
|
msg_mutex_->lock();
|
||||||
|
if (!work_node_ && top_node_) {
|
||||||
|
work_node_ = top_node_;
|
||||||
|
top_node_ = nullptr;
|
||||||
|
bot_node_ = nullptr;
|
||||||
|
}
|
||||||
|
msg_mutex_->unlock();
|
||||||
|
}
|
||||||
|
if (work_node_) {
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
void App::DispatchMsg()
|
||||||
|
{
|
||||||
|
long long starttick = a8::XGetTickCount();
|
||||||
|
if (!work_node_ && top_node_) {
|
||||||
|
msg_mutex_->lock();
|
||||||
|
work_node_ = top_node_;
|
||||||
|
top_node_ = nullptr;
|
||||||
|
bot_node_ = nullptr;
|
||||||
|
working_msgnode_size_ = msgnode_size_;
|
||||||
|
msg_mutex_->unlock();
|
||||||
|
}
|
||||||
|
|
||||||
|
f8::MsgHdr hdr;
|
||||||
|
while (work_node_) {
|
||||||
|
MsgNode *pdelnode = work_node_;
|
||||||
|
work_node_ = pdelnode->next;
|
||||||
|
hdr.msgid = pdelnode->msgid;
|
||||||
|
hdr.seqid = pdelnode->seqid;
|
||||||
|
hdr.socket_handle = pdelnode->sockhandle;
|
||||||
|
hdr.buf = pdelnode->buf;
|
||||||
|
hdr.buflen = pdelnode->buflen;
|
||||||
|
hdr.offset = 0;
|
||||||
|
hdr.ip_saddr = pdelnode->ip_saddr;
|
||||||
|
switch (pdelnode->sockfrom) {
|
||||||
|
case SF_IMServer:
|
||||||
|
{
|
||||||
|
ProcessIMServerMsg(hdr);
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
if (pdelnode->buf) {
|
||||||
|
free(pdelnode->buf);
|
||||||
|
}
|
||||||
|
free(pdelnode);
|
||||||
|
working_msgnode_size_--;
|
||||||
|
if (a8::XGetTickCount() - starttick > 200) {
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}//end while
|
||||||
|
|
||||||
|
if (!work_node_) {
|
||||||
|
working_msgnode_size_ = 0;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
void App::ProcessIMServerMsg(f8::MsgHdr& hdr)
|
||||||
|
{
|
||||||
|
f8::NetMsgHandler* handler = f8::GetNetMsgHandler(&HandlerMgr::Instance()->immsghandler,
|
||||||
|
hdr.msgid);
|
||||||
|
if (handler) {
|
||||||
|
#ifdef DEBUG
|
||||||
|
f8::DumpMsgToLog(hdr, handler, ">>>>>>IMS ");
|
||||||
|
#endif
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
void App::ProcessIMMsg()
|
||||||
|
{
|
||||||
|
if (!im_work_node_ && im_top_node_) {
|
||||||
|
im_msg_mutex_->lock();
|
||||||
|
im_work_node_ = im_top_node_;
|
||||||
|
im_top_node_ = nullptr;
|
||||||
|
im_bot_node_ = nullptr;
|
||||||
|
im_msg_mutex_->unlock();
|
||||||
|
}
|
||||||
|
while (im_work_node_) {
|
||||||
|
IMMsgNode *pdelnode = im_work_node_;
|
||||||
|
switch (im_work_node_->msgid) {
|
||||||
|
case f8::IM_SysMsgQueue:
|
||||||
|
{
|
||||||
|
const a8::XParams* param = (const a8::XParams*)pdelnode->params.param1.GetUserData();
|
||||||
|
f8::MsgQueue::Instance()->ProcessMsg(pdelnode->params.sender.GetInt(),
|
||||||
|
*param
|
||||||
|
);
|
||||||
|
delete param;
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case IM_ClientSocketDisconnect:
|
||||||
|
{
|
||||||
|
#if 0
|
||||||
|
PlayerMgr::Instance()->OnClientDisconnect(pdelnode->params);
|
||||||
|
#endif
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case IM_IMSSocketDisconnect:
|
||||||
|
{
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case IM_ExecGM:
|
||||||
|
{
|
||||||
|
HandlerMgr::Instance()->ProcGMMsg(pdelnode->params.param3,
|
||||||
|
pdelnode->params.sender,
|
||||||
|
pdelnode->params.param1.GetString(),
|
||||||
|
pdelnode->params.param2.GetString()
|
||||||
|
);
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
im_work_node_ = im_work_node_->next;
|
||||||
|
delete pdelnode;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
void App::InitLog()
|
||||||
|
{
|
||||||
|
std::string filename_fmt = PROJ_LOG_FILENAME_FMT;
|
||||||
|
a8::ReplaceString(filename_fmt, "$pid", a8::XValue(getpid()));
|
||||||
|
|
||||||
|
std::string proj_root_dir = a8::Format(PROJ_ROOT_FMT, {a8::Format(PROJ_NAME_FMT,{})});
|
||||||
|
std::string proj_log_root_dir = a8::Format(PROJ_LOG_ROOT_FMT, {a8::Format(PROJ_NAME_FMT, {})});
|
||||||
|
std::string log_file_name = a8::Format(PROJ_LOG_ROOT_FMT,
|
||||||
|
{a8::Format(PROJ_NAME_FMT, {})}) + "/" + filename_fmt;
|
||||||
|
|
||||||
|
a8::MkDir(proj_root_dir);
|
||||||
|
a8::MkDir(proj_log_root_dir);
|
||||||
|
a8::UdpLog::Instance()->SetLogFileName(log_file_name);
|
||||||
|
a8::UdpLog::Instance()->Init();
|
||||||
|
a8::UdpLog::Instance()->Info("proj_root_dir:%s", {proj_root_dir});
|
||||||
|
a8::UdpLog::Instance()->Info("proj_log_root_dir:%s", {proj_log_root_dir});
|
||||||
|
a8::UdpLog::Instance()->Info("log_file_name:%s", {log_file_name});
|
||||||
|
}
|
||||||
|
|
||||||
|
void App::UnInitLog()
|
||||||
|
{
|
||||||
|
a8::UdpLog::Instance()->UnInit();
|
||||||
|
}
|
||||||
|
|
||||||
|
bool App::ParseOpt()
|
||||||
|
{
|
||||||
|
int ch = 0;
|
||||||
|
while ((ch = getopt(argc, argv, "n:i:t:r:f:")) != -1) {
|
||||||
|
switch (ch) {
|
||||||
|
case 'i':
|
||||||
|
{
|
||||||
|
instance_id = a8::XValue(optarg);
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 't':
|
||||||
|
{
|
||||||
|
is_test_mode = true;
|
||||||
|
test_param = a8::XValue(optarg);
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case 'f':
|
||||||
|
{
|
||||||
|
std::vector<std::string> strings;
|
||||||
|
a8::Split(optarg, strings, ',');
|
||||||
|
for (auto& str : strings) {
|
||||||
|
flags.insert(a8::XValue(str).GetInt());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return instance_id > 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
long long App::NewUuid()
|
||||||
|
{
|
||||||
|
return uuid.Generate();
|
||||||
|
}
|
||||||
|
|
||||||
|
a8::XParams* App::AddContext(long long context_id)
|
||||||
|
{
|
||||||
|
context_hash_[context_id] = a8::XParams();
|
||||||
|
return GetContext(context_id);
|
||||||
|
}
|
||||||
|
|
||||||
|
void App::DelContext(long long context_id)
|
||||||
|
{
|
||||||
|
context_hash_.erase(context_id);
|
||||||
|
}
|
||||||
|
|
||||||
|
a8::XParams* App::GetContext(long long context_id)
|
||||||
|
{
|
||||||
|
auto itr = context_hash_.find(context_id);
|
||||||
|
return itr != context_hash_.end() ? &(itr->second) : nullptr;
|
||||||
|
}
|
||||||
86
server/textserver/app.h
Normal file
86
server/textserver/app.h
Normal file
@ -0,0 +1,86 @@
|
|||||||
|
#pragma once
|
||||||
|
|
||||||
|
#include <a8/uuid.h>
|
||||||
|
|
||||||
|
struct MsgNode;
|
||||||
|
struct IMMsgNode;
|
||||||
|
class App : public a8::Singleton<App>
|
||||||
|
{
|
||||||
|
private:
|
||||||
|
App() {};
|
||||||
|
friend class a8::Singleton<App>;
|
||||||
|
|
||||||
|
public:
|
||||||
|
|
||||||
|
void Init(int argc, char* argv[]);
|
||||||
|
void UnInit();
|
||||||
|
|
||||||
|
int Run();
|
||||||
|
|
||||||
|
void AddSocketMsg(SocketFrom_e sockfrom,
|
||||||
|
int sockhandle,
|
||||||
|
long ip_saddr,
|
||||||
|
unsigned short msgid,
|
||||||
|
unsigned int seqid,
|
||||||
|
const char *msgbody,
|
||||||
|
int bodylen);
|
||||||
|
void AddIMMsg(unsigned short imcmd, a8::XParams params);
|
||||||
|
|
||||||
|
void NotifyLoopCond();
|
||||||
|
|
||||||
|
long long NewUuid();
|
||||||
|
a8::XParams* AddContext(long long context_id);
|
||||||
|
void DelContext(long long context_id);
|
||||||
|
a8::XParams* GetContext(long long context_id);
|
||||||
|
|
||||||
|
private:
|
||||||
|
void QuickExecute(int delta_time);
|
||||||
|
void SlowerExecute(int delta_time);
|
||||||
|
void Schedule();
|
||||||
|
bool HasTask();
|
||||||
|
|
||||||
|
void DispatchMsg();
|
||||||
|
void ProcessIMMsg();
|
||||||
|
|
||||||
|
void ProcessIMServerMsg(f8::MsgHdr& hdr);
|
||||||
|
|
||||||
|
void InitLog();
|
||||||
|
void UnInitLog();
|
||||||
|
|
||||||
|
bool ParseOpt();
|
||||||
|
|
||||||
|
public:
|
||||||
|
int argc = 0;
|
||||||
|
char** argv = nullptr;
|
||||||
|
volatile bool terminated = false;
|
||||||
|
a8::uuid::SnowFlake uuid;
|
||||||
|
time_t nowtime = 0;
|
||||||
|
|
||||||
|
public:
|
||||||
|
int instance_id = 0;
|
||||||
|
bool is_test_mode = false;
|
||||||
|
int test_param = 0;
|
||||||
|
std::set<int> flags;
|
||||||
|
|
||||||
|
private:
|
||||||
|
long long last_run_tick_ = 0;
|
||||||
|
std::mutex *loop_mutex_ = nullptr;
|
||||||
|
std::condition_variable *loop_cond_ = nullptr;
|
||||||
|
|
||||||
|
std::mutex *msg_mutex_ = nullptr;
|
||||||
|
MsgNode* top_node_ = nullptr;
|
||||||
|
MsgNode* bot_node_ = nullptr;
|
||||||
|
MsgNode* work_node_ = nullptr;
|
||||||
|
|
||||||
|
std::mutex* im_msg_mutex_ = nullptr;
|
||||||
|
IMMsgNode* im_top_node_ = nullptr;
|
||||||
|
IMMsgNode* im_bot_node_ = nullptr;
|
||||||
|
IMMsgNode* im_work_node_ = nullptr;
|
||||||
|
|
||||||
|
std::map<long long, a8::XParams> context_hash_;
|
||||||
|
|
||||||
|
public:
|
||||||
|
int msgnode_size_ = 0 ;
|
||||||
|
int working_msgnode_size_ = 0;
|
||||||
|
|
||||||
|
};
|
||||||
27
server/textserver/constant.h
Executable file
27
server/textserver/constant.h
Executable file
@ -0,0 +1,27 @@
|
|||||||
|
#pragma once
|
||||||
|
|
||||||
|
enum SocketFrom_e
|
||||||
|
{
|
||||||
|
SF_IMServer,
|
||||||
|
};
|
||||||
|
|
||||||
|
enum InnerMesssage_e
|
||||||
|
{
|
||||||
|
IM_ClientSocketDisconnect = 100,
|
||||||
|
IM_IMSSocketDisconnect,
|
||||||
|
IM_ExecGM,
|
||||||
|
IM_HttpResponse,
|
||||||
|
};
|
||||||
|
|
||||||
|
//网络处理对象
|
||||||
|
enum NetHandler_e
|
||||||
|
{
|
||||||
|
HID_IMSMgr,
|
||||||
|
};
|
||||||
|
|
||||||
|
const char* const PROJ_NAME_FMT = "textserver";
|
||||||
|
const char* const PROJ_ROOT_FMT = "/data/logs/%s";
|
||||||
|
|
||||||
|
const float TEN_W = 10000 * 10;
|
||||||
|
|
||||||
|
const int MAX_INSTANCE_ID = 1023;
|
||||||
80
server/textserver/handlermgr.cc
Normal file
80
server/textserver/handlermgr.cc
Normal file
@ -0,0 +1,80 @@
|
|||||||
|
#include "precompile.h"
|
||||||
|
|
||||||
|
#include <a8/mutable_xobject.h>
|
||||||
|
|
||||||
|
#include "handlermgr.h"
|
||||||
|
|
||||||
|
#include "app.h"
|
||||||
|
#include "perfmonitor.h"
|
||||||
|
|
||||||
|
static void _GMOpsSelfChecking(f8::JsonHttpRequest* request)
|
||||||
|
{
|
||||||
|
request->resp_xobj->SetVal("errcode", 0);
|
||||||
|
request->resp_xobj->SetVal("errmsg", "");
|
||||||
|
request->resp_xobj->SetVal("healthy", 1);
|
||||||
|
request->resp_xobj->SetVal("max_rundelay", PerfMonitor::Instance()->max_run_delay_time);
|
||||||
|
request->resp_xobj->SetVal("max_timer_idle", PerfMonitor::Instance()->max_timer_idle);
|
||||||
|
}
|
||||||
|
|
||||||
|
static void _GMOpsReload(f8::JsonHttpRequest* request)
|
||||||
|
{
|
||||||
|
request->resp_xobj->SetVal("errcode", 0);
|
||||||
|
request->resp_xobj->SetVal("errmsg", "");
|
||||||
|
a8::UdpLog::Instance()->Warning("reload config files", {});
|
||||||
|
}
|
||||||
|
|
||||||
|
void HandlerMgr::Init()
|
||||||
|
{
|
||||||
|
RegisterNetMsgHandlers();
|
||||||
|
RegisterGMMsgHandler("Ops@selfChecking", _GMOpsSelfChecking);
|
||||||
|
RegisterGMMsgHandler("Ops@reload", _GMOpsReload);
|
||||||
|
}
|
||||||
|
|
||||||
|
void HandlerMgr::UnInit()
|
||||||
|
{
|
||||||
|
}
|
||||||
|
|
||||||
|
void HandlerMgr::RegisterNetMsgHandlers()
|
||||||
|
{
|
||||||
|
}
|
||||||
|
|
||||||
|
void HandlerMgr::ProcGMMsg(unsigned long saddr, int sockhandle,
|
||||||
|
const std::string& url, const std::string& querystr)
|
||||||
|
{
|
||||||
|
if (url != "/webapp/index.php") {
|
||||||
|
//IMListener::Instance()->SendText(sockhandle, a8::HttpResponse(404, ""));
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
a8::HTTPRequest request;
|
||||||
|
a8::ParserUrlQueryString(querystr.c_str(), request);
|
||||||
|
|
||||||
|
std::string msgname = a8::Get(request, "c").GetString() + "@" + a8::Get(request, "a").GetString();
|
||||||
|
auto itr = gmhandlers_.find(msgname);
|
||||||
|
if (itr != gmhandlers_.end()) {
|
||||||
|
f8::JsonHttpRequest* request = new f8::JsonHttpRequest;
|
||||||
|
request->saddr = saddr;
|
||||||
|
request->socket_handle = sockhandle;
|
||||||
|
request->query_str = querystr;
|
||||||
|
request->request.ReadFromUrlQueryString(querystr);
|
||||||
|
request->resp_xobj->SetVal("errcode", 0);
|
||||||
|
request->resp_xobj->SetVal("errmsg", "");
|
||||||
|
itr->second(request);
|
||||||
|
|
||||||
|
if (!request->pending){
|
||||||
|
std::string response;
|
||||||
|
request->resp_xobj->ToJsonStr(response);
|
||||||
|
//IMListener::Instance()->SendText(sockhandle, a8::HttpResponse(response));
|
||||||
|
|
||||||
|
delete request;
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
//IMListener::Instance()->SendText(sockhandle, a8::HttpResponse("{}"));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
void HandlerMgr::RegisterGMMsgHandler(const std::string& msgname,
|
||||||
|
void (*handler)(f8::JsonHttpRequest*))
|
||||||
|
{
|
||||||
|
gmhandlers_[msgname] = handler;
|
||||||
|
}
|
||||||
36
server/textserver/handlermgr.h
Normal file
36
server/textserver/handlermgr.h
Normal file
@ -0,0 +1,36 @@
|
|||||||
|
#pragma once
|
||||||
|
|
||||||
|
#include <a8/basehttpsession.h>
|
||||||
|
|
||||||
|
#include "framework/cpp/netmsghandler.h"
|
||||||
|
|
||||||
|
namespace a8
|
||||||
|
{
|
||||||
|
class MutableXObject;
|
||||||
|
}
|
||||||
|
|
||||||
|
class HandlerMgr : public a8::Singleton<HandlerMgr>
|
||||||
|
{
|
||||||
|
|
||||||
|
private:
|
||||||
|
HandlerMgr() {};
|
||||||
|
friend class a8::Singleton<HandlerMgr>;
|
||||||
|
|
||||||
|
public:
|
||||||
|
|
||||||
|
void Init();
|
||||||
|
void UnInit();
|
||||||
|
|
||||||
|
f8::NetMsgHandlerObject wsmsghandler;
|
||||||
|
f8::NetMsgHandlerObject immsghandler;
|
||||||
|
|
||||||
|
void ProcGMMsg(unsigned long saddr, int sockhandle,
|
||||||
|
const std::string& url, const std::string& quyerstr);
|
||||||
|
|
||||||
|
private:
|
||||||
|
void RegisterNetMsgHandlers();
|
||||||
|
void RegisterGMMsgHandler(const std::string& msgname,
|
||||||
|
void (*)(f8::JsonHttpRequest*));
|
||||||
|
|
||||||
|
std::map<std::string, void (*)(f8::JsonHttpRequest*)> gmhandlers_;
|
||||||
|
};
|
||||||
62
server/textserver/jsondatamgr.cc
Normal file
62
server/textserver/jsondatamgr.cc
Normal file
@ -0,0 +1,62 @@
|
|||||||
|
#include "precompile.h"
|
||||||
|
|
||||||
|
#include "jsondatamgr.h"
|
||||||
|
#include "app.h"
|
||||||
|
|
||||||
|
#include "framework/cpp/utils.h"
|
||||||
|
|
||||||
|
void JsonDataMgr::Init()
|
||||||
|
{
|
||||||
|
if (!f8::IsOnlineEnv()) {
|
||||||
|
if (f8::IsTestEnv()) {
|
||||||
|
work_path_ = a8::Format("/root/pub/%d/%d/conf_test/game%d/rankserver.test",
|
||||||
|
{
|
||||||
|
GAME_ID,
|
||||||
|
App::Instance()->instance_id,
|
||||||
|
GAME_ID
|
||||||
|
});
|
||||||
|
} else {
|
||||||
|
work_path_ = a8::Format("/root/pub/%d/%d/conf_test/game%d/rankserver.dev",
|
||||||
|
{
|
||||||
|
GAME_ID,
|
||||||
|
App::Instance()->instance_id,
|
||||||
|
GAME_ID
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
std::string rankserver_cluster_json_file;
|
||||||
|
std::string mysql_cluster_json_file;
|
||||||
|
mysql_cluster_json_file = a8::Format("%s/node1/friend.rankserver.mysql.cluster.json",
|
||||||
|
{
|
||||||
|
work_path_,
|
||||||
|
});
|
||||||
|
|
||||||
|
rankserver_cluster_json_file = a8::Format("%s/node1/friend.rankserver.cluster.json",
|
||||||
|
{
|
||||||
|
work_path_,
|
||||||
|
});
|
||||||
|
rankserver_cluster_json_.ReadFromFile(rankserver_cluster_json_file);
|
||||||
|
mysql_cluster_json_.ReadFromFile(mysql_cluster_json_file);
|
||||||
|
}
|
||||||
|
|
||||||
|
void JsonDataMgr::UnInit()
|
||||||
|
{
|
||||||
|
}
|
||||||
|
|
||||||
|
std::shared_ptr<a8::XObject> JsonDataMgr::GetConf()
|
||||||
|
{
|
||||||
|
if (App::Instance()->instance_id < 1 || App::Instance()->instance_id > rankserver_cluster_json_.Size()) {
|
||||||
|
abort();
|
||||||
|
}
|
||||||
|
return rankserver_cluster_json_[App::Instance()->instance_id - 1];
|
||||||
|
}
|
||||||
|
|
||||||
|
std::shared_ptr<a8::XObject> JsonDataMgr::GetMysqlClusterConf()
|
||||||
|
{
|
||||||
|
return std::make_shared<a8::XObject>(mysql_cluster_json_);
|
||||||
|
}
|
||||||
|
|
||||||
|
std::shared_ptr<a8::XObject> JsonDataMgr::GetMysqlConf(int instance_id)
|
||||||
|
{
|
||||||
|
return mysql_cluster_json_[instance_id - 1];
|
||||||
|
}
|
||||||
21
server/textserver/jsondatamgr.h
Normal file
21
server/textserver/jsondatamgr.h
Normal file
@ -0,0 +1,21 @@
|
|||||||
|
#pragma once
|
||||||
|
|
||||||
|
class JsonDataMgr : public a8::Singleton<JsonDataMgr>
|
||||||
|
{
|
||||||
|
private:
|
||||||
|
JsonDataMgr() {};
|
||||||
|
friend class a8::Singleton<JsonDataMgr>;
|
||||||
|
|
||||||
|
public:
|
||||||
|
void Init();
|
||||||
|
void UnInit();
|
||||||
|
|
||||||
|
std::shared_ptr<a8::XObject> GetMysqlClusterConf();
|
||||||
|
std::shared_ptr<a8::XObject> GetConf();
|
||||||
|
std::shared_ptr<a8::XObject> GetMysqlConf(int instance_id);
|
||||||
|
|
||||||
|
private:
|
||||||
|
std::string work_path_ = "../config";
|
||||||
|
a8::XObject mysql_cluster_json_;
|
||||||
|
a8::XObject rankserver_cluster_json_;
|
||||||
|
};
|
||||||
14
server/textserver/main.cc
Normal file
14
server/textserver/main.cc
Normal file
@ -0,0 +1,14 @@
|
|||||||
|
#include "precompile.h"
|
||||||
|
|
||||||
|
#include <algorithm>
|
||||||
|
#include <functional>
|
||||||
|
#include "app.h"
|
||||||
|
|
||||||
|
int main(int argc, char* argv[])
|
||||||
|
{
|
||||||
|
int exitcode = 0;
|
||||||
|
App::Instance()->Init(argc, argv);
|
||||||
|
exitcode = App::Instance()->Run();
|
||||||
|
App::Instance()->UnInit();
|
||||||
|
return exitcode;
|
||||||
|
}
|
||||||
0
server/textserver/metadata.cc
Normal file
0
server/textserver/metadata.cc
Normal file
3
server/textserver/metadata.h
Normal file
3
server/textserver/metadata.h
Normal file
@ -0,0 +1,3 @@
|
|||||||
|
#pragma once
|
||||||
|
|
||||||
|
#include "metatable.pb.h"
|
||||||
180
server/textserver/metamgr.cc
Normal file
180
server/textserver/metamgr.cc
Normal file
@ -0,0 +1,180 @@
|
|||||||
|
#include "precompile.h"
|
||||||
|
|
||||||
|
#include <algorithm>
|
||||||
|
|
||||||
|
#include <a8/stringlist.h>
|
||||||
|
#include <a8/csvreader.h>
|
||||||
|
|
||||||
|
#include "framework/cpp/utils.h"
|
||||||
|
|
||||||
|
#include "metamgr.h"
|
||||||
|
#include "app.h"
|
||||||
|
#include "jsondatamgr.h"
|
||||||
|
|
||||||
|
#define METAMGR_READ(field_name, def_val) MetaMgr::Instance()->field_name = \
|
||||||
|
a8::XValue(MetaMgr::Instance()->GetSysParamAsString(#field_name, #def_val));
|
||||||
|
|
||||||
|
#define METAMGR_READ_STR(field_name, def_val) MetaMgr::Instance()->field_name = \
|
||||||
|
a8::XValue(MetaMgr::Instance()->GetSysParamAsString(#field_name, def_val)).GetString();
|
||||||
|
|
||||||
|
static bool PureEnglishName(const std::string& role_name)
|
||||||
|
{
|
||||||
|
for (size_t i = 0; i < role_name.size(); i++) {
|
||||||
|
if (role_name[i] >= 0 && role_name[i] <= 127) {
|
||||||
|
continue;
|
||||||
|
} else {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
class MetaDataLoader
|
||||||
|
{
|
||||||
|
public:
|
||||||
|
std::map<size_t, std::map<std::string, std::string> > dirty_words;
|
||||||
|
std::list<metatable::Text> text_meta_list;
|
||||||
|
|
||||||
|
std::map<std::string, std::string> text_hash;
|
||||||
|
|
||||||
|
void Load()
|
||||||
|
{
|
||||||
|
if (!f8::IsOnlineEnv()) {
|
||||||
|
if (f8::IsTestEnv()) {
|
||||||
|
res_path = a8::Format("/root/pub/%d/%d/conf_test/game%d/rankserver.test/res%d/",
|
||||||
|
{
|
||||||
|
GAME_ID,
|
||||||
|
App::Instance()->instance_id,
|
||||||
|
GAME_ID,
|
||||||
|
App::Instance()->instance_id
|
||||||
|
});
|
||||||
|
} else {
|
||||||
|
res_path = a8::Format("/root/pub/%d/%d/conf_test/game%d/rankserver.dev/res%d/",
|
||||||
|
{
|
||||||
|
GAME_ID,
|
||||||
|
App::Instance()->instance_id,
|
||||||
|
GAME_ID,
|
||||||
|
App::Instance()->instance_id
|
||||||
|
});
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
res_path = "../res/";
|
||||||
|
}
|
||||||
|
f8::ReadCsvMetaFile(res_path + "text@text.csv", text_meta_list);
|
||||||
|
LoadDirtyWordTable();
|
||||||
|
BindToMetaData();
|
||||||
|
Check();
|
||||||
|
}
|
||||||
|
|
||||||
|
private:
|
||||||
|
|
||||||
|
void LoadDirtyWordTable()
|
||||||
|
{
|
||||||
|
a8::CsvReader reader;
|
||||||
|
reader.Load(res_path + "dirtyWord@dirtyWord.csv");
|
||||||
|
while (reader.NextLine()) {
|
||||||
|
std::string strword = reader.GetValue("word").GetString();
|
||||||
|
if (strword == " " || strword.empty()) { //忽略空格
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
std::transform(strword.begin(), strword.end(), strword.begin(), ::tolower);
|
||||||
|
auto itr = dirty_words.find(strword.size());
|
||||||
|
if (dirty_words.find(strword.size()) != dirty_words.end()) {
|
||||||
|
itr->second[strword] = strword;
|
||||||
|
} else {
|
||||||
|
std::map<std::string, std::string> words;
|
||||||
|
words[strword] = strword;
|
||||||
|
dirty_words[strword.size()] = words;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
void Check()
|
||||||
|
{
|
||||||
|
}
|
||||||
|
|
||||||
|
void BindToMetaData()
|
||||||
|
{
|
||||||
|
for (auto& meta : text_meta_list) {
|
||||||
|
text_hash[meta.textid()] = meta.text();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private:
|
||||||
|
std::string res_path;
|
||||||
|
};
|
||||||
|
|
||||||
|
void MetaMgr::Init()
|
||||||
|
{
|
||||||
|
loader_ = new MetaDataLoader();
|
||||||
|
loader_->Load();
|
||||||
|
}
|
||||||
|
|
||||||
|
void MetaMgr::UnInit()
|
||||||
|
{
|
||||||
|
delete loader_;
|
||||||
|
loader_ = nullptr;
|
||||||
|
}
|
||||||
|
|
||||||
|
void MetaMgr::Reload()
|
||||||
|
{
|
||||||
|
delete loader_;
|
||||||
|
loader_ = nullptr;
|
||||||
|
|
||||||
|
loader_ = new MetaDataLoader();
|
||||||
|
loader_->Load();
|
||||||
|
}
|
||||||
|
|
||||||
|
bool MetaMgr::HasDirtyWord(const std::string& text)
|
||||||
|
{
|
||||||
|
for (size_t i = 0; i < text.size(); i++) {
|
||||||
|
for (auto itr = loader_->dirty_words.begin(); itr != loader_->dirty_words.end(); ++itr) {
|
||||||
|
if (itr->first <= text.size() - i) {
|
||||||
|
std::string substr = text.substr(i, itr->first);
|
||||||
|
// 如果是纯英文，则先转为小写，根据策划说明，屏蔽字大小写不敏感
|
||||||
|
std::transform(substr.begin(), substr.end(), substr.begin(), ::tolower);
|
||||||
|
if (substr.size() > 0 && itr->second.find(substr) != itr->second.end()) {
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
std::string MetaMgr::ReplaceDirtyWord(const std::string& text, char c)
|
||||||
|
{
|
||||||
|
std::string result;
|
||||||
|
result.reserve(text.size());
|
||||||
|
for (size_t i = 0; i < text.size(); i++) {
|
||||||
|
bool found = false;
|
||||||
|
for (auto itr = loader_->dirty_words.begin(); itr != loader_->dirty_words.end(); ++itr) {
|
||||||
|
if (itr->first <= text.size() - i) {
|
||||||
|
std::string substr = text.substr(i, itr->first);
|
||||||
|
// 如果是纯英文，则先转为小写，根据策划说明，屏蔽字大小写不敏感
|
||||||
|
if (PureEnglishName(substr)) {
|
||||||
|
transform(substr.begin(), substr.end(), substr.begin(), ::tolower);
|
||||||
|
}
|
||||||
|
if (substr.size() > 0 && itr->second.find(substr) != itr->second.end()) {
|
||||||
|
int str_len = a8::GetUtf8Length(substr.c_str());
|
||||||
|
for (int j = 0; j < str_len; j++) {
|
||||||
|
result.push_back(c);
|
||||||
|
}
|
||||||
|
i += substr.size() - 1;
|
||||||
|
found = true;
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}//endfor map
|
||||||
|
if (!found) {
|
||||||
|
result.push_back(text[i]);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
|
||||||
|
std::string MetaMgr::GetText(const std::string& textid, const std::string& def_text)
|
||||||
|
{
|
||||||
|
auto itr = loader_->text_hash.find(textid);
|
||||||
|
return itr != loader_->text_hash.end() ? itr->second : def_text;
|
||||||
|
}
|
||||||
29
server/textserver/metamgr.h
Normal file
29
server/textserver/metamgr.h
Normal file
@ -0,0 +1,29 @@
|
|||||||
|
#pragma once
|
||||||
|
|
||||||
|
#include "metadata.h"
|
||||||
|
|
||||||
|
#define TEXT(textid, def_text) MetaMgr::Instance()->GetText(textid, def_text)
|
||||||
|
|
||||||
|
class MetaDataLoader;
|
||||||
|
class MetaMgr : public a8::Singleton<MetaMgr>
|
||||||
|
{
|
||||||
|
|
||||||
|
private:
|
||||||
|
MetaMgr() {};
|
||||||
|
friend class a8::Singleton<MetaMgr>;
|
||||||
|
|
||||||
|
public:
|
||||||
|
|
||||||
|
void Init();
|
||||||
|
void UnInit();
|
||||||
|
void Reload();
|
||||||
|
|
||||||
|
bool HasDirtyWord(const std::string& text);
|
||||||
|
std::string ReplaceDirtyWord(const std::string& text, char c);
|
||||||
|
std::string GetText(const std::string& textid, const std::string& def_text="");
|
||||||
|
|
||||||
|
private:
|
||||||
|
MetaDataLoader* loader_ = nullptr;
|
||||||
|
|
||||||
|
friend class MetaDataLoader;
|
||||||
|
};
|
||||||
64
server/textserver/perfmonitor.cc
Normal file
64
server/textserver/perfmonitor.cc
Normal file
@ -0,0 +1,64 @@
|
|||||||
|
#include "precompile.h"
|
||||||
|
|
||||||
|
#include <a8/timer.h>
|
||||||
|
#include <a8/ioloop.h>
|
||||||
|
|
||||||
|
#include "perfmonitor.h"
|
||||||
|
#include "app.h"
|
||||||
|
|
||||||
|
static void SavePerfLog()
|
||||||
|
{
|
||||||
|
a8::UdpLog::Instance()->Info
|
||||||
|
("max_run_delay_time:%d max_timer_idle:%d "
|
||||||
|
"in_data_size:%d out_data_size:%d msgnode_size:%d "
|
||||||
|
"cache_friend_num:%d alloc_node_total_times:%d alloc_node_ok_times:%d "
|
||||||
|
"alloc_node_fail_times:%d " ,
|
||||||
|
{
|
||||||
|
PerfMonitor::Instance()->max_run_delay_time,
|
||||||
|
PerfMonitor::Instance()->max_timer_idle,
|
||||||
|
PerfMonitor::Instance()->in_data_size,
|
||||||
|
PerfMonitor::Instance()->out_data_size,
|
||||||
|
App::Instance()->msgnode_size_,
|
||||||
|
PerfMonitor::Instance()->read_count,
|
||||||
|
PerfMonitor::Instance()->alloc_node_total_times,
|
||||||
|
PerfMonitor::Instance()->alloc_node_ok_times,
|
||||||
|
PerfMonitor::Instance()->alloc_node_fail_times
|
||||||
|
});
|
||||||
|
a8::UdpLog::Instance()->Info
|
||||||
|
("run_times:%d timer_times:%d event_times:%d free_times:%d "
|
||||||
|
"shutdown_times:%d connect_times:%d close_times:%d "
|
||||||
|
"send_times:%d recv_times:%d error_times:%d immsg_times:%d",
|
||||||
|
{
|
||||||
|
(long long)a8::IoLoop::Instance()->run_times,
|
||||||
|
(long long)a8::IoLoop::Instance()->timer_times,
|
||||||
|
(long long)a8::IoLoop::Instance()->event_times,
|
||||||
|
(long long)a8::IoLoop::Instance()->free_times,
|
||||||
|
(long long)a8::IoLoop::Instance()->shutdown_times,
|
||||||
|
(long long)a8::IoLoop::Instance()->connect_times,
|
||||||
|
(long long)a8::IoLoop::Instance()->close_times,
|
||||||
|
(long long)a8::IoLoop::Instance()->send_times,
|
||||||
|
(long long)a8::IoLoop::Instance()->recv_times,
|
||||||
|
(long long)a8::IoLoop::Instance()->error_times,
|
||||||
|
(long long)a8::IoLoop::Instance()->immsg_times
|
||||||
|
});
|
||||||
|
PerfMonitor::Instance()->max_run_delay_time = 0;
|
||||||
|
PerfMonitor::Instance()->max_timer_idle = 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
void PerfMonitor::Init()
|
||||||
|
{
|
||||||
|
{
|
||||||
|
int perf_log_time = 1000 * 60 * 5;
|
||||||
|
a8::Timer::Instance()->AddRepeatTimer(perf_log_time,
|
||||||
|
a8::XParams(),
|
||||||
|
[] (const a8::XParams& param)
|
||||||
|
{
|
||||||
|
SavePerfLog();
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
void PerfMonitor::UnInit()
|
||||||
|
{
|
||||||
|
|
||||||
|
}
|
||||||
22
server/textserver/perfmonitor.h
Normal file
22
server/textserver/perfmonitor.h
Normal file
@ -0,0 +1,22 @@
|
|||||||
|
#pragma once
|
||||||
|
|
||||||
|
class PerfMonitor : public a8::Singleton<PerfMonitor>
|
||||||
|
{
|
||||||
|
private:
|
||||||
|
PerfMonitor() {};
|
||||||
|
friend class a8::Singleton<PerfMonitor>;
|
||||||
|
|
||||||
|
public:
|
||||||
|
int max_run_delay_time = 0;
|
||||||
|
int max_timer_idle = 0;
|
||||||
|
int max_dispatchmsg_time = 0;
|
||||||
|
long long out_data_size = 0;
|
||||||
|
long long in_data_size = 0;
|
||||||
|
long long read_count = 0;
|
||||||
|
long long alloc_node_total_times = 0;
|
||||||
|
long long alloc_node_ok_times = 0;
|
||||||
|
long long alloc_node_fail_times = 0;
|
||||||
|
|
||||||
|
void Init();
|
||||||
|
void UnInit();
|
||||||
|
};
|
||||||
19
server/textserver/precompile.h
Normal file
19
server/textserver/precompile.h
Normal file
@ -0,0 +1,19 @@
|
|||||||
|
#pragma once
|
||||||
|
|
||||||
|
#include <a8/a8.h>
|
||||||
|
#include <a8/udplog.h>
|
||||||
|
|
||||||
|
#include "constant.h"
|
||||||
|
#include "types.h"
|
||||||
|
|
||||||
|
namespace google
|
||||||
|
{
|
||||||
|
namespace protobuf
|
||||||
|
{
|
||||||
|
class Message;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#include "framework/cpp/types.h"
|
||||||
|
#include "framework/cpp/utils.h"
|
||||||
|
#include "framework/cpp/protoutils.h"
|
||||||
3
server/textserver/typeconvert.cc
Normal file
3
server/textserver/typeconvert.cc
Normal file
@ -0,0 +1,3 @@
|
|||||||
|
#include "precompile.h"
|
||||||
|
|
||||||
|
#include "typeconvert.h"
|
||||||
8
server/textserver/typeconvert.h
Normal file
8
server/textserver/typeconvert.h
Normal file
@ -0,0 +1,8 @@
|
|||||||
|
#pragma once
|
||||||
|
|
||||||
|
#include <a8/mutable_xobject.h>
|
||||||
|
|
||||||
|
class TypeConvert
|
||||||
|
{
|
||||||
|
public:
|
||||||
|
};
|
||||||
3
server/textserver/types.cc
Normal file
3
server/textserver/types.cc
Normal file
@ -0,0 +1,3 @@
|
|||||||
|
#include "precompile.h"
|
||||||
|
|
||||||
|
|
||||||
1
server/textserver/types.h
Executable file
1
server/textserver/types.h
Executable file
@ -0,0 +1 @@
|
|||||||
|
#pragma once
|
||||||
13
server/tools/protobuild/metatable.proto
Normal file
13
server/tools/protobuild/metatable.proto
Normal file
@ -0,0 +1,13 @@
|
|||||||
|
package metatable;
|
||||||
|
|
||||||
|
message MFPair
|
||||||
|
{
|
||||||
|
optional int32 key = 1; //key
|
||||||
|
optional int32 value = 2; //val
|
||||||
|
}
|
||||||
|
|
||||||
|
message Text
|
||||||
|
{
|
||||||
|
optional string textid = 1;
|
||||||
|
optional string text = 2;
|
||||||
|
}
|
||||||
Loading…
x
Reference in New Issue
Block a user