关于将业务逻辑做成Windows下的“服务”类型程序的问题

chengweikang_

我今天下午搭建业务逻辑服务程序，考虑将业务逻辑的程序做成服务类型程序，程序搭建完成后，也以程序也以服务形式正式运行了，日志也打印了。
也在程序加入了AnyChatServerSDK等，也注册了相关的回调函数。但就是回调消息收不到！(如用户身份验证回调函数)
请问是不是不能将业务逻辑服务器做成服务类型的程序，就是在windows下服务栏中的一样，类似于SqlServer，oracle服务的类型。

#include "stdafx.h"
#include "JDCIMBizServer.h"
#include "AnyChatServerSDK.h"
#pragma comment(lib,"AnyChatServerSDK.lib")

#define SENDBUF_STYLE_SYSTEM        0                // 系统广播
#define SENDBUF_STYLE_ROOM                1                // 房间广播
#define SENDBUF_STYLE_USER                2                // 指定用户

#define TIMER_REFRESH_ONLINES        1                // 刷新在线用户数定时器

#ifdef _DEBUG
#define new DEBUG_NEW
#endif


// 服务器应用程序消息回调函数定义
void CALLBACK OnServerAppMessageExCallBack(DWORD dwNotifyMessage, DWORD wParam, DWORD lParam, LPVOID lpUserValue)
{
        /*CAnyChatCallCenterServerDlg* lpServerDlg = (CAnyChatCallCenterServerDlg*)lpUserValue;
        if(dwNotifyMessage == BRAS_MESSAGE_CORESERVERCONN)
        {
                if(wParam == 0)
                        lpServerDlg->AppendLogString("Success connected with AnyChatCoreServer...");
                else
                        lpServerDlg->AppendLogString("Disconnected from the AnyChatCoreServer");
        }
        else if(dwNotifyMessage == BRAS_MESSAGE_RECORDSERVERCONN)
        {
                if(wParam == 0)
                {
                        CString strNotify;
                        strNotify.Format("Success connected with AnyChatRecordServer...(serverid:%d)", lParam);
                        lpServerDlg->AppendLogString(strNotify);
                }
                else
                {
                        CString strNotify;
                        strNotify.Format("Disconnected from the AnyChatRecordServer...(errorcode:%d, serverid:%d)", wParam, lParam);
                        lpServerDlg->AppendLogString(strNotify);
                }
        }
        else
        {
                CString strNotify;
                strNotify.Format("OnServerAppMessageExCallBack(dwNotifyMessage:%d, wParam:%d, lParam:%d)", dwNotifyMessage, wParam, lParam);
                lpServerDlg->AppendLogString(strNotify);
        }*/
}

/**
*        SDK定时器回调函数定义，上层应用可以在该回调中处理定时任务，而不需要额外开启线程，或是定时器
*        如果单独开启线程，或是注册Windows定时器，则必须考虑多线程同步的问题
*        而使用SDK的TimerEvent回调，则不需要考虑，因为定时器回调和别的回调函数均是顺序触发的
*/
void CALLBACK OnTimerEventCallBack(LPVOID lpUserValue)
{
//        CAnyChatCallCenterServerDlg* lpServerDlg = (CAnyChatCallCenterServerDlg*)lpUserValue;
//        if(lpServerDlg)
//        {
////                lpServerDlg->AppendLogString("定时器事件");
//        }
}

