Add business processing code .use center as a Codename

center network and threadpool are supported

Author: xengine-qyt

XEngine_Source/XEngine_StorageApp/StorageApp_Center.cpp

@@ -0,0 +1,61 @@
+#include "StorageApp_Hdr.h"
+
+XHTHREAD CALLBACK XEngine_Center_HTTPThread(LPVOID lParam)
+{
+	int nThreadPos = *(int*)lParam;
+	TCHAR tszMsgBuffer[10240];
+	nThreadPos++;
+
+	while (bIsRun)
+	{
+		//等待指定线程事件触发
+		if (RfcComponents_HttpServer_EventWaitEx(xhCenterHttp, nThreadPos))
+		{
+			int nListCount = 0;
+			RFCCOMPONENTS_HTTP_REQPARAM st_HTTPParam;
+			RFCCOMPONENTS_HTTP_PKTCLIENT** ppSt_PKTClient;
+
+			memset(&st_HTTPParam, '\0', sizeof(RFCCOMPONENTS_HTTP_REQPARAM));
+			memset(tszMsgBuffer, '\0', sizeof(tszMsgBuffer));
+			//获取当前队列池中所有触发上传客户端
+			RfcComponents_HttpServer_GetPoolEx(xhCenterHttp, nThreadPos, &ppSt_PKTClient, &nListCount);
+			for (int i = 0; i < nListCount; i++)
+			{
+				for (int j = 0; j < ppSt_PKTClient[i]->nPktCount; j++)
+				{
+					int nMsgLen = 10240;
+					//获得指定上传客户端触发信息
+					if (RfcComponents_HttpServer_GetClientEx(xhCenterHttp, ppSt_PKTClient[i]->tszClientAddr, tszMsgBuffer, &nMsgLen, &st_HTTPParam))
+					{
+						XEngine_Task_HttpCenter(ppSt_PKTClient[i]->tszClientAddr, tszMsgBuffer, nMsgLen, &st_HTTPParam);
+					}
+				}
+			}
+			BaseLib_OperatorMemory_Free((XPPPMEM)&ppSt_PKTClient, nListCount);
+		}
+	}
+	return 0;
+}
+BOOL XEngine_Task_HttpCenter(LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, int nMsgLen, RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam)
+{
+	int nSDLen = 2048;
+	TCHAR tszSDBuffer[2048];
+	RFCCOMPONENTS_HTTP_HDRPARAM st_HDRParam;
+
+	memset(tszSDBuffer, '\0', sizeof(tszSDBuffer));
+	memset(&st_HDRParam, '\0', sizeof(RFCCOMPONENTS_HTTP_HDRPARAM));
+
+	LPCTSTR lpszMethodName = _T("POST");
+	if (0 != _tcsncmp(lpszMethodName, pSt_HTTPParam->tszHttpMethod, _tcslen(lpszMethodName)))
+	{
+		st_HDRParam.bIsClose = TRUE;
+		st_HDRParam.nHttpCode = 405;
+
+		RfcComponents_HttpServer_SendMsgEx(xhCenterHttp, tszSDBuffer, &nSDLen, &st_HDRParam);
+		XEngine_Net_SendMsg(lpszClientAddr, tszSDBuffer, nSDLen, STORAGE_NETTYPE_HTTPUPLOADER);
+		XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("业务客户端:%s,发送的方法不支持"), lpszClientAddr);
+		return FALSE;
+	}
+	
+	return TRUE;
+}

XEngine_Source/XEngine_StorageApp/StorageApp_Center.h

@@ -0,0 +1,4 @@
+#pragma once
+
+XHTHREAD CALLBACK XEngine_Center_HTTPThread(LPVOID lParam);
+BOOL XEngine_Task_HttpCenter(LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, int nMsgLen, RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam);

XEngine_Source/XEngine_StorageApp/StorageApp_Hdr.h

@@ -47,6 +47,7 @@ using namespace std;
 
 #define STORAGE_NETTYPE_HTTPUPLOADER 1
 #define STORAGE_NETTYPE_HTTPDOWNLOAD 2
