HP Socket
v6.0.3
إطار شبكة عالي الأداء
# include < hpsocket/HPSocket.h >
/* Listener Class */
class CListenerImpl : public CTcpPullServerListener
{
public:
// 5. process network events
virtual EnHandleResult OnPrepareListen (ITcpServer* pSender, SOCKET soListen);
virtual EnHandleResult OnAccept (ITcpServer* pSender, CONNID dwConnID, UINT_PTR soClient);
virtual EnHandleResult OnHandShake (ITcpServer* pSender, CONNID dwConnID);
virtual EnHandleResult OnReceive (ITcpServer* pSender, CONNID dwConnID, int iLength);
virtual EnHandleResult OnSend (ITcpServer* pSender, CONNID dwConnID, const BYTE* pData, int iLength);
virtual EnHandleResult OnClose (ITcpServer* pSender, CONNID dwConnID, EnSocketOperation enOperation, int iErrorCode);
virtual EnHandleResult OnShutdown (ITcpServer* pSender);
};
int main ( int argc, char * const argv[])
{
// 1. Create listener object
CListenerImpl s_listener;
// 2. Create component object (and binding with listener object)
CTcpPullServerPtr s_pserver (&s_listener);
// 3. Start component object
if (!s_pserver-> Start ( " 0.0.0.0 " , 5555 ))
exit ( 1 );
/* wait for exit */
// ... ...
// 6. (optional) Stop component object
s_pserver-> Stop ();
return 0 ;
// 7. Destroy component object automatically
// 8. Destroy listener object automatically
} #include <hpsocket/HPSocket4C.h>
// 5. process network events
EnHandleResult __HP_CALL OnConnect ( HP_Agent pSender , HP_CONNID dwConnID );
EnHandleResult __HP_CALL OnReceive ( HP_Agent pSender , HP_CONNID dwConnID , int iLength );
EnHandleResult __HP_CALL OnSend ( HP_Agent pSender , HP_CONNID dwConnID , const BYTE * pData , int iLength );
EnHandleResult __HP_CALL OnClose ( HP_Agent pSender , HP_CONNID dwConnID , En_HP_SocketOperation enOperation , int iErrorCode );
EnHandleResult __HP_CALL OnShutdown ( HP_Agent pSender );
int main ( int argc , char * const argv [])
{
HP_TcpPullAgentListener s_listener ;
HP_TcpPullAgent s_agent ;
// 1. Create listener object
s_listener = :: Create_HP_TcpPullAgentListener ();
// 2. Create component object (and binding with listener object)
s_agent = :: Create_HP_TcpPullAgent ( s_listener );
/* Set listener callbacks */
:: HP_Set_FN_Agent_OnConnect ( s_listener , OnConnect );
:: HP_Set_FN_Agent_OnSend ( s_listener , OnSend );
:: HP_Set_FN_Agent_OnPullReceive ( s_listener , OnReceive );
:: HP_Set_FN_Agent_OnClose ( s_listener , OnClose );
:: HP_Set_FN_Agent_OnShutdown ( s_listener , OnShutdown );
// 3. Start component object
if (!:: HP_Agent_Start ( s_agent , "0.0.0.0" , TRUE))
exit ( 1 );
// 4. Connect to dest host
:: HP_Agent_Connect ( s_agent , REMOTE_HOST_1 , REMOTE_PORT_1 , nullptr );
:: HP_Agent_Connect ( s_agent , REMOTE_HOST_2 , REMOTE_PORT_2 , nullptr );
:: HP_Agent_Connect ( s_agent , REMOTE_HOST_3 , REMOTE_PORT_3 , nullptr );
/* wait for exit */
// ... ...
// 6. (optional) Stop component object
:: HP_Agent_Stop ( s_agent );
// 7. Destroy component object
:: Destroy_HP_TcpPullAgent ( s_agent );
// 8. Destroy listener object
:: Destroy_HP_TcpPullAgentListener ( s_listener );
return 0 ;
}
