cocos2dx 3.x 網絡循環接收數據(RakNet::Packet* packet)單步網絡接收

 

void FriendFightLayer::update(float dt)

{

    dealWithPacket(dt);

    if (m_isNeedSwitchToLobby) {

        PublicMethod::changeToLobby();

    }

}

void FriendFightLayer::dealWithPacket(float dt)

{

    RakNet::Packet* packet = g_net.getNewPacket();

    if (packet == NULL) {

        return;//return之后下面的代碼就不執行了，所以除了協議以外的東西，就不能寫在里面了。

    }

//  為什么說是單步呢？看看for循環的條件就知道了，因為有數據進來就進for就會一直取到NULL才會停止

//    for( RakNet::Packet* packet = g_net.getNewPacket(); packet != NULL; packet = g_net.getNewPacket())

//    {

 

        if( packet->data[0] == ID_REMOTE_DISCONNECTION_NOTIFICATION)

        {

            CCLOG("遠端連接丟失");

            m_isNeedSwitchToLobby = true;

            g_net.releasePacket(packet);

        }

        else if( packet->data[0] == ID_REMOTE_CONNECTION_LOST)

        {

            CCLOG("遠端連接丟失");

            m_isNeedSwitchToLobby = true;

            g_net.releasePacket(packet);

        }

        else if( packet->data[0] == ID_REMOTE_NEW_INCOMING_CONNECTION)

        {

            CCLOG("新連接進入");

            g_net.releasePacket(packet);

        }

        else if( packet->data[0] == ID_NEW_INCOMING_CONNECTION)

        {

            CCLOG("新連接進入");

            g_net.releasePacket(packet);

        }

        else if( packet->data[0] == ID_NO_FREE_INCOMING_CONNECTIONS)

        {

            CCLOG("服務器已滿");

            m_isNeedSwitchToLobby = true;

            g_net.releasePacket(packet);

        }

        else if( packet->data[0] == ID_DISCONNECTION_NOTIFICATION)

        {

            CCLOG("掉線");

            m_isNeedSwitchToLobby = true;

            g_net.releasePacket(packet);

        }

        else if( packet->data[0] == ID_CONNECTION_LOST)

        {

            CCLOG("連接丟失");

            m_isNeedSwitchToLobby = true;

            g_net.releasePacket(packet);

        }

        else if (packet->data[0] == ID_CONNECTION_ATTEMPT_FAILED)

        {

            CCLOG("嘗試連接失敗");

            PlatformHelper::showHint("無法連接服務器");

            MahJong_Foure_Main::s_returnToLobby = true;

            m_isNeedSwitchToLobby = true;

            g_net.releasePacket(packet);

        }

        else if( packet->data[0] == ID_CONNECTION_REQUEST_ACCEPTED)

        {

            g_net.m_mahJongFourServerAddress = packet->systemAddress;

            CCLOG("連接游戲服務器成功");

            g_net.releasePacket(packet);

            

//            RakNet::BitStream configRequest;

//            configRequest.Write((RakNet::MessageID)ID_GET_CONFIG);

//            g_net.getPeer()->Send(&configRequest, MEDIUM_PRIORITY, RELIABLE, 0, g_net.getServerAddress(), false);

            

            RakNet::BitStream loginRequest;

            loginRequest.Write((RakNet::MessageID)ID_LOGIN_FROM_CLIENT);//從客戶端發送登陸信息

            loginRequest.Write(DataManager::getInstance()->m_myData.m_id);

            loginRequest.Write(m_sessionID);

            loginRequest.Write(m_gameTimes);

            loginRequest.Write(ConfigData::getInstance()->nProxy);

            g_net.getPeer()->Send(&loginRequest, MEDIUM_PRIORITY, RELIABLE, 0, g_net.getServerAddress(), false);

        }

        else if (packet->data[0] == ID_GET_CONFIG)

        {

            dealWithGetConfig(packet);

        }

#pragma mark - 123

//        else if(packet->data[0] == ID_PLAYER_LOGIN)

//        {

////            LandLordsScene* loadingLayer = LandLordsScene::create();

//            CCLOG("ID_PLAYER_LOGIN123456");

//        }

        else if (packet->data[0] == ID_TABLE_LOGIN)

        {

            CCLOG("有玩家進入房間);

        }

       

        else if (packet->data[0] == ID_LOGIN_TO_GAME)

        {

            dealWithLoginToGame(packet);

        }

        else if(packet->data[0] == ID_LOGIN_FROM_CLIENT)

        {

            CCLOG("登錄游戲服務器成功");

            dealWithLoginFromClient(packet);

        }

//        else if(packet->data[0] == ID_VIP_SCORE)

//        {

    

        else if(packet->data[0] == ID_VIP_SCORE)

        {

            RakNet::BitStream vipScoreResult( packet->data, packet->length, false);

            vipScoreResult.IgnoreBytes( sizeof(RakNet::MessageID));

            RakNet::MessageID realPacketID;

            vipScoreResult.Read(realPacketID);

            switch (realPacketID) {

                case SVIP_ID_PULLRECORDLIST:

                    dealWithRecordList(vipScoreResult);

                    break;

                case SVIP_ID_CREATETABLE:

                    dealWithCreateTable(vipScoreResult);

                    break;

                case SVIP_ID_JOINTABLE:

                    dealWithJoinTable(vipScoreResult);

//                    if(m_selectedName == "landlords")

//                    {

//                        return;

//                    }

//                    else

//                    {

                        break;

//                    }

                case SVIP_ID_EXCHANGE:

                    CCLOG("SVIP_ID_EXCHANGE:%d",SVIP_ID_EXCHANGE);

                    dealWithExchange(vipScoreResult);

                    break;

                case SVIP_ID_PULLRECORD:

                    dealWithRecord(vipScoreResult);

                    break;

                    

//                case SVIP_ID_DISMISSTABLE_RESULT://解散桌子

//                     CCLOG("解散桌子SVIP_ID_DISMISSTABLE_RESULT");

//                    break;

                    

                default:

                    break;

            }

            g_net.releasePacket(packet);

        }

        else

        {

            CCLOG("未知數據報:%d",packet->data[0]);

        }

  //  }

   

}