+#define STORAGE_NETTYPE_HTTPCENTER 3
 
 extern BOOL bIsRun;
 extern XLOG xhLog;
@@ -55,11 +56,14 @@ extern XNETHANDLE xhHBDownload;
 extern XNETHANDLE xhHBUPLoader;
 extern XNETHANDLE xhNetDownload;
 extern XNETHANDLE xhNetUPLoader;
+extern XNETHANDLE xhNetCenter;
 extern XNETHANDLE xhUPPool;
 extern XNETHANDLE xhDLPool;
 extern XNETHANDLE xhSDPool;
+extern XNETHANDLE xhCTPool;
 extern XHANDLE xhUPHttp;
 extern XHANDLE xhDLHttp;
+extern XHANDLE xhCenterHttp;
 
 extern XENGINE_SERVERCONFIG st_ServiceCfg;
 
@@ -68,6 +72,7 @@ extern XENGINE_SERVERCONFIG st_ServiceCfg;
 #include "StorageApp_Config.h"
 #include "StorageApp_Download.h"
 #include "StorageApp_UPLoader.h"
+#include "StorageApp_Center.h"
 
 #ifdef _WINDOWS
 #pragma comment(lib,"Ws2_32.lib")

XEngine_Source/XEngine_StorageApp/StorageApp_Network.cpp

@@ -19,8 +19,9 @@ void CALLBACK XEngine_Callback_DownloadRecv(LPCTSTR lpszClientAddr, SOCKET hSock
 }
 void CALLBACK XEngine_Callback_DownloadLeave(LPCTSTR lpszClientAddr, SOCKET hSocket, LPVOID lParam)
 {
-	XEngine_Net_CloseClient(lpszClientAddr, FALSE, FALSE);
+	XEngine_Net_CloseClient(lpszClientAddr, FALSE, STORAGE_NETTYPE_HTTPDOWNLOAD);
 }
+//////////////////////////////////////////////////////////////////////////
 BOOL CALLBACK XEngine_Callback_UPLoaderLogin(LPCTSTR lpszClientAddr, SOCKET hSocket, LPVOID lParam)
 {
 	RfcComponents_HttpServer_CreateClientEx(xhUPHttp, lpszClientAddr, 0);
@@ -41,23 +42,56 @@ void CALLBACK XEngine_Callback_UPLoaderRecv(LPCTSTR lpszClientAddr, SOCKET hSock
 }
 void CALLBACK XEngine_Callback_UPLoaderLeave(LPCTSTR lpszClientAddr, SOCKET hSocket, LPVOID lParam)
 {
-	XEngine_Net_CloseClient(lpszClientAddr, FALSE, TRUE);
+	XEngine_Net_CloseClient(lpszClientAddr, FALSE, STORAGE_NETTYPE_HTTPUPLOADER);
+}
+//////////////////////////////////////////////////////////////////////////
+BOOL CALLBACK XEngine_Callback_CenterLogin(LPCTSTR lpszClientAddr, SOCKET hSocket, LPVOID lParam)
+{
+	RfcComponents_HttpServer_CreateClientEx(xhUPHttp, lpszClientAddr, 0);
+	XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("业务客户端：%s，进入了服务器"), lpszClientAddr);
+	return TRUE;
+}
+void CALLBACK XEngine_Callback_CenterRecv(LPCTSTR lpszClientAddr, SOCKET hSocket, LPCTSTR lpszRecvMsg, int nMsgLen, LPVOID lParam)
+{
+	if (!RfcComponents_HttpServer_InserQueueEx(xhCenterHttp, lpszClientAddr, lpszRecvMsg, nMsgLen))
+	{
+		XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("业务客户端：%s，投递数据失败,大小:%d,错误;%lX"), lpszClientAddr, nMsgLen, HttpServer_GetLastError());
+		return;
+	}
+	XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_DEBUG, _T("业务客户端：%s，投递包成功，大小：%d"), lpszClientAddr, nMsgLen);
+}
+void CALLBACK XEngine_Callback_CenterLeave(LPCTSTR lpszClientAddr, SOCKET hSocket, LPVOID lParam)
+{
+	XEngine_Net_CloseClient(lpszClientAddr, FALSE, STORAGE_NETTYPE_HTTPCENTER);
 }
 //////////////////////////////////////////////////////////////////////////
 void CALLBACK XEngine_Callback_HBDownload(LPCTSTR lpszClientAddr, SOCKET hSocket, int nStatus, LPVOID lParam)
 {
-	XEngine_Net_CloseClient(lpszClientAddr, TRUE);
+	XEngine_Net_CloseClient(lpszClientAddr, TRUE, STORAGE_NETTYPE_HTTPDOWNLOAD);
 }
 void CALLBACK XEngine_Callback_HBUPLoader(LPCTSTR lpszClientAddr, SOCKET hSocket, int nStatus, LPVOID lParam)
 {
-	XEngine_Net_CloseClient(lpszClientAddr, TRUE);
+	XEngine_Net_CloseClient(lpszClientAddr, TRUE, STORAGE_NETTYPE_HTTPUPLOADER);
 }
 //////////////////////////////////////////////////////////////////////////