// 用户身份验证回调函数定义
DWORD CALLBACK VerifyUserCallBack(IN LPCTSTR lpUserName,IN LPCTSTR lpPassword, OUT LPDWORD lpUserID, OUT LPDWORD lpUserLevel, OUT LPTSTR lpNickName,IN DWORD dwNCLen, LPVOID lpUserValue)
{
       
        CString strMsg;
        strMsg.Format(_T("VerifyUser(%s - %s) --> userid(%d)"),lpUserName,lpPassword,(int)*lpUserID);
        WriteToLog(strMsg.GetBuffer(0));

        /*static DWORD dwUserIdSeed = 1;
        *lpUserID = dwUserIdSeed++;

        CAnyChatCallCenterServerDlg* lpServerDlg = (CAnyChatCallCenterServerDlg*)lpUserValue;
        if(lpServerDlg && lpServerDlg->m_bShowUserLog)
        {
                CString strMsg;
                strMsg.Format(_T("VerifyUser(%s - %s) --> userid(%d)"),lpUserName,lpPassword,(int)*lpUserID);
                lpServerDlg->AppendLogString(strMsg);
        }*/
        return 0;
}
// 用户申请进入房间回调函数定义
DWORD CALLBACK PrepareEnterRoomCallBack(DWORD dwUserId, DWORD dwRoomId, LPCTSTR lpRoomName,LPCTSTR lpPassword, LPVOID lpUserValue)
{
        /*CAnyChatCallCenterServerDlg* lpServerDlg = (CAnyChatCallCenterServerDlg*)lpUserValue;
        if(lpServerDlg && lpServerDlg->m_bShowUserLog)
        {
                CString strMsg;
                strMsg.Format(_T("repareEnterRoom(dwUserId:%d - dwRoomId:%d)"),(int)dwUserId,(int)dwRoomId);
                lpServerDlg->AppendLogString(strMsg);
        }*/
        return 0;
}
// 用户登录成功回调函数定义
void CALLBACK OnUserLoginActionCallBack(DWORD dwUserId, LPCTSTR szUserName, DWORD dwLevel, LPCTSTR szIpAddr, LPVOID lpUserValue)
{
        //CAnyChatCallCenterServerDlg* lpServerDlg = (CAnyChatCallCenterServerDlg*)lpUserValue;
        //if(!lpServerDlg)
        //        return;

        //// 获取在线用户列表
        //DWORD dwOnlineUserCount = 0;
        //DWORD* lpOnlineUserIdArray = NULL;
        //BRAS_GetOnlineUsers(-1, NULL, dwOnlineUserCount);                        // 第一次查询只是获取在线用户数，为后面分配ID空间做准备
        //if(dwOnlineUserCount)
        //{
        //        lpOnlineUserIdArray = (DWORD*)malloc(dwOnlineUserCount * sizeof(DWORD));
        //        if(!lpOnlineUserIdArray)
        //                return;
        //        BRAS_GetOnlineUsers(-1, lpOnlineUserIdArray, dwOnlineUserCount);                // 第二次查询获取实际的ID列表
        //}
        //
        //// 添加用户分组
        //int iGroupId = 1;
        //BRAS_UserInfoControl(dwUserId, BRAS_USERINFO_CTRLCODE_ADDGROUP, iGroupId, 0, "我的好友");        // 用户名+密码方式登录的用户
        //iGroupId = 2;
        //BRAS_UserInfoControl(dwUserId, BRAS_USERINFO_CTRLCODE_ADDGROUP, iGroupId, 0, "在线游客");        // 密码为空的用户

        //// 将当前所有在线用户添加为自己的好友
        //if(lpOnlineUserIdArray)
        //{
        //        DWORD dwOffset = 0;
        //        while(dwOffset < dwOnlineUserCount)
        //        {
        //                DWORD dwOtherUserId = lpOnlineUserIdArray[dwOffset];
        //                if(dwOtherUserId != dwUserId)
        //                        BRAS_UserInfoControl(dwUserId, BRAS_USERINFO_CTRLCODE_ADDFRIEND, dwOtherUserId, 0, "");
        //                dwOffset++;
        //        }
        //}

        //// 设置好友与分组的关系（即好友属于哪一个分组）
        //iGroupId = 1;
        //if(lpOnlineUserIdArray)
        //{
        //        DWORD dwOffset = 0;
        //        while(dwOffset < dwOnlineUserCount)
        //        {
        //                DWORD dwOtherUserId = lpOnlineUserIdArray[dwOffset];
        //                if(dwOtherUserId != dwUserId)
        //                {
        //                        iGroupId = (dwOtherUserId > 0) ? 1 : 2;                // 游客密码为空，userid由核心服务器分配，为负数
        //                        BRAS_UserInfoControl(dwUserId, BRAS_USERINFO_CTRLCODE_SETGROUPRELATION, iGroupId, dwOtherUserId, "");
        //                }
        //                dwOffset++;
        //        }
        //}

        //// 设置当前用户信息（用户资料，客户端可以通过API：BRAC_GetUserInfo来获取这些信息）
        //int iInfoId = 1;        // InfoId由业务层自己定义
        //BRAS_SetUserInfo(dwUserId, iInfoId, szUserName, 0);
        //iInfoId = 2;
        //BRAS_SetUserInfo(dwUserId, iInfoId, szIpAddr, 0);
        //iInfoId = 3;
        //BRAS_SetUserInfo(dwUserId, iInfoId, "我的签名", 0);
        //iInfoId = 4;
        //CHAR szImageId[10] = {0};
        //_snprintf(szImageId, sizeof(szImageId), "%d", dwUserId%10 + 1);
        //BRAS_SetUserInfo(dwUserId, iInfoId, szImageId, 0);                // 随机分配一个图像ID

        //// 将本地用户添加为其它用户的好友列表中
        //if(lpOnlineUserIdArray)
        //{
        //        DWORD dwOffset = 0;
        //        while(dwOffset < dwOnlineUserCount)
        //        {
        //                DWORD dwOtherUserId = lpOnlineUserIdArray[dwOffset];
        //                if(dwOtherUserId != dwUserId)
        //                {
        //                        // 添加好友
        //                        BRAS_UserInfoControl(dwOtherUserId, BRAS_USERINFO_CTRLCODE_ADDFRIEND, dwUserId, 0, "");
        //                        // 关联好友分组
        //                        iGroupId = (dwUserId > 0) ? 1 : 2;
        //                        BRAS_UserInfoControl(dwOtherUserId, BRAS_USERINFO_CTRLCODE_SETGROUPRELATION, iGroupId, dwUserId, "");
        //                        // 下发同步指令，将新设置的好友同步给客户端
        //                        BRAS_UserInfoControl(dwOtherUserId, BRAS_USERINFO_CTRLCODE_SYNCDATA,  0, 0, "");
        //                }
        //                dwOffset++;
        //        }
        //}

        //// 下发同步指令，将前面设置的资料同步给当前客户端
        //BRAS_UserInfoControl(dwUserId, BRAS_USERINFO_CTRLCODE_SYNCDATA,  0, 0, "");

        //if(lpServerDlg->m_bShowUserLog)
        //{
        //        CString strMsg;
        //        strMsg.Format(_T("OnUserLoginAction(dwUserId:%d - Name:%s)"),(int)dwUserId,szUserName);
        //        lpServerDlg->AppendLogString(strMsg);
        //}

        //if(lpOnlineUserIdArray)
        //        free(lpOnlineUserIdArray);
}
// 用户注销回调函数定义
void CALLBACK OnUserLogoutActionExCallBack(DWORD dwUserId, DWORD dwErrorCode, LPVOID lpUserValue)
{
        //CAnyChatCallCenterServerDlg* lpServerDlg = (CAnyChatCallCenterServerDlg*)lpUserValue;
        //if(!lpServerDlg)
        //        return;

        //// 核心服务器会通知其它用户（如果是好友），提示好友下线，不需要业务服务器干预

        //if(lpServerDlg->m_bShowUserLog)
        //{
        //        CString strMsg;
        //        strMsg.Format(_T("OnUserLogoutAction(dwUserId:%d, dwErrorCode:%d)"),(int)dwUserId, dwErrorCode);
        //        lpServerDlg->AppendLogString(strMsg);
        //}
}
// 用户进入房间回调函数定义
void CALLBACK OnUserEnterRoomActionCallBack(DWORD dwUserId, DWORD dwRoomId, LPVOID lpUserValue)
{
        /*CAnyChatCallCenterServerDlg* lpServerDlg = (CAnyChatCallCenterServerDlg*)lpUserValue;
        if(lpServerDlg && lpServerDlg->m_bShowUserLog)
        {
                CString strMsg;
                strMsg.Format(_T("OnUserEnterRoomAction(dwUserId:%d - dwRoomId:%d)"),(int)dwUserId,(int)dwRoomId);
                lpServerDlg->AppendLogString(strMsg);
        }*/
}
// 用户离开房间回调函数定义
void CALLBACK OnUserLeaveRoomActionCallBack(DWORD dwUserId, DWORD dwRoomId, LPVOID lpUserValue)
{
        /*CAnyChatCallCenterServerDlg* lpServerDlg = (CAnyChatCallCenterServerDlg*)lpUserValue;
        if(lpServerDlg && lpServerDlg->m_bShowUserLog)
        {
                CString strMsg;
                strMsg.Format(_T("OnUserLeaveRoomAction(dwUserId:%d - dwRoomId:%d)"),(int)dwUserId,(int)dwRoomId);
                lpServerDlg->AppendLogString(strMsg);
        }*/
}
// 上层业务自定义数据回调函数定义
void CALLBACK OnRecvUserFilterDataCallBack(DWORD dwUserId, BYTE* lpBuf, DWORD dwLen, LPVOID lpUserValue)
{
        /*CAnyChatCallCenterServerDlg* lpServerDlg = (CAnyChatCallCenterServerDlg*)lpUserValue;
        if(lpServerDlg && lpServerDlg->m_bShowUserLog)
        {
                CString strMsg;
                strMsg.Format(_T("OnRecvUserFilterData(dwUserId:%d - Buf:%s)"),(int)dwUserId,lpBuf);
                lpServerDlg->AppendLogString(strMsg);
        }*/
}
// 收到用户文字聊天通信数据回调函数定义
void CALLBACK OnRecvUserTextMsgCallBack(DWORD dwRoomId, DWORD dwSrcUserId, DWORD dwTarUserId, BOOL bSecret, LPCTSTR lpTextMessage, DWORD dwLen, LPVOID lpUserValue)
{
        /*CAnyChatCallCenterServerDlg* lpServerDlg = (CAnyChatCallCenterServerDlg*)lpUserValue;
        if(lpServerDlg && lpServerDlg->m_bShowUserLog)
        {
                CString strMsg;
                strMsg.Format(_T("OnRecvUserTextMsg(dwRoomId:%d, dwSrcUserId:%d, dwTarUserId:%d - Buf:%s)"),(int)dwRoomId,(int)dwSrcUserId,(int)dwTarUserId,lpTextMessage);
                lpServerDlg->AppendLogString(strMsg);
        }*/
}
// 透明通道数据回调函数定义
void CALLBACK OnTransBufferCallBack(DWORD dwUserId, LPBYTE lpBuf, DWORD dwLen, LPVOID lpUserValue)
{
        /*CAnyChatCallCenterServerDlg* lpServerDlg = (CAnyChatCallCenterServerDlg*)lpUserValue;
        if(lpServerDlg && lpServerDlg->m_bShowUserLog)
        {
                CString strMsg;
                strMsg.Format(_T("OnTransBufferCallBack(dwUserId:%d - BufLen:%d)"),(int)dwUserId,dwLen);
                lpServerDlg->AppendLogString(strMsg);
        }*/
}
// 透明通道数据扩展回调函数定义
void CALLBACK OnTransBufferExCallBack(DWORD dwUserId, LPBYTE lpBuf, DWORD dwLen, DWORD wParam, DWORD lParam, DWORD dwTaskId, LPVOID lpUserValue)
{
        /*CAnyChatCallCenterServerDlg* lpServerDlg = (CAnyChatCallCenterServerDlg*)lpUserValue;
        if(lpServerDlg && lpServerDlg->m_bShowUserLog)
        {
                CString strMsg;
                strMsg.Format(_T("OnTransBufferExCallBack(dwUserId:%d - BufLen:%d - wParam:%d - lParam:%d - dwTaskId:%d)"),(int)dwUserId,dwLen, wParam, lParam, dwTaskId);
                lpServerDlg->AppendLogString(strMsg);
        }*/
}
// 文件传输回调函数定义
void CALLBACK OnTransFileCallBack(DWORD dwUserId, LPCTSTR lpFileName, LPCTSTR lpTempFilePath, DWORD dwFileLength, DWORD wParam, DWORD lParam, DWORD dwTaskId, LPVOID lpUserValue)
{
        //CAnyChatCallCenterServerDlg* lpServerDlg = (CAnyChatCallCenterServerDlg*)lpUserValue;
        //if(lpServerDlg && lpServerDlg->m_bShowUserLog)
        //{
        //        CString strMsg;
        //        strMsg.Format(_T("OnTransFileCallBack(dwUserId:%d, PathName:%s - wParam:%d - lParam:%d - dwTaskId:%d)"),(int)dwUserId, lpFileName, wParam, lParam, dwTaskId);
        //        lpServerDlg->AppendLogString(strMsg);
        //}
}
// 服务器录像回调函数定义（扩展）
void CALLBACK OnServerRecordEx_CallBack(DWORD dwUserId, LPCTSTR lpFileName, DWORD dwElapse, DWORD dwFlags, DWORD dwParam, LPCTSTR lpUserStr, DWORD dwRecordServerId, LPVOID lpUserValue)
{
        //CAnyChatCallCenterServerDlg* lpServerDlg = (CAnyChatCallCenterServerDlg*)lpUserValue;
        //if(lpServerDlg)
        //{
        //        CString strMsg;
        //        BOOL bSnapShotType = !!(dwFlags & ANYCHAT_RECORD_FLAGS_SNAPSHOT);
        //        strMsg.Format(_T("OnServerRecordExCallBack(type:%s dwUserId:%d, dwParam:%d, dwElapse:%d, FileName:%s, UserStr:%s)"), bSnapShotType?_T("SnapShot"):_T("Record"), (int)dwUserId, dwParam, dwElapse, lpFileName, lpUserStr);
        //        lpServerDlg->AppendLogString(strMsg);
        //}
}

