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]);

        }

  //  }

   

}