学步园

本程序是一个实验RakNet RPC3 & NetworkIDManager的Demo，修改和扩充自RakNet的RPC3例子。

公共NPC基类：

CNetBNPC.h

#ifndef ___NET_Common_CNetBNPC_H__<br /> #define ___NET_Common_CNetBNPC_H__</p> <p>#include <MessageIdentifiers.h></p> <p>/** Packet IDs*/<br /> enum PACKET_ID<br /> {<br /> NET_PACKETID_CREATE_NPC = ID_USER_PACKET_ENUM + 1<br /> };<br /> namespace RakNet<br /> {<br /> class RPC3;<br /> }<br /> namespace NetSys<br /> {<br /> class CNetBNPC : public NetworkIDObject<br /> {<br /> public:<br /> CNetBNPC(void) {}<br /> virtual ~CNetBNPC(void){}<br /> // Register in Client, Called by Server<br /> virtual void sentToBattle_C(RakNet::RPC3 *rpcFromNetwork) = 0;<br /> // Register in Server, Called by Client<br /> virtual void callBackFromBattleField_S(RakNet::RPC3 *rpcFromNetwork) = 0;<br /> virtual void bulletHit_S(RakNet::RPC3 *rpcFromNetwork) = 0;<br /> };<br /> }<br /> #endif<br />  

服务器端：

BNPC_S.h

#ifndef ___NET_Common_BNPC_S_H__<br /> #define ___NET_Common_BNPC_S_H__<br /> #include "CNetBNPC.h"</p> <p>namespace NetSys<br /> {<br /> class BNPC_S : public CNetBNPC<br /> {<br /> public:<br /> BNPC_S(void) {}<br /> virtual ~BNPC_S(void){}<br /> // Register in Client, Called by Server<br /> virtual void sentToBattle_C(RakNet::RPC3 *rpcFromNetwork)<br /> {<br /> printf("BNPC_S : sentToBattle_C , Func is called from %s /n", rpcFromNetwork->GetLastSenderAddress().ToString());<br /> }<br /> // Register in Server, Called by Client<br /> virtual void callBackFromBattleField_S(RakNet::RPC3 *rpcFromNetwork)<br /> {<br /> printf("BNPC_S : callBackFromBattleField_S , Func is called from %s /n", rpcFromNetwork->GetLastSenderAddress().ToString());<br /> }<br /> virtual void bulletHit_S(RakNet::RPC3 *rpcFromNetwork)<br /> {<br /> printf("BNPC_S : bulletHit_S , Func is called from %s /n", rpcFromNetwork->GetLastSenderAddress().ToString());<br /> }<br /> };<br /> }<br /> #endif<br />  

RPC3Server.cpp

