一。使用设置:
头文件的添加：
..\Framwork\Include\pthread_64;
..\Framwork\CommFramwork\include;
..\Framwork\Utility\Include;
..\Framwork\NetMgr\Include;
..\Framwork\FramworkAp\Include;
..\Framwork\BlockMsg\Include;
..\Framwork\wdInterface\Include;
lib路径的添加:
FramworkAp.lib
Utility.lib
libeay32.lib
ssleay32.lib
BlockMsg.lib
pthreadVC2.lib
CommFramwork.lib
Utility.lib
FramworkAp.lib
NetMgr.lib
wdinterface.lib
二。使用方法
1.LOG的使用
准备工作:
建立配置文件 Config.cfg,拷贝内容:
-------------------------------------------------------------
# -------------------------日志-----------------------------
# device(设备)包括file(文件), console(控制台)及将来扩展的日志主机等
# level(级别)包括E_CRITICAL, E_ERROR, E_WARNING, E_NOTICE, E_SYSINFO, E_PROINFO, E_APPINFO, E_DEBUG
logger.type = common, debug, net
logger.common.device = file
logger.common.level = E_CRITICAL, E_ERROR, E_WARNING, E_NOTICE, E_SYSINFO, E_PROINFO, E_APPINFO, E_DEBUG, E_STATICS
logger.common.path = E:\work\CTPServer\Bin64\log
logger.common.prefix = CTPServer
logger.common.postfix = log
logger.common.num = 6
logger.common.level1 = E_CRITICAL
logger.common.file1 = LogErr
logger.common.level2 = E_ERROR
logger.common.file2 = LogErr
logger.common.level3 = E_WARNING
logger.common.file3 = LogErr
logger.common.level4 = E_PROINFO
logger.common.file4 = LogProInfo
logger.common.level5 = E_STATICS
logger.common.file5 = LogStatics
logger.common.level6 = E_DEBUG
logger.common.file6 = LogDebug
logger.debug.device = console
logger.debug.level = E_CRITICAL, E_ERROR, E_WARNING, E_NOTICE, E_SYSINFO, E_PROINFO, E_APPINFO, E_DEBUG, E_STATICS
logger.net.device = netlog
logger.net.level = E_CRITICAL, E_ERROR, E_WARNING, E_NOTICE, E_SYSINFO, E_PROINFO, E_APPINFO, E_DEBUG, E_STATICS
第一步：添加头文件
#include "Logger.h"
第二步：初始化
CLogger::Instance()->Initial(。。。）；
第三步：启动日志
if (CLogger::Instance()->Start() != 0)
return ;
第四步：使用
CRLog(E_DEBUG, "配置初始化成功");
CRLog(E_APPINFO, "配置初始化成功");
2.配置文件的使用
准备工作：
第一步:引入
#include "ConfigImpl.h"
第二步:定义
CConfigImpl* m_pConfig;
第三步:日志初始化
m_pConfig = new CConfigImpl();
第四步:加载配置文件
if (m_pConfig->Load(strPath) != 0)
return ;
第五步:使用配置
m_pConfig->GetProperty(key, value);
例如“用配置来初始化日志”：
if (CLogger::Instance()->Initial(m_pConfig->GetProperties("logger")) != 0)
return ;
第六步:删除
if (0 != m_pConfig)
{
delete m_pConfig;
m_pConfig = nullptr;
}
3.文件共享的消息队列
第一步：引入头文件
#include "XQueue.h"
#include "XQueueIO.h"
第二步：
1.读取模式（进程间通信）
CXQueue xQueue;//定义
do
{
setColor(12,0);
int nRet = xQueue.Open(sXQueName.c_str());//打开
if (!xQueue.IsOpen())
{
string strTmp ="打开共享内存信息队列[";
strTmp += sXQueName;
strTmp += "]失败!10秒后再试!";
//cout << "打开共享内存信息队列[" << sXQueName << "]失败!10秒后再试!" << endl;
Sleep(10000);
}
else
{
break;
}
} while (1);
unsigned int uiBlockSize = 1024;
unsigned int uiXQueLen = 1024;
unsigned int uiBufSize = uiBlockSize*uiXQueLen;
char* pBuf= NULL;
pBuf = new char[uiBufSize];
long lRet = xQueue.Read((LPBYTE)pBuf, &uiBufSize, &nMessageId, NULL, uiTimeout);//读取
if (XQUEUE_ERROR_SUCCESS != lRet)
{
setColor(12);
string strTmp ="共享队列 [";
strTmp += sXQueName;
strTmp += "]没有数据!";
CRLog(E_ERROR,"%s",strTmp.c_str());
continue;
}
setColor(11);
CRLog(E_ERROR,"共享队列[XQueue]读完成");
2.创建模式
例如：创建2个文件共享队列
vector< CXQueueIo<QUOTATION>* > m_vecQueueIo;
//初始创建
unsigned int uiXQueNum = 2;
if (0 == m_pConfig->GetProperty("XQUE_NUM", sTmp))
{
uiXQueNum = strutils::FromString<unsigned int>(sTmp);
if (uiXQueNum > 10)
uiXQueNum = 2;
}
for (unsigned int uiIndex = 1; uiIndex <= uiXQueNum; uiIndex++)
{
string sCfgName = "XQUE" + strutils::ToString<unsigned int>(uiIndex);
CConfig *pCfgWriter;
pCfgWriter = m_pConfig->GetProperties(sCfgName);
if (0 != pCfgWriter && !pCfgWriter->IsEmpty())
{
}
else
{
pCfgWriter = m_pConfig;
}
CRLog(E_APPINFO,"初始化[%s]发布点", sCfgName.c_str());
CXQueueIo<QUOTATION>* pWriter = new CXQueueIo<QUOTATION>();
pWriter->Init(pCfgWriter);//跟配置文件名绑定在一起
m_vecQueueIo.push_back(pWriter);
}
//启动
int nCount = 0;
for (vector< CXQueueIo<QUOTATION>* >::iterator it = m_vecQueueIo.begin(); it != m_vecQueueIo.end(); ++it)
{
nCount++;
if (0 != *it)
{
CRLog(E_APPINFO,"启动[XQUE%d]", nCount);
(*it)->Start();
}
}
//分发给相应队列处理
int uiCount = 0;
string sXQueName,sTmp;
for (vector< CXQueueIo<QUOTATION>* >::iterator it = m_vecQueueIo.begin(); it != m_vecQueueIo.end(); ++it)
{
uiCount++;
if (0 != *it)
{
(*it)->Enque(quo);
sXQueName = "XQUE" + strutils::ToString<unsigned int>(uiCount);
sXQueName +=".XQUE_NAME";
if (0 == m_pConfig->GetProperty(sXQueName,sTmp))
sXQueName = sTmp;
CRLog(E_APPINFO,"共享队列XQueue[%s]写完成",sXQueName.c_str());
}
}//end for
4.看门狗功能
第一步：引入头文件
#include
第二步：定义对象
CMemShareAlive m_oMemShareAlive;
第三步：初始化
m_oMemShareAlive.Bind(E_PROCESS_APP);
第四步：创建对象
if (FALSE == m_oMemShareAlive.Create(sTmp.c_str()))
{
setColor(12,0);
cout << "MemShareAlive.Create fail" << endl;
CRLog(E_ERROR,"%s", sXQueName.c_str());
}
else
{
cout << "MemShareAlive.Create Successfull." << endl;
unsigned int uiProcessID = ::GetCurrentProcessId();
m_oMemShareAlive.IamAlive(uiProcessID);
//m_oMemShareAlive.SetNodeID(uiNodeID);
}
第五步：在节点位置，都添加上语句
m_oMemShareAlive.IamAlive();
第六步：在WatchDog的配置文件上加上监控XX.EXE，就可以自动启动XX.EXE程序