lnk/microser
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix cpu 100% and consumer now dont recive history message

Browse Source
This commit is contained in:
lnk
2025-03-26 10:51:18 +08:00
parent fa629ee071
commit e8b5f08c6b
2 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
cfg_parse/SimpleProducer.cpp
View File

@@ -28,6 +28,10 @@
//lnk20241209添加队列选择 //lnk20241209添加队列选择
#include <cstring> #include <cstring>
//引入消费起点
#include "../include/rocketmq/DefaultMQPushConsumer.h"
#include "../include/rocketmq/ConsumeType.h"
// 引入提供的消费者接口头文件 // 引入提供的消费者接口头文件
#include "../include/rocketmq/CPushConsumer.h" #include "../include/rocketmq/CPushConsumer.h"
#include "../include/rocketmq/CCommon.h" #include "../include/rocketmq/CCommon.h"

6
json/save2json.cpp
View File

@@ -680,6 +680,8 @@ void KafkaSendThread::run()
my_rocketmq_send(log_send); my_rocketmq_send(log_send);
} }
QThread::msleep(1); // <20><><EFBFBD><EFBFBD> CPU <20><>תlnk20250326
/*if (data_gotten) { /*if (data_gotten) {
LD_info_t* LD_info = find_LD_info_only_from_mp_id(data.mp_id.toAscii().data()); LD_info_t* LD_info = find_LD_info_only_from_mp_id(data.mp_id.toAscii().data());
ied_t* ied; ied_t* ied;
@@ -801,7 +803,7 @@ void KafkaSendThread::run()
}*/ }*/
} //while(1) { } //while(1) {
//<2F>߳̽<DFB3><CCBD><EFBFBD><EFBFBD>ݻ<EFBFBD><DDBB><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD> //<2F>߳̽<DFB3><CCBD><EFBFBD><EFBFBD>ݻ<EFBFBD><DDBB><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
ShutdownAndDestroyProducer();//lnk20241211 ShutdownAndDestroyProducer();//lnk20241211
} }
@@ -2116,7 +2118,7 @@ int myMessageCallbackrecall(CPushConsumer* consumer, CMessageExt* msg)
void mqconsumerThread::run() void mqconsumerThread::run()
{ {
// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>߲<EFBFBD><DFB2><EFBFBD> // <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>߲<EFBFBD><DFB2><EFBFBD>
std::string consumerName = std::string(subdir) + intToString(g_front_seg_index); // <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ID std::string consumerName = subdir + intToString(g_front_seg_index) + "_start_" + QDateTime::currentDateTime().toString("yyyyMMddhhmmss").toStdString(); // <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ID+<2B><><EFBFBD><EFBFBD>ʱ<EFBFBD>䣬<EFBFBD><E4A3AC><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʷ<EFBFBD><CAB7>Ϣ
std::string nameServer = G_MQCONSUMER_IPPORT; // NameServer<65><72>ַ std::string nameServer = G_MQCONSUMER_IPPORT; // NameServer<65><72>ַ