-BOOL XEngine_Net_CloseClient(LPCTSTR lpszClientAddr, BOOL bHBLeave, BOOL bUP)
+BOOL XEngine_Net_CloseClient(LPCTSTR lpszClientAddr, BOOL bHBLeave, int nType)
 {
 	LPCTSTR lpszLeaveMsg = bHBLeave ? _T("心跳超时") : _T("主动断开");
-	LPCTSTR lpszClientType = bUP ? _T("上传客户端") : _T("下载客户端");
+	tstring m_StrClient;
 
+	if (STORAGE_NETTYPE_HTTPUPLOADER == nType)
+	{
+		m_StrClient = _T("上传客户端");
+	}
+	else if (STORAGE_NETTYPE_HTTPDOWNLOAD == nType)
+	{
+		m_StrClient = _T("下载客户端");
+	}
+	else
+	{
+		m_StrClient = _T("业务客户端");
+	}
+	
 	if (bHBLeave)
 	{
 		NetCore_TCPXCore_CloseForClientEx(xhNetDownload, lpszClientAddr);
@@ -72,7 +106,8 @@ BOOL XEngine_Net_CloseClient(LPCTSTR lpszClientAddr, BOOL bHBLeave, BOOL bUP)
 	Session_DLStroage_Delete(lpszClientAddr);
 	RfcComponents_HttpServer_CloseClinetEx(xhUPHttp, lpszClientAddr);
 	RfcComponents_HttpServer_CloseClinetEx(xhDLHttp, lpszClientAddr);
-	XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("%s：%s，与服务器断开，原因：%s"), lpszClientType, lpszClientAddr, lpszLeaveMsg);
+	RfcComponents_HttpServer_CloseClinetEx(xhCenterHttp, lpszClientAddr);
+	XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("%s：%s，与服务器断开，原因：%s"), m_StrClient.c_str(), lpszClientAddr, lpszLeaveMsg);
 	return TRUE;
 }
 ///////////////////////////////////////////////////////////////////////////////////

XEngine_Source/XEngine_StorageApp/StorageApp_Network.h