#include <RPC3/RPC3.h><br /> #include <RakPeerInterface.h><br /> #include <stdio.h><br /> #include <RakSleep.h><br /> #include <NetworkIDManager.h><br /> #include <RakNetworkFactory.h><br /> #include <MessageIdentifiers.h><br /> #include <string><br /> #include <RakString.h><br /> #include <Kbhit.h><br /> #include "BNPC_S.h"<br /> using namespace std;<br /> using namespace RakNet;</p> <p>int main(int argc, char* argv[])<br /> {<br /> printf("begin rpc3 demo/n");</p> <p> RakPeerInterface* rakPeer;<br /> SystemAddress sa = UNASSIGNED_SYSTEM_ADDRESS;<br /> rakPeer = RakNetworkFactory::GetRakPeerInterface();<br /> SocketDescriptor sd(8000,0);<br /> rakPeer->Startup(10,30,&sd,1);<br /> rakPeer->SetMaximumIncomingConnections(5);<br /> RakNet::RPC3 * rpc3Inst = new RakNet::RPC3;<br /> RPC3_REGISTER_FUNCTION(rpc3Inst, &NetSys::CNetBNPC::callBackFromBattleField_S );<br /> RPC3_REGISTER_FUNCTION(rpc3Inst, &NetSys::CNetBNPC::bulletHit_S );<br /> NetworkIDManager networkIDManager;<br /> networkIDManager.SetIsNetworkIDAuthority(true);<br /> rpc3Inst->SetNetworkIDManager(&networkIDManager);<br /> rakPeer->SetNetworkIDManager(&networkIDManager);<br /> rakPeer->AttachPlugin(rpc3Inst);</p> <p> NetSys::BNPC_S * npc_s = new NetSys::BNPC_S();<br /> npc_s->SetNetworkIDManager(&networkIDManager);</p> <p> char ch;<br /> Packet* packet = NULL;<br /> bool bQuit = false;<br /> while (!bQuit)<br /> {<br /> if (_kbhit())<br /> {<br /> ch = getch();<br /> if (ch=='c' || ch=='C')<br /> {<br /> RakNet::BitStream bs;<br /> bs.Write(unsigned char(NET_PACKETID_CREATE_NPC));<br /> bs.Write(npc_s->GetNetworkID());<br /> rakPeer->Send(&bs, HIGH_PRIORITY, RELIABLE_ORDERED, 0, UNASSIGNED_SYSTEM_ADDRESS, true);<br /> }<br /> if (ch=='s' || ch=='S')<br /> {<br /> rpc3Inst->CallCPP("&NetSys::CNetBNPC::sentToBattle_C", npc_s->GetNetworkID(), rpc3Inst);<br /> }<br /> if (ch=='q' || ch=='Q')<br /> {<br /> bQuit = true;<br /> }<br /> }<br /> for (packet = rakPeer->Receive();packet;rakPeer->DeallocatePacket(packet),<br /> packet = rakPeer->Receive())<br /> {<br /> switch (packet->data[0])<br /> {<br /> case ID_DISCONNECTION_NOTIFICATION:<br /> printf("ID_DISCONNECTION_NOTIFICATION/n");<br /> break;<br /> case ID_ALREADY_CONNECTED:<br /> printf("ID_ALREADY_CONNECTED/n");<br /> break;<br /> case ID_CONNECTION_ATTEMPT_FAILED:<br /> printf("Connection attempt failed/n");<br /> break;<br /> case ID_NO_FREE_INCOMING_CONNECTIONS:<br /> printf("ID_NO_FREE_INCOMING_CONNECTIONS/n");<br /> break;<br /> case ID_PONG:<br /> printf("ID_PONG/n");<br /> break;<br /> case ID_CONNECTION_REQUEST_ACCEPTED:<br /> // This tells the client they have connected<br /> printf("ID_CONNECTION_REQUEST_ACCEPTED/n");<br /> break;<br /> case ID_NEW_INCOMING_CONNECTION:<br /> {<br /> printf("ID_NEW_INCOMING_CONNECTION/n");<br /> break;<br /> }<br /> case ID_RPC_REMOTE_ERROR:<br /> {<br /> printf("ID_RPC_REMOTE_ERROR/n");<br /> // Recipient system returned an error<br /> switch (packet->data[1])<br /> {<br /> case RakNet::RPC_ERROR_NETWORK_ID_MANAGER_UNAVAILABLE:<br /> printf("RPC_ERROR_NETWORK_ID_MANAGER_UNAVAILABLE/n");<br /> break;<br /> case RakNet::RPC_ERROR_OBJECT_DOES_NOT_EXIST:<br /> printf("RPC_ERROR_OBJECT_DOES_NOT_EXIST/n");<br /> break;<br /> case RakNet::RPC_ERROR_FUNCTION_INDEX_OUT_OF_RANGE:<br /> printf("RPC_ERROR_FUNCTION_INDEX_OUT_OF_RANGE/n");<br /> break;<br /> case RakNet::RPC_ERROR_FUNCTION_NOT_REGISTERED:<br /> printf("RPC_ERROR_FUNCTION_NOT_REGISTERED/n");<br /> break;<br /> case RakNet::RPC_ERROR_FUNCTION_NO_LONGER_REGISTERED:<br /> printf("RPC_ERROR_FUNCTION_NO_LONGER_REGISTERED/n");<br /> break;<br /> case RakNet::RPC_ERROR_CALLING_CPP_AS_C:<br /> printf("RPC_ERROR_CALLING_CPP_AS_C/n");<br /> break;<br /> case RakNet::RPC_ERROR_CALLING_C_AS_CPP:<br /> printf("RPC_ERROR_CALLING_C_AS_CPP/n");<br /> break;<br /> }<br /> printf("Function: %s", packet->data+2);<br /> }<br /> }<br /> }<br /> RakSleep(30);<br /> }<br /> rakPeer->Shutdown(100,0);<br /> RakNetworkFactory::DestroyRakPeerInterface(rakPeer);<br /> if (npc_s)<br /> {<br /> delete npc_s;<br /> }<br /> if (rpc3Inst)<br /> {<br /> delete rpc3Inst;<br /> }<br /> printf("leave now/n");<br /> RakSleep(1000*2);<br /> return 0;<br /> }<br />  

