Producers (send syncask requests) and consumers (with xxxask monitoring and Implementation)

home clothing

application.xml

 <net:config id="tankHome" protocol-location="protocol.xml" generate-cs-protocol="${net.generate.cs.protocol}"
                fold-protocol="${net.fold.protocol}">

        <net:registry center="${registry.center}" user="${registry.user}" password="${registry.password}">
            <net:address name="${registry.address.name}" url="${registry.address.url}"/>
        </net:registry>

        <net:provider task-dispatch="consistent-hash">
            <net:module name="tankHome"/>
        </net:provider>

        <net:consumer load-balancer="consistent-hash">
            <net:module name="tankCache"/>
        </net:consumer>

    </net:config>

home The server makes a request

        //  Send asynchronously to cache clothing 
        NetContext.getConsumer().asyncAsk(BattleScoreAsk.valueOf(uid, score), BattleScoreAnswer.class, uid)
                .whenComplete(answer -> {
                    logger.info("c[{}][{}] Asynchronous callback of player battle results ", gatewayAttachment.getUid(), gatewayAttachment.getSid());

                    //  After the battle, if you get on the leaderboard , Then reward , Each point is worth one gold coin , Half a diamond 
                    if (answer.isRankReward()) {
                        var currencyPo = player.getCurrencyPo();
                        currencyPo.setGold(currencyPo.getGold() + score);
                        currencyPo.setGem(currencyPo.getGem() + score / 2);
                        addPlayerExp(player, score);

                        playerEntityCaches.update(player);

                        NetContext.getRouter().send(session, BattleResultResponse.valueOf(score), gatewayAttachment);
                        NetContext.getRouter().send(session, CurrencyUpdateNotice.valueOf(currencyPo.toCurrencyVO()), gatewayAttachment);
                    }
                });

cache clothing

    @PacketReceiver
    public void atBattleScoreAsk(Session session, BattleScoreAsk ask) {
        var playerId = ask.getPlayerId();
        var score = ask.getScore();

        //  If not on the list , Go straight back to ; On the list , Insert the current score into the database 
        if (score <= minScore && rankLimit >= RANK_SIZE) {
            NetContext.getRouter().send(session, BattleScoreAnswer.valueOf(false));
            return;
        }

        //  Get a distributed auto increment unique id
        var id = MongoIdUtils.getIncrementIdFromMongoDefault(ScoreRankEntity.class);
        //  Insert database 
        OrmContext.getAccessor().insert(ScoreRankEntity.valueOf(id, playerId, TimeUtils.now(), score));
        NetContext.getRouter().send(session, BattleScoreAnswer.valueOf(true));
    }