@@ -6,9 +6,12 @@ void CALLBACK XEngine_Callback_DownloadLeave(LPCTSTR lpszClientAddr, SOCKET hSoc
 BOOL CALLBACK XEngine_Callback_UPLoaderLogin(LPCTSTR lpszClientAddr, SOCKET hSocket, LPVOID lParam);
 void CALLBACK XEngine_Callback_UPLoaderRecv(LPCTSTR lpszClientAddr, SOCKET hSocket, LPCTSTR lpszRecvMsg, int nMsgLen, LPVOID lParam);
 void CALLBACK XEngine_Callback_UPLoaderLeave(LPCTSTR lpszClientAddr, SOCKET hSocket, LPVOID lParam);
+BOOL CALLBACK XEngine_Callback_CenterLogin(LPCTSTR lpszClientAddr, SOCKET hSocket, LPVOID lParam);
+void CALLBACK XEngine_Callback_CenterRecv(LPCTSTR lpszClientAddr, SOCKET hSocket, LPCTSTR lpszRecvMsg, int nMsgLen, LPVOID lParam);
+void CALLBACK XEngine_Callback_CenterLeave(LPCTSTR lpszClientAddr, SOCKET hSocket, LPVOID lParam);
 
 void CALLBACK XEngine_Callback_HBDownload(LPCTSTR lpszClientAddr, SOCKET hSocket, int nStatus, LPVOID lParam);
 void CALLBACK XEngine_Callback_HBUPLoader(LPCTSTR lpszClientAddr, SOCKET hSocket, int nStatus, LPVOID lParam);
 
-BOOL XEngine_Net_CloseClient(LPCTSTR lpszClientAddr, BOOL bHBLeave, BOOL bUP = TRUE);
+BOOL XEngine_Net_CloseClient(LPCTSTR lpszClientAddr, BOOL bHBLeave, int nType = STORAGE_NETTYPE_HTTPDOWNLOAD);
 BOOL XEngine_Net_SendMsg(LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, int nMsgLen, int nType = STORAGE_NETTYPE_HTTPDOWNLOAD);

XEngine_Source/XEngine_StorageApp/XEngine_StorageApp.cpp

@@ -7,11 +7,14 @@ XNETHANDLE xhHBDownload = 0;
 XNETHANDLE xhHBUPLoader = 0;
 XNETHANDLE xhNetDownload = 0;
 XNETHANDLE xhNetUPLoader = 0;
+XNETHANDLE xhNetCenter = 0;
 XNETHANDLE xhUPPool = 0;
 XNETHANDLE xhDLPool = 0;
 XNETHANDLE xhSDPool = 0;
+XNETHANDLE xhCTPool = 0;
 XHANDLE xhUPHttp = NULL;
 XHANDLE xhDLHttp = NULL;
+XHANDLE xhCenterHttp = NULL;
 
 XENGINE_SERVERCONFIG st_ServiceCfg;
 
@@ -21,27 +24,22 @@ void ServiceApp_Stop(int signo)
 	{
 		XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_WARN, _T("存储中心服务器退出..."));
 		bIsRun = FALSE;
-		printf("1\n");
 		RfcComponents_HttpServer_DestroyEx(xhUPHttp);
 		RfcComponents_HttpServer_DestroyEx(xhDLHttp);
-		printf("2\n");
+		RfcComponents_HttpServer_DestroyEx(xhCenterHttp);
 		NetCore_TCPXCore_DestroyEx(xhNetDownload);
 		NetCore_TCPXCore_DestroyEx(xhNetUPLoader);
-		printf("3\n");
+		NetCore_TCPXCore_DestroyEx(xhNetCenter);
 		SocketOpt_HeartBeat_DestoryEx(xhHBDownload);
 		SocketOpt_HeartBeat_DestoryEx(xhHBUPLoader);
-		printf("4\n");
 		ManagePool_Thread_NQDestroy(xhUPPool);
 		ManagePool_Thread_NQDestroy(xhDLPool);
 		ManagePool_Thread_NQDestroy(xhSDPool);
-		printf("5\n");
+		ManagePool_Thread_NQDestroy(xhCTPool);
 		HelpComponents_XLog_Destroy(xhLog);
-		printf("6\n");
 		Session_DLStroage_Destory();
 		Session_UPStroage_Destory();
-		printf("7\n");
 		XStorageSQL_Destory();
-		printf("8\n");
 		exit(0);
 	}
 }
@@ -90,6 +88,7 @@ int main(int argc, char** argv)
 	THREADPOOL_PARAMENT** ppSt_ListUPThread;
 	THREADPOOL_PARAMENT** ppSt_ListDLThread;
 	THREADPOOL_PARAMENT** ppSt_ListSDThread;
+	THREADPOOL_PARAMENT** ppSt_ListCTThread;
 
 	memset(&st_XLogConfig, '\0', sizeof(HELPCOMPONENTS_XLOG_CONFIGURE));
 	memset(&st_ServiceCfg, '\0', sizeof(XENGINE_SERVERCONFIG));
@@ -163,6 +162,13 @@ int main(int argc, char** argv)
 		goto XENGINE_EXITAPP;
 	}
 	XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("启动服务中，初始化HTTP上传服务成功，IO线程个数:%d"), st_ServiceCfg.st_XMax.nStorageUPThread);