客户端：

BNPC_C.h

#ifndef ___NET_Common_BNPC_C_H__<br /> #define ___NET_Common_BNPC_C_H__<br /> #include "CNetBNPC.h"</p> <p>namespace NetSys<br /> {<br /> class BNPC_C : public CNetBNPC<br /> {<br /> public:<br /> BNPC_C(void) {}<br /> virtual ~BNPC_C(void){}<br /> // Register in Client, Called by Server<br /> virtual void sentToBattle_C(RakNet::RPC3 *rpcFromNetwork)<br /> {<br /> printf("BNPC_C : sentToBattle_C , Func is called from %s /n", rpcFromNetwork->GetLastSenderAddress().ToString());<br /> }<br /> // Register in Server, Called by Client<br /> virtual void callBackFromBattleField_S(RakNet::RPC3 *rpcFromNetwork)<br /> {<br /> printf("BNPC_C : callBackFromBattleField_S , Func is called from %s /n", rpcFromNetwork->GetLastSenderAddress().ToString());<br /> }<br /> virtual void bulletHit_S(RakNet::RPC3 *rpcFromNetwork)<br /> {<br /> printf("BNPC_C : bulletHit_S , Func is called from %s /n", rpcFromNetwork->GetLastSenderAddress().ToString());<br /> }<br /> };<br /> }<br /> #endif<br />  

RPC3Client.cpp

