zhangwen/front_linux
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

modify logs

Browse Source
This commit is contained in:
lnk
2025-09-24 09:44:52 +08:00
parent e997c88d82
commit 4fe8aee149
6 changed files with 43 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
LFtid1056/cloudfront/code/rocketmq.cpp
View File

@@ -1849,7 +1849,7 @@ void send_reply_to_cloud(int reply_code, const std::string& dev_id, int type, co
// ---- 构造根 JSON ----
nlohmann::json obj;
obj["guid"] = guid;
obj["FrontIP"] = FRONT_IP;
obj["FrontId"] = FRONT_INST;
obj["Node"] = g_front_seg_index;
// Dev_mac：从台账取 addr_str 并规范化
@@ -1918,11 +1918,11 @@ rocketmq::ConsumeStatus cloudMessageCallback(const rocketmq::MQMessageExt& msg)
// 消息解析
std::string guid;
std::string devid;
std::string FrontIP;
std::string FrontId;
int Node;
nlohmann::json DetailObj;
if (!parseJsonMessageCLOUD(body, devid, guid, DetailObj,FrontIP,Node)) {
if (!parseJsonMessageCLOUD(body, devid, guid, DetailObj,FrontId,Node)) {
std::cerr << "Failed to parse the JSON message." << std::endl;
DIY_ERRORLOG("process", "【ERROR】前置消费topic:%s_%s的云前置控制消息失败,消息的json格式不正确", FRONT_INST.c_str(), G_MQCONSUMER_TOPIC_RT.c_str());
return rocketmq::RECONSUME_LATER;
@@ -1932,11 +1932,11 @@ rocketmq::ConsumeStatus cloudMessageCallback(const rocketmq::MQMessageExt& msg)
std::cout << "[CLOUD Msg Parsed] "
<< "guid=" << guid
<< ", devid=" << devid
<< ", FrontIP=" << FrontIP
<< ", FrontId=" << FrontId
<< ", Node=" << Node
<< std::endl;
if(FrontIP != FRONT_IP || Node != g_front_seg_index){
if(FrontId != FRONT_INST || Node != g_front_seg_index){
std::cout << "当前进程不消费这个消息" << std::endl;
return rocketmq::CONSUME_SUCCESS;
}