#include <vector>
#include <tuple>
#include "comserver_control.h"
#include "aaaaaa_com_interface.h"
#include "business_engine_comserver.h"
#include "comserver_define.h"
#include "aaaaaa_com_factory.h"
#include "http_pool_factory.h"
CComServerControl::CComServerControl() {
CComServerControl::Init();
}
CComServerControl::~CComServerControl() {
}
bool CComServerControl::Init() {
if (_bInit) return true;
std::vector<std::tuple<int, VBusinessComFactoryFuncSPtr>> comFactoryConfigs = {
// 业务组件
std::make_tuple(ComServer_Basic_AAAAAA, (VBusinessComFactoryFuncSPtr)CAAAAAAComFactory::CreateInstanceSPtr),
// 通用组件
std::make_tuple(ComServer_Common_HttpPool, (VBusinessComFactoryFuncSPtr)CIHttpClientPoolFactory::CreateInstanceSPtr),
};
for (const auto &t : comFactoryConfigs) {
_compFactoryMap.insert(CompFactoryMap::value_type(std::get<0>(t), std::get<1>(t)));
}
// 初始化组件
_bInit = InitComponents();
return _bInit;
}
void CComServerControl::UnInit() {
}
bool CComServerControl::InitComponents() {
bool bRet = true;
// 此处动态控制对应默认组件是否被创建
std::vector<std::tuple<int, bool>> comConfigs = {
std::make_tuple(ComServer_Basic_AAAAAA, m_clDyConfig.DY_ENABLE_AAAAAA),
std::make_tuple(ComServer_Common_HttpPool, m_clDyConfig.DY_ENABLE_HTTPPOOL),
};
CompSPtr compSPtr;
for(const auto &t : comConfigs)
{
int type = std::get<0>(t);
if (std::get<1>(t) && _compFactoryMap.find(type) != _compFactoryMap.end())
{
if (!AddDefaultComponent(type, _compFactoryMap[type], compSPtr))
{
bRet = false;
break;
}
}
}
return bRet;
}
void CComServerControl::UnInitComponents() {
}
bool CComServerControl::LoadDynamicConfig(const std::string& clDyJson) {
return true;
}
bool CComServerControl::SetDefaultCompControl(BusinessControlSPtr pBusinessControl) {
// 第一个创建的
if (_pDefaultBusinessControl) return true;
for (auto &kv : _compMapDefault) {
for (auto &sub : kv.second) {
sub.second->SetBusinessControl(pBusinessControl);
}
}
_pDefaultBusinessControl = pBusinessControl;
return true;
}
bool CComServerControl::RegistComponent(const int& type, const VBusinessComFactoryFuncSPtr& factoryFunc, const bool& isComRegist) {
return RegistComponent(type, factoryFunc, CompClsID(type), isComRegist);
}
bool CComServerControl::AddDefaultComponent(const int& type, const VBusinessComFactoryFuncSPtr& factoryFunc, CompSPtr& compSPtr) {
return AddDefaultComponent(type, factoryFunc, CompClsID(type), CompVID(type), compSPtr);
}
bool CComServerControl::GetDefaultComServerSPtr(const int& type, CompSPtr& compSPtr) {
if (!_bInit)
{
CComServerControl::Init();
}
bool bRet = false;
if (type <= 0 || type == ComServer_Basic_Cnt || type >= ComServer_Common_Cnt)
{
return bRet;
}
std::string clsID = CompClsID(type);
std::string vID = CompVID(type);
do {
// defalut 中查询
if (_compMapDefault.find(clsID) == _compMapDefault.end()) break;
if (_compMapDefault[clsID].find(vID) == _compMapDefault[clsID].end()) break;
compSPtr = _compMapDefault[clsID][vID];
bRet = true;
} while (false);
if (!bRet && (_compFactoryMap.find(type) != _compFactoryMap.end()))
{
bRet = AddDefaultComponent(type, _compFactoryMap[type], compSPtr);
}
return bRet;
}
bool CComServerControl::CreateCompSPtr(const int& type, const std::string& tag, CompSPtr& compSPtr) {
return true;
}
std::string CComServerControl::CompClsID(const int& type) {
std::string strID = "";
strID += "comp_";
strID += std::to_string(type);
return strID;
}
std::string CComServerControl::CompVID(const int& type) {
return CompVID(type, "");
}
std::string CComServerControl::CompVID(const int& type, const std::string& tag) {
std::string strID = "";
strID += CompClsID(type);
if (!tag.empty()) {
strID.append("_");
strID.append(tag);
}
strID += "_instance";
return strID;
}
bool CComServerControl::AddComponent(const int& type, const VBusinessComFactoryFuncSPtr& factoryFunc, CompSPtr& compSPtr) {
std::string clsID = CompClsID(type);
std::string tag = "";
if (_pBusinessControl)
{
tag = _pBusinessControl->ID().c_str();
}
std::string vID = CompVID(type, tag);
return AddComponent(type, factoryFunc, clsID, vID, compSPtr);
}
bool CComServerControl::AddComponent(const int& type, const VBusinessComFactoryFuncSPtr& factoryFunc, const std::string& tag, CompSPtr& compSPtr) {
std::string clsID = CompClsID(type);
std::string vID = CompVID(type, tag);
return AddComponent(type, factoryFunc, clsID, vID, compSPtr);
}
bool CComServerControl::SetBusinessControl(BusinessControlSPtr pBusinessControl) {
_pBusinessControl = pBusinessControl;
SetDefaultCompControl(pBusinessControl);
return true;
}
bool CComServerControl::GetComServerSPtr(const int& type, CompSPtr& compSPtr) {
bool bRet = GetComServerSPtr(type,
CompVID(type, _pBusinessControl->ID().c_str()),
compSPtr
);
if (!bRet) {
bRet = GetComServerSPtr(type,
CompVID(type),
compSPtr
);
}
return bRet;
}
bool CComServerControl::GetComServerSPtr(const int& type, const std::string& vID, CompSPtr& compSPtr) {
bool bRet = false;
std::string clsID = CompClsID(type);
do{
if (vID == CompVID(type))
{
if (_compMapDefault.find(clsID) == _compMapDefault.end()) break;
if (_compMapDefault[clsID].find(vID) == _compMapDefault[clsID].end()) break;
compSPtr = _compMapDefault[clsID][vID];
}
else
{
if (_compMap.find(clsID) == _compMap.end()) break;
if (_compMap[clsID].find(vID) == _compMap[clsID].end()) break;
compSPtr = _compMap[clsID][vID];
}
bRet = true;
}while (0);
return bRet;
}
bool CComServerControl::AddDefaultComponent(const int& type, const VBusinessComFactoryFuncSPtr& factoryFunc, const std::string& clsID, const std::string& vID, CompSPtr& compSPtr) {
bool bRet = false;
if (!RegistComponent(type, factoryFunc, clsID)) return bRet;
if (clsID == "" || vID == "") return bRet;
if (_compMapDefault.find(clsID) == _compMapDefault.end())
{
CompSPtrMap subCompMap;
_compMapDefault.insert(CompMap::value_type(clsID, subCompMap));
}
std::map<std::string, CompSPtr> &subCompMap = _compMapDefault[clsID];
if (subCompMap.find(vID) == subCompMap.end())
{
CompSPtr compSptr;
if (CVBusinessComServer::ComCreateInstanceSPtr(clsID, vID, compSptr) == BUSINESS_VS_OK)
{
compSptr->SetBusinessControl(_pDefaultBusinessControl);
subCompMap.insert(CompSPtrMap::value_type(vID, compSptr));
bRet = true;
}
}
return bRet;
}
bool CComServerControl::RegistComponent(const int& type, const VBusinessComFactoryFuncSPtr& factoryFunc, const std::string& clsID, const bool& isComRegist) {
_compFactoryMap[type] = factoryFunc;
if (isComRegist)
{
return CVBusinessComServer::ComRegist(clsID, factoryFunc) == BUSINESS_VS_OK;
}
return true;
}
bool CComServerControl::AddComponent(const int& type, const VBusinessComFactoryFuncSPtr& factoryFunc, const std::string& clsID, const std::string& vID, CompSPtr& compSPtr) {
bool bRet = false;
if (!RegistComponent(type, factoryFunc, clsID)) return bRet;
if (clsID
com_compent.tar.gz （26个子文件） 
com_compent 
comserver_control.cpp 9KB comserver_control.h 3KB http_pool_interface.h 2KB aaaaaa_if.cpp 176B test_com.cpp 2KB comserver_define.h 415B business_engine_interface.h 2KB Makefile 723B shared_pointer_guard.h 2KB aaaaaa_if.h 276B business_control_interface.h 1KB comserver_config.h 1KB http_pool.cpp 3KB business_engine_comserver.cpp 1KB HttpClient.cpp 1KB http_pool_factory.cpp 512B aaaaaa_com_factory.h 452B http_pool_factory.h 210B business_engine_factory.h 448B business_engine_comserver.h 1KB aaaaaa_com_factory.cpp 704B business_control_impl.cpp 2KB aaaaaa_com_interface.h 359B http_pool.h 2KB business_control_impl.h 1KB HttpClient.h 1KB资源评论