/****************************************************************************************
  * 记录日志.
  * @param[in]                char*
  * @return                        int
  * @note                        在需要记录日志的地方传入所需要记录的字符串即可.
  * @author                        WeiKangC
  * @date                        2015/07/31
****************************************************************************************/
int WriteToLog(char* str)
{
   FILE* log;
   log = fopen(LOGFILE, "a+");
   if (log == NULL){
          OutputDebugString("Log file open failed.");
      return -1;
   }
   fprintf(log, "%s\n", str);
   fclose(log);
   return 0;
}

/****************************************************************************************
  * 判断服务是否已经被安装.
  * @param[in]                void
  * @return                        BOOL
  * @note                        判断服务是否已经被安装，在需要的地方调用即可。
  * @author                        WeiKangC
  * @date                        2015/07/31
*****************************************************************************************/
BOOL IsInstalled()
{
    BOOL bResult = FALSE;

        //打开服务控制管理器
    SC_HANDLE hSCM = ::OpenSCManager(NULL, NULL, SC_MANAGER_ALL_ACCESS);

    if (hSCM != NULL)
    {
                //打开服务
        SC_HANDLE hService = ::OpenService(hSCM, szServiceName, SERVICE_QUERY_CONFIG);
        if (hService != NULL)
        {
            bResult = TRUE;
            ::CloseServiceHandle(hService);
        }
        ::CloseServiceHandle(hSCM);
    }
    return bResult;
}
/****************************************************************************************
  * 安装服务函数.
  * @param[in]                void
  * @return                        BOOL
  * @note                        安装服务函数，在需要的地方调用即可。
  * @author                        WeiKangC
  * @date                        2015/07/31
*****************************************************************************************/
BOOL Install()
{
    if (IsInstalled())
        return TRUE;

        //打开服务控制管理器
    SC_HANDLE hSCM = ::OpenSCManager(NULL, NULL, SC_MANAGER_ALL_ACCESS);
    if (hSCM == NULL)
    {
        MessageBox(NULL, _T("Couldn't open service manager"), szServiceName, MB_OK);
        return FALSE;
    }

    // Get the executable file path
    TCHAR szFilePath[MAX_PATH];
    ::GetModuleFileName(NULL, szFilePath, MAX_PATH);

        //创建服务
    SC_HANDLE hService = ::CreateService(
        hSCM, szServiceName, szServiceName,
        SERVICE_ALL_ACCESS, SERVICE_WIN32_OWN_PROCESS,
        SERVICE_DEMAND_START, SERVICE_ERROR_NORMAL,
        szFilePath, NULL, NULL, _T(""), NULL, NULL);

    if (hService == NULL)
    {
        ::CloseServiceHandle(hSCM);
        MessageBox(NULL, _T("Couldn't create service"), szServiceName, MB_OK);
        return FALSE;
    }

    ::CloseServiceHandle(hService);
    ::CloseServiceHandle(hSCM);
    return TRUE;
}