#include <RPC3/RPC3.h><br /> #include <RakPeerInterface.h><br /> #include <stdio.h><br /> #include <RakSleep.h><br /> #include <NetworkIDManager.h><br /> #include <RakNetworkFactory.h><br /> #include <MessageIdentifiers.h><br /> #include <string><br /> #include <RakString.h><br /> #include <BitStream.h><br /> #include <Kbhit.h><br /> #include "BNPC_C.h"<br /> using namespace std;<br /> using namespace RakNet;</p> <p>int main(int argc, char* argv[])<br /> {<br /> printf("begin rpc3 demo/n");</p> <p> RakPeerInterface* rakPeer;<br /> SystemAddress sa = UNASSIGNED_SYSTEM_ADDRESS;</p> <p> rakPeer = RakNetworkFactory::GetRakPeerInterface();<br /> SocketDescriptor sd(8001,0);<br /> rakPeer->Startup(10,30,&sd,1);<br /> rakPeer->Connect("127.0.0.1",8000,0,0,0);<br /> RakNet::RPC3 * rpc3Inst = new RakNet::RPC3;<br /> RPC3_REGISTER_FUNCTION(rpc3Inst, &NetSys::CNetBNPC::sentToBattle_C );</p> <p> NetworkIDManager networkIDManager;<br /> networkIDManager.SetIsNetworkIDAuthority(false);<br /> rpc3Inst->SetNetworkIDManager(&networkIDManager);<br /> rakPeer->SetNetworkIDManager(&networkIDManager);<br /> rakPeer->AttachPlugin(rpc3Inst);<br /> Packet* packet = NULL;<br /> bool bRet;</p> <p> NetSys::BNPC_C * npc_c = 0;</p> <p> char ch;<br /> bool bQuit = false;<br /> while (!bQuit)<br /> {<br /> if (_kbhit())<br /> {<br /> ch = getch();<br /> if (ch=='d' || ch=='D')<br /> {<br /> rpc3Inst->CallCPP("&NetSys::CNetBNPC::callBackFromBattleField_S", npc_c->GetNetworkID(), rpc3Inst);<br /> }<br /> if (ch=='q' || ch=='Q')<br /> {<br /> bQuit = true;<br /> }<br /> }<br /> for (packet = rakPeer->Receive();packet;rakPeer->DeallocatePacket(packet),<br /> packet = rakPeer->Receive())<br /> {<br /> unsigned char msgID = packet->data[0];<br /> if (msgID == NET_PACKETID_CREATE_NPC)<br /> {<br /> RakNet::BitStream bs(packet->data, packet->length, false);<br /> // Ignore the message ID<br /> bs.IgnoreBits(8);<br /> NetworkID appleNetworkID;<br /> bs.Read(appleNetworkID);<br /> npc_c = new NetSys::BNPC_C();<br /> npc_c->SetNetworkIDManager(&networkIDManager);<br /> npc_c->SetNetworkID(appleNetworkID);<br /> printf("NET_PACKETID_CREATE_NPC，NetSys::BNPC_C has been created!!!!/n");<br /> }<br /> switch (msgID)<br /> {<br /> case ID_DISCONNECTION_NOTIFICATION:<br /> printf("ID_DISCONNECTION_NOTIFICATION/n");<br /> break;<br /> case ID_ALREADY_CONNECTED:<br /> printf("ID_ALREADY_CONNECTED/n");<br /> break;<br /> case ID_CONNECTION_ATTEMPT_FAILED:<br /> printf("Connection attempt failed/n");<br /> break;<br /> case ID_NO_FREE_INCOMING_CONNECTIONS:<br /> printf("ID_NO_FREE_INCOMING_CONNECTIONS/n");<br /> break;<br /> case ID_PONG:<br /> printf("ID_PONG/n");<br /> break;<br /> case ID_CONNECTION_REQUEST_ACCEPTED:<br /> break;<br /> case ID_NEW_INCOMING_CONNECTION:<br /> printf("ID_NEW_INCOMING_CONNECTION/n");<br /> break;<br /> case ID_RPC_REMOTE_ERROR:<br /> {<br /> // Recipient system returned an error<br /> switch (packet->data[1])<br /> {<br /> case RakNet::RPC_ERROR_NETWORK_ID_MANAGER_UNAVAILABLE:<br /> printf("RPC_ERROR_NETWORK_ID_MANAGER_UNAVAILABLE/n");<br /> break;<br /> case RakNet::RPC_ERROR_OBJECT_DOES_NOT_EXIST:<br /> printf("RPC_ERROR_OBJECT_DOES_NOT_EXIST/n");<br /> break;<br /> case RakNet::RPC_ERROR_FUNCTION_INDEX_OUT_OF_RANGE:<br /> printf("RPC_ERROR_FUNCTION_INDEX_OUT_OF_RANGE/n");<br /> break;<br /> case RakNet::RPC_ERROR_FUNCTION_NOT_REGISTERED:<br /> printf("RPC_ERROR_FUNCTION_NOT_REGISTERED/n");<br /> break;<br /> case RakNet::RPC_ERROR_FUNCTION_NO_LONGER_REGISTERED:<br /> printf("RPC_ERROR_FUNCTION_NO_LONGER_REGISTERED/n");<br /> break;<br /> case RakNet::RPC_ERROR_CALLING_CPP_AS_C:<br /> printf("RPC_ERROR_CALLING_CPP_AS_C/n");<br /> break;<br /> case RakNet::RPC_ERROR_CALLING_C_AS_CPP:<br /> printf("RPC_ERROR_CALLING_C_AS_CPP/n");<br /> break;<br /> }<br /> printf("Function: %s", packet->data+2);<br /> }<br /> case ID_USER_PACKET_ENUM:<br /> {<br /> printf("user data: %s/n",packet->data + 1);<br /> break;<br /> }<br /> printf("case type = %d/n",packet->data[0]);<br /> }<br /> }<br /> RakSleep(30);<br /> //printf("client loop/n");<br /> }<br /> rakPeer->Shutdown(100,0);<br /> RakNetworkFactory::DestroyRakPeerInterface(rakPeer);<br /> if (npc_c)<br /> {<br /> delete npc_c;<br /> }<br /> if (rpc3Inst)<br /> {<br /> delete rpc3Inst;<br /> }<br /> printf("leave now/n");<br /> RakSleep(1000*2);<br /> return 0;<br /> }<br />