+	xhCenterHttp = RfcComponents_HttpServer_InitEx(lpszHTTPCode, lpszHTTPMime, st_ServiceCfg.st_XMax.nCenterThread);
+	if (NULL == xhCenterHttp)
+	{
+		XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("启动服务器中，初始化HTTP业务服务失败，错误：%lX"), HttpServer_GetLastError());
+		goto XENGINE_EXITAPP;
+	}
+	XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("启动服务中，初始化HTTP业务服务成功，IO线程个数:%d"), st_ServiceCfg.st_XMax.nCenterThread);
 
 	if (!NetCore_TCPXCore_StartEx(&xhNetDownload, st_ServiceCfg.nStorageDLPort, st_ServiceCfg.st_XMax.nMaxClient, st_ServiceCfg.st_XMax.nIOThread))
 	{
@@ -182,6 +188,15 @@ int main(int argc, char** argv)
 	NetCore_TCPXCore_RegisterCallBackEx(xhNetUPLoader, XEngine_Callback_UPLoaderLogin, XEngine_Callback_UPLoaderRecv, XEngine_Callback_UPLoaderLeave);
 	XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("启动服务中，注册上传存储网络服务事件成功！"));
 
+	if (!NetCore_TCPXCore_StartEx(&xhNetCenter, st_ServiceCfg.nCenterPort, st_ServiceCfg.st_XMax.nMaxClient, st_ServiceCfg.st_XMax.nIOThread))
+	{
+		XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("启动服务器中，启动业务控制存储网络服务失败,端口:%d，错误：%lX"), st_ServiceCfg.nCenterPort, NetCore_GetLastError());
+		goto XENGINE_EXITAPP;
+	}
+	XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("启动服务中，启动业务控制存储网络服务成功，句柄：%llu，端口：%d,IO线程个数:%d"), xhNetCenter, st_ServiceCfg.nCenterPort, st_ServiceCfg.st_XMax.nIOThread);
+	NetCore_TCPXCore_RegisterCallBackEx(xhNetCenter, XEngine_Callback_UPLoaderLogin, XEngine_Callback_UPLoaderRecv, XEngine_Callback_UPLoaderLeave);
+	XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("启动服务中，注册业务控制存储存储网络服务事件成功！"));
+
 	if (!Session_DLStroage_Init(st_ServiceCfg.st_XMax.nStorageDLThread))
 	{
 		XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("启动服务器中，启动下载会话服务失败，错误：%lX"), Session_GetLastError());
@@ -198,6 +213,7 @@ int main(int argc, char** argv)
 	BaseLib_OperatorMemory_Malloc((XPPPMEM)&ppSt_ListDLThread, st_ServiceCfg.st_XMax.nStorageDLThread, sizeof(THREADPOOL_PARAMENT));
 	BaseLib_OperatorMemory_Malloc((XPPPMEM)&ppSt_ListSDThread, st_ServiceCfg.st_XMax.nStorageDLThread, sizeof(THREADPOOL_PARAMENT));
 	BaseLib_OperatorMemory_Malloc((XPPPMEM)&ppSt_ListUPThread, st_ServiceCfg.st_XMax.nStorageUPThread, sizeof(THREADPOOL_PARAMENT));
+	BaseLib_OperatorMemory_Malloc((XPPPMEM)&ppSt_ListCTThread, st_ServiceCfg.st_XMax.nCenterThread, sizeof(THREADPOOL_PARAMENT));
 	for (int i = 0; i < st_ServiceCfg.st_XMax.nStorageDLThread; i++)
 	{
 		int* pInt_Pos = new int;
@@ -237,6 +253,21 @@ int main(int argc, char** argv)
 	}
 	XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("启动服务中，启动HTTP上传任务处理线程池成功,线程池个数:%d"), st_ServiceCfg.st_XMax.nStorageDLThread);
 