/****************************************************************************************
  * 删除服务函数.
  * @param[in]                void
  * @return                        BOOL
  * @note                        删除服务函数，在需要的地方调用即可。
  * @author                        WeiKangC
  * @date                        2015/07/31
*****************************************************************************************/
BOOL Uninstall()
{
    if (!IsInstalled())
        return TRUE;

    SC_HANDLE hSCM = ::OpenSCManager(NULL, NULL, SC_MANAGER_ALL_ACCESS);
    if (hSCM == NULL)
    {
        MessageBox(NULL, _T("Couldn't open service manager"), szServiceName, MB_OK);
        return FALSE;
    }

    SC_HANDLE hService = ::OpenService(hSCM, szServiceName, SERVICE_STOP | DELETE);

    if (hService == NULL)
    {
        ::CloseServiceHandle(hSCM);
        MessageBox(NULL, _T("Couldn't open service"), szServiceName, MB_OK);
        return FALSE;
    }
    SERVICE_STATUS status;
    ::ControlService(hService, SERVICE_CONTROL_STOP, &status);

        //删除服务
    BOOL bDelete = :eleteService(hService);
    ::CloseServiceHandle(hService);
    ::CloseServiceHandle(hSCM);

    if (bDelete)
        return TRUE;

    WriteToLog(_T("Service could not be deleted"));
    return FALSE;
}

