开天上报注释

master_ob2
PC-202302260912\Administrator 2023-08-09 14:48:06 +08:00
parent 1493bbfbca
commit 23005ce431
4 changed files with 39 additions and 49 deletions

View File

@ -19,7 +19,7 @@ public class ThreadManager implements IManager {
private static final Logger LOGGER = LoggerFactory.getLogger(ThreadManager.class); private static final Logger LOGGER = LoggerFactory.getLogger(ThreadManager.class);
private static DataReportTask dataReportTask; // private static DataReportTask dataReportTask;
private static MongoDataHandlerTask mongoDataHandlerTask; private static MongoDataHandlerTask mongoDataHandlerTask;
private static ItemLogTask itemLogTask; private static ItemLogTask itemLogTask;
@ -31,12 +31,12 @@ public class ThreadManager implements IManager {
public void init() { public void init() {
mongoDataHandlerTask = ConfigurableApplicationContextManager.getBean(MongoDataHandlerTask.class); mongoDataHandlerTask = ConfigurableApplicationContextManager.getBean(MongoDataHandlerTask.class);
dataReportTask = ConfigurableApplicationContextManager.getBean(DataReportTask.class); // dataReportTask = ConfigurableApplicationContextManager.getBean(DataReportTask.class);
itemLogTask = ConfigurableApplicationContextManager.getBean(ItemLogTask.class); itemLogTask = ConfigurableApplicationContextManager.getBean(ItemLogTask.class);
new RetrySendIndicationThread("retry-indi").start(); new RetrySendIndicationThread("retry-indi").start();
mongoDataHandlerTask.start(); mongoDataHandlerTask.start();
dataReportTask.start(); // dataReportTask.start();
itemLogTask.start(); itemLogTask.start();
scheduledExecutor = new ScheduledThreadPoolExecutor(8, new ScheduleThreadFactory()); scheduledExecutor = new ScheduledThreadPoolExecutor(8, new ScheduleThreadFactory());

View File

@ -1,8 +1,5 @@
package com.ljsd.jieling.thread.task; package com.ljsd.jieling.thread.task;
import com.ljsd.jieling.config.reportData.DataMessageUtils;
import com.ljsd.jieling.ktbeans.ReportUserEvent;
import com.ljsd.jieling.ktbeans.ReportUtil;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@Component @Component
public class DataReportTask extends Thread { public class DataReportTask extends Thread {
@ -13,21 +10,21 @@ public class DataReportTask extends Thread {
} }
@Override @Override
public void run() { public void run() {
try { // try {
int i = 0; // int i = 0;
while(true){ // while(true){
// ReportUserEvent event = ReportUtil.queue.take(); //// ReportUserEvent event = ReportUtil.queue.take();
// ReportUtil.doReport(event); //// ReportUtil.doReport(event);
//
DataMessageUtils.manageData(); // DataMessageUtils.manageData();
i++; // i++;
if (i >= 1000) { // if (i >= 1000) {
i = 0; // i = 0;
Thread.sleep(100); // Thread.sleep(100);
} // }
} // }
} catch (InterruptedException e) { // } catch (InterruptedException e) {
e.printStackTrace(); // e.printStackTrace();
} // }
} }
} }

View File

@ -162,7 +162,7 @@ public class MinuteTask extends Thread {
try { try {
GuildFightLogic.minuteCheckForCarFight(); GuildFightLogic.minuteCheckForCarFight();
reportUserOnline(); // reportUserOnline();
OnlineUserManager.checkOnline(); OnlineUserManager.checkOnline();
}catch (Exception e){ }catch (Exception e){
e.printStackTrace(); e.printStackTrace();

View File

@ -1,14 +1,7 @@
package com.ljsd.jieling.thread.task; package com.ljsd.jieling.thread.task;
import com.ljsd.jieling.config.reportData.DataMessageUtils;
import com.ljsd.jieling.ktbeans.BeanBuilder.KtBeanBuilderUtils;
import com.ljsd.jieling.ktbeans.KTRequestBeans.LoginParamType;
import com.ljsd.jieling.ktbeans.parmsBean.ParamEventBean;
import com.ljsd.jieling.ktbeans.sendbeans.KTAppOnline;
import com.ljsd.jieling.logic.OnlineUserManager;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import util.TimeUtils;
/** /**
* @author lvxinran * @author lvxinran
@ -27,25 +20,25 @@ public class OnlineUserReportTask extends Thread {
public void run() { public void run() {
try{ try{
//5分钟上报一次 //5分钟上报一次
if(TimeUtils.getMinute()%5 == 0){ // if(TimeUtils.getMinute()%5 == 0){
// int serverId = GameApplication.serverId; //// int serverId = GameApplication.serverId;
// Set<Integer> uids = OnlineUserManager.sessionMap.keySet(); //// Set<Integer> uids = OnlineUserManager.sessionMap.keySet();
// OnlineUserCalEvent onlineUserCalEvent = new OnlineUserCalEvent(); //// OnlineUserCalEvent onlineUserCalEvent = new OnlineUserCalEvent();
// onlineUserCalEvent.setAppid(GameApplication.serverProperties.getAppId()==null?"APPID":GameApplication.serverProperties.getAppId()); //// onlineUserCalEvent.setAppid(GameApplication.serverProperties.getAppId()==null?"APPID":GameApplication.serverProperties.getAppId());
// onlineUserCalEvent.setOnlines(new OnlineProp[]{new OnlineProp(String.valueOf(serverId),uids.size(), TimeUtils.now()/1000)}); //// onlineUserCalEvent.setOnlines(new OnlineProp[]{new OnlineProp(String.valueOf(serverId),uids.size(), TimeUtils.now()/1000)});
// DataMessageUtils.sendOnlinePost(onlineUserCalEvent); //// DataMessageUtils.sendOnlinePost(onlineUserCalEvent);
//
KTAppOnline ktAppOnline = new KTAppOnline(); // KTAppOnline ktAppOnline = new KTAppOnline();
int onlineNum = OnlineUserManager.sessionMap.size(); // int onlineNum = OnlineUserManager.sessionMap.size();
ParamEventBean paramEventBean = new ParamEventBean(ParamEventBean.OnlineEvent); // ParamEventBean paramEventBean = new ParamEventBean(ParamEventBean.OnlineEvent);
long time = TimeUtils.now()/ 1000; // long time = TimeUtils.now()/ 1000;
paramEventBean.add(String.valueOf(time)); // paramEventBean.add(String.valueOf(time));
paramEventBean.add(String.valueOf(onlineNum)); // paramEventBean.add(String.valueOf(onlineNum));
ktAppOnline.setParam_event(paramEventBean); // ktAppOnline.setParam_event(paramEventBean);
ktAppOnline.setParam_data(KtBeanBuilderUtils.paramDataBuildForSystem()); // ktAppOnline.setParam_data(KtBeanBuilderUtils.paramDataBuildForSystem());
ktAppOnline.getParam_data().setCategory_s(LoginParamType.DATA_CATEGORY_APP); // ktAppOnline.getParam_data().setCategory_s(LoginParamType.DATA_CATEGORY_APP);
DataMessageUtils.addLogQueue(ktAppOnline); // DataMessageUtils.addLogQueue(ktAppOnline);
} // }
// Set<Integer> uids = OnlineUserManager.sessionMap.keySet(); // Set<Integer> uids = OnlineUserManager.sessionMap.keySet();
// Map<String,Integer> channelMap = new HashMap<>(); // Map<String,Integer> channelMap = new HashMap<>();