顺序消息消费第一次比较慢

[mobaijaavaer]

我使用4.5.2客户端版本，测试顺序消费场景,连接的server段是阿里云rocketmq商业版，我的程序代码如下：
`java
SimpleDateFormat simpleDateFormat=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

    String cloudPrefix = "MQ_INST_125036_BXbcy8xH%";
    String group = cloudPrefix + "GID-pt-gaoding-message-test-dev";
    RPCHook aclRPCHook = new AclClientRPCHook(new SessionCredentials("",""));
    DefaultMQPushConsumer mqClient = new DefaultMQPushConsumer(group,
            aclRPCHook,
            new AllocateMessageQueueAveragely(), true, null);
    mqClient.setAccessChannel(AccessChannel.CLOUD);
    mqClient.setInstanceName("");
    mqClient.setNamesrvAddr("");
    mqClient.setUnitName("");
    mqClient.subscribe("", "*");
    mqClient.setConsumeTimeout(10000);
    mqClient.registerMessageListener(new MessageListenerOrderly() {
        @Override
        public ConsumeOrderlyStatus consumeMessage(List<MessageExt> msgs, ConsumeOrderlyContext context) {
            MessageExt messageExt = msgs.get(0);
            String time = new String(messageExt.getBody(), StandardCharsets.UTF_8);
            long now = System.currentTimeMillis();
            long duration = now - (Long.parseLong(time));
            System.out.println("消息id:"+messageExt.getMsgId()+",发送时间:"+simpleDateFormat.format(new Date(Long.parseLong(time)))+
                    ",存储时间:"+simpleDateFormat.format(new Date(messageExt.getStoreTimestamp()))+",客户端消费时间:"+simpleDateFormat.format(new Date(now))+",延时:"+duration);
            return ConsumeOrderlyStatus.SUCCESS;
        }
    });
    mqClient.start();
    //生产者
    DefaultMQProducer mqProducer = new DefaultMQProducer("gaoding-message-producer",
            new AclClientRPCHook(new SessionCredentials("","")),
            true, null);
    mqProducer.setAccessChannel(AccessChannel.CLOUD);
    mqProducer.setInstanceName("");
    mqProducer.setNamesrvAddr("");
    mqProducer.setUnitName("");
    mqProducer.start();
    //连续发送3条顺序消息
    for (int i = 0; i < 3; i++) {
        Message test = new Message("MQ_INST_125036_BXbcy8xH%pt-gaoding-message-test-order-dev",
                "*",
                "test",
                (System.currentTimeMillis() + "").getBytes(StandardCharsets.UTF_8));
        test.putUserProperty("__SHARDINGKEY", "test");
        mqProducer.send(test, new MessageQueueSelector() {
            @Override
            public MessageQueue select(List<MessageQueue> mqs, Message msg, Object arg) {
                int select = Math.abs(arg.hashCode());
                if (select < 0) {
                    select = 0;
                }
                return mqs.get(select % mqs.size());
            }
        }, "test");
    }

    Thread.sleep(10000L);

`

发现程序启动之后，消息很快发送出去了，但是每次需要过几十秒才能在客户端收到消息。目前定位到的原因主要可能是
顺序消费需要对队列上锁，没有上锁的队列会放弃消息拉取，处理队列上锁的类是ConsumeMessageOrderlyService,默认20s执行一次，而客户端负载均衡也是20s， 通过在RebalanceImpl#lockAll 方法中打日志，发现首次启动后客户端没有任何队列，以下是控制台截图：

请教一下社区，有人遇到过此类问题吗？