/****************************************************************************************
  * 初始化服务管理器服务函数.
  * @param[in]                void
  * @return                        int
  * @note                        初始化服务管理器服务函数，在需要的地方调用即可。
  * @author                        WeiKangC
  * @date                        2015/07/31
*****************************************************************************************/
int InitService()
{
        // 设置服务器应用程序消息回调函数
        BRAS_SetOnServerAppMessageExCallBack(OnServerAppMessageExCallBack);
        // 设置SDK定时器回调函数
        BRAS_SetTimerEventCallBack(1000,OnTimerEventCallBack);
        // 设置用户身份验证回调函数
        BRAS_SetVerifyUserCallBack(VerifyUserCallBack);
        // 设置用户申请进入房间回调函数
        BRAS_SetPrepareEnterRoomCallBack(PrepareEnterRoomCallBack);
        // 设置用户登录成功回调函数
        BRAS_SetOnUserLoginActionCallBack(OnUserLoginActionCallBack);
        // 设置用户注销回调函数（扩展）
        BRAS_SetOnUserLogoutActionExCallBack(OnUserLogoutActionExCallBack);
        // 设置用户进入房间回调函数
        BRAS_SetOnUserEnterRoomActionCallBack(OnUserEnterRoomActionCallBack);
        // 设置用户离开房间回调函数
        BRAS_SetOnUserLeaveRoomActionCallBack(OnUserLeaveRoomActionCallBack);
        // 设置用户上层业务自定义数据回调函数
        BRAS_SetOnRecvUserFilterDataCallBack(OnRecvUserFilterDataCallBack);
        // 用户文字聊天通信数据回调函数
        BRAS_SetOnRecvUserTextMsgCallBack(OnRecvUserTextMsgCallBack);
        // 设置透明通道数据回调函数
        BRAS_SetOnTransBufferCallBack(OnTransBufferCallBack);
        // 设置透明通道数据扩展回调函数
        BRAS_SetOnTransBufferExCallBack(OnTransBufferExCallBack);
        // 设置文件传输回调函数
        BRAS_SetOnTransFileCallBack(OnTransFileCallBack);
        // 设置服务器录像回调函数
        BRAS_SetCallBack(BRAS_CBTYPE_SERVERRECORDEX, OnServerRecordEx_CallBack);

        BRAS_InitSDK(0);

        SetTimer(NULL,TIMER_REFRESH_ONLINES, 1000, NULL);

        OutputDebugString("Monitoring startedxxxxx.");
        int result;
        result = WriteToLog("Monitoring startedxxxxxxx.");
        return(result);
}