+	for (int i = 0; i < st_ServiceCfg.st_XMax.nCenterThread; i++)
+	{
+		int* pInt_Pos = new int;
+		*pInt_Pos = i;
+
+		ppSt_ListCTThread[i]->lParam = pInt_Pos;
+		ppSt_ListCTThread[i]->fpCall_ThreadsTask = XEngine_Center_HTTPThread;
+	}
+	if (!ManagePool_Thread_NQCreate(&xhCTPool, &ppSt_ListCTThread, st_ServiceCfg.st_XMax.nCenterThread))
+	{
+		XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("启动服务中，启动HTTP业务处理线程池失败，错误：%d"), errno);
+		goto XENGINE_EXITAPP;
+	}
+	XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("启动服务中，启动HTTP业务任务处理线程池成功,线程池个数:%d"), st_ServiceCfg.st_XMax.nCenterThread);
+
 	m_StrVersion = st_ServiceCfg.st_XVer.pStl_ListStorage->front();
 	XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("所有服务成功启动，存储中心服务运行中，发行版本次数:%d,当前运行版本：%s。。。"), st_ServiceCfg.st_XVer.pStl_ListStorage->size(), m_StrVersion.c_str());
 
@@ -252,15 +283,18 @@ int main(int argc, char** argv)
 		XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("存储中心服务关闭，服务器退出..."));
 		bIsRun = FALSE;
 
+		RfcComponents_HttpServer_DestroyEx(xhUPHttp);
+		RfcComponents_HttpServer_DestroyEx(xhDLHttp);
+		RfcComponents_HttpServer_DestroyEx(xhCenterHttp);
 		NetCore_TCPXCore_DestroyEx(xhNetDownload);
 		NetCore_TCPXCore_DestroyEx(xhNetUPLoader);
+		NetCore_TCPXCore_DestroyEx(xhNetCenter);
 		SocketOpt_HeartBeat_DestoryEx(xhHBDownload);
 		SocketOpt_HeartBeat_DestoryEx(xhHBUPLoader);
-		RfcComponents_HttpServer_DestroyEx(xhUPHttp);
-		RfcComponents_HttpServer_DestroyEx(xhDLHttp);
 		ManagePool_Thread_NQDestroy(xhUPPool);
 		ManagePool_Thread_NQDestroy(xhDLPool);
 		ManagePool_Thread_NQDestroy(xhSDPool);
+		ManagePool_Thread_NQDestroy(xhCTPool);
 		HelpComponents_XLog_Destroy(xhLog);
 		Session_DLStroage_Destory();
 		Session_UPStroage_Destory();

XEngine_Source/XEngine_StorageApp/XEngine_StorageApp.vcxproj

@@ -142,6 +142,7 @@
     </Link>
   </ItemDefinitionGroup>
   <ItemGroup>
+    <ClCompile Include="StorageApp_Center.cpp" />
     <ClCompile Include="StorageApp_Config.cpp" />
     <ClCompile Include="StorageApp_Download.cpp" />
     <ClCompile Include="StorageApp_Network.cpp" />
@@ -150,6 +151,7 @@
     <ClCompile Include="XEngine_StorageApp.cpp" />
   </ItemGroup>
   <ItemGroup>
+    <ClInclude Include="StorageApp_Center.h" />
     <ClInclude Include="StorageApp_Config.h" />
     <ClInclude Include="StorageApp_Download.h" />
     <ClInclude Include="StorageApp_Hdr.h" />

XEngine_Source/XEngine_StorageApp/XEngine_StorageApp.vcxproj.filters

@@ -33,6 +33,9 @@
     <ClCompile Include="StorageApp_UPLoader.cpp">
       <Filter>源文件</Filter>
     </ClCompile>
+    <ClCompile Include="StorageApp_Center.cpp">
+      <Filter>源文件</Filter>
+    </ClCompile>
   </ItemGroup>
   <ItemGroup>
     <ClInclude Include="StorageApp_Config.h">
@@ -53,5 +56,8 @@
     <ClInclude Include="StorageApp_UPLoader.h">
       <Filter>头文件</Filter>
     </ClInclude>
+    <ClInclude Include="StorageApp_Center.h">
+      <Filter>头文件</Filter>
+    </ClInclude>
   </ItemGroup>
 </Project>