server/websocket/wsClientMgr.h

/**
* @brief
websocket客户端管理器类

* @version
  V 1.0.0

* @author
  王益俊

* @date
  创建时间:  2018-08-17\n

* @note
  2018-08-17  创建类。\n

* @warning

* @bug
  
*/

#pragma once

#include <vector>
#include <string>
#include <map>

#include <boost/serialization/singleton.hpp>

#include "wsClient.h"
#include "ws_common.h"
#include "jsonBuilder.h"


namespace YA
{
	class wsClientMgr
	{
	private:
		std::vector<std::shared_ptr<wsClient>> __wsClientList;//ws客户端列表
		std::map<std::string,int>  __uriIndexList;//uri和客户端下标对应表
		std::string __LastError;//最新错误
		std::recursive_mutex __lock;//锁
		jsonBuilder __jsBuilder;//json生成器
	public:
		wsClientMgr();
		~wsClientMgr();
		/**
		* @brief
		  重载[]运算符。

		* @param  [in] int index  下标\n

		* @return 下标对应的客户端\n

		* @note

		* @warning

		* @bug

		*/
		std::shared_ptr<wsClient> operator[]( int index )
		{
			std::lock_guard<std::recursive_mutex> lock( __lock );
			std::shared_ptr<wsClient> pClient;

			if ( index < 0 )
			{
				return pClient;
			}

			if ( index < (int)__wsClientList.size() )
			{
				pClient = __wsClientList[index];
			}

			return pClient;
		}
		/**
		* @brief
		；构造函数。

		* @param  [in] const std::vector<std::string> uri_list  服务器uri列表\n
		* @param  [in] const std::map<std::string, MSG_HANDLE_FUNC_TYPE>& MsgFuncList  处理函数列表\n

		* @return 连接服务器是否成功\n
		* @retval  0  成功\n
        * @retval  -1  失败\n

		* @note

		* @warning

		* @bug

		*/
		void Build( const std::vector<std::string> uri_list, const std::map<std::string, MSG_HANDLE_FUNC_TYPE>& MsgFuncList );
		/**
		* @brief
		；连接函数。

		* @param  [in] int time_out  超时(单位：秒),默认是3秒\n

		* @return 连接服务器是否成功\n
		* @retval  0  成功\n
        * @retval  -1  失败\n

		* @note

		* @warning

		* @bug

		*/
		int connect( int time_out = 3 );
		/**
		* @brief
		；登录函数。

		* @param  无\n

		* @return 无\n

		* @note

		* @warning

		* @bug

		*/
		void login();
		/**
		* @brief
		发送数据函数。

		* @param  [in] const std::string & Cmd  要发送的命令\n
		* @param  [in] const std::string& Data  要发送的数据\n

		* @return 无\n

		* @note

		* @warning

		* @bug

		*/
		void send( const std::string & Cmd, const std::string & Data );
		/**
		* @brief
		根据URI(连接串)获得对应的客户端函数。

		* @param  [in] const std::string& URI  \n

		* @return 获得的客户端\n

		* @note

		* @warning

		* @bug

		*/
		std::shared_ptr<wsClient> GetClientByURI( const std::string& URI );
		/**
		* @brief
		关闭函数。

		* @param  无\n

		* @return 无\n

		* @note

		* @warning

		* @bug

		*/
		void close();
		/**
		* @brief
		获得是否已连接服务器端函数。

		* @param  无\n

		* @return 是否已连接服务器\n

		* @note

		* @warning

		* @bug

		*/
		bool IsConnected();
		/**
		* @brief
		获得是否已登录成功函数。

		* @param  无\n

		* @return 是否已登录成功\n

		* @note

		* @warning

		* @bug

		*/
		bool IsLogined();
		/**
		* @brief
		获得Socket是否已打开函数。

		* @param  无\n

		* @return Socket是否已打开\n

		* @note

		* @warning

		* @bug

		*/
		bool IsSktOpened();
		/**
		* @brief
		发送车辆进入特殊区域函数。

		* @param  [in] const _BASE_CARD_& stCard  卡结构体\n

		* @return 无\n

		* @note

		* @warning

		* @bug

		*/
		void SendSpecialAreaProcess( const _BASE_CARD_& stCard );
	};
}

//单件相关定义
typedef boost::serialization::singleton<YA::wsClientMgr> singleton_wsClientMgr;
#define swsClientMgr singleton_wsClientMgr::get_mutable_instance()
#define swsClientMgr_const singleton_wsClientMgr::get_const_instance()