/****************************************************************************************
  * ControlHandler .
  * @param[in]                DWORD
  * @return                        void
  * @note                        ControlHandler 。
  * @author                        WeiKangC
  * @date                        2015/07/31
*****************************************************************************************/
void ControlHandler(DWORD request)
{
   switch(request)
   {
      case SERVICE_CONTROL_STOP:
                 OutputDebugString("Monitoring stopped.");
         WriteToLog("Monitoring stopped.");

         ServiceStatus.dwWin32ExitCode = 0;
         ServiceStatus.dwCurrentState = SERVICE_STOPPED;
         SetServiceStatus (hStatus, &ServiceStatus);
         return;
                 break;
      case SERVICE_CONTROL_SHUTDOWN:
                 OutputDebugString("Monitoring stopped.");
         WriteToLog("Monitoring stopped.");

         ServiceStatus.dwWin32ExitCode = 0;
         ServiceStatus.dwCurrentState = SERVICE_STOPPED;
         SetServiceStatus (hStatus, &ServiceStatus);
         return;
                 break;
          case SERVICE_CONTROL_PAUSE:
                  OutputDebugString("Monitoring pause.");
                  WriteToLog("Monitoring pause.");

                  ServiceStatus.dwWin32ExitCode = 0 ;
                  ServiceStatus.dwCurrentState  = SERVICE_PAUSED;
                  SetServiceStatus(hStatus,&ServiceStatus);
                  return;
                  break;
          case SERVICE_CONTROL_CONTINUE:
                  OutputDebugString("Monitoring running.");
                  WriteToLog("Monitoring running.");

                  ServiceStatus.dwWin32ExitCode = 0 ;
                  ServiceStatus.dwCurrentState  = SERVICE_RUNNING;
                  SetServiceStatus(hStatus,&ServiceStatus);
                  return ;
                  break;
      default:
         break;
    }
    SetServiceStatus (hStatus, &ServiceStatus);

    return;
}
/****************************************************************************************
  * ServiceMain
  * @param[in]                DWORD
  * @return                        void
  * @note                        Service Main Control Function
  * @author                        WeiKangC
  * @date                        2015/07/31
*****************************************************************************************/
void ServiceMain(int argc, char** argv)
{   
   ServiceStatus.dwServiceType                  =   SERVICE_WIN32;
   ServiceStatus.dwCurrentState       =   SERVICE_START_PENDING;
   ServiceStatus.dwControlsAccepted   =   SERVICE_ACCEPT_STOP|SERVICE_ACCEPT_SHUTDOWN|SERVICE_ACCEPT_PAUSE_CONTINUE;
   ServiceStatus.dwWin32ExitCode          =   NO_ERROR;
   ServiceStatus.dwServiceSpecificExitCode = NO_ERROR;
   ServiceStatus.dwCheckPoint = 0;
   ServiceStatus.dwWaitHint = 30;

   hStatus = RegisterServiceCtrlHandler("JDCIMBizServer",
           (LPHANDLER_FUNCTION)ControlHandler);

   if (hStatus ==
           (SERVICE_STATUS_HANDLE)0)
   {
      WriteToLog("Registering Control Handler failed!");
      return;
   }  

   int error = InitService();
   if (error)
   {
          // Initialization failed
      ServiceStatus.dwCurrentState =  SERVICE_STOPPED;
      ServiceStatus.dwWin32ExitCode = -1;
      SetServiceStatus(hStatus, &ServiceStatus);
      return;
   }

   // We report the running status to SCM.
   ServiceStatus.dwCurrentState                           = SERVICE_RUNNING;
   ServiceStatus.dwCheckPoint                           = 0;
   ServiceStatus.dwWaitHint                                   = 0;
   ServiceStatus.dwWin32ExitCode                   = NO_ERROR;
   ServiceStatus.dwServiceSpecificExitCode = NO_ERROR;
   SetServiceStatus (hStatus, &ServiceStatus);

   MEMORYSTATUS memory = { 0 };

   // The worker loop of a service
   while (ServiceStatus.dwCurrentState
      == SERVICE_RUNNING)
   {
          //char buffer[16] = { 0 };
      //GlobalMemoryStatus(&memory);
      //sprintf(buffer, "%d", memory.dwAvailPhys);

      //OutputDebugString(buffer);
      //int result = WriteToLog(buffer);
     // if (result)
     // {
     //    ServiceStatus.dwCurrentState  = SERVICE_STOPPED;
     //    ServiceStatus.dwWin32ExitCode = -1;
     //    SetServiceStatus(hStatus,&ServiceStatus);
     //    return;
     // }
     // Sleep(SLEEP_TIME);
   }
   return;
}

int _tmain(int argc, TCHAR* argv[], TCHAR* envp[])
{
        int nRetCode = 0;

        SERVICE_TABLE_ENTRY ServiceTable[2];
        ServiceTable[0].lpServiceName = "JDCIMBizServer";
        ServiceTable[0].lpServiceProc = (LPSERVICE_MAIN_FUNCTION)ServiceMain;

        ServiceTable[1].lpServiceName = NULL;
        ServiceTable[1].lpServiceProc = NULL;

        // Start the control dispatcher thread for our service
        StartServiceCtrlDispatcher(ServiceTable);

        return nRetCode;
}