mqtt 丢失消息问题

Question

请问大家有没有这个遇到过这种问题，mqtt一个客户端每间隔5分钟会向1075个主题各发送一条消息，发送消息是0秒的时候一起发送，都是在1秒内完成1075条消息的发送，我这边通过通配符订阅了1075个发布主题去接收消息，但每次只能收到1050个左右的消息，好像是丢了一些消息，首先主题是没有配错，因为发现过一些主题有时能收到消息，有时收不到消息，而发送的客户端是发送过的，emqx消息流入统计也是能对的上发送客户端发送的消息数量，请问是怎么回事呢？
#客户端发送数量:

emqx 消息流入看板：

我的代码

    @Override
    public void messageArrived(String topic, MqttMessage message) {
       
        try {
            if (topic.indexOf("dev/monitor/") != -1){
                // 主动上报
                TalIotMonitorHis monitorHis = new TalIotMonitorHis();
                monitorHis.setIotTopic(topic);
                monitorHis.setIotMsg(message.toString());
               TalIotGateway iotGateway = topicHand(topic);
               if (iotGateway!=null){
                   monitorHis.setGatewayId(iotGateway.getGatewayId());
               }
                monitorHisService.insertTalIotMonitorHis(monitorHis);
                if (iotGateway!=null && iotGateway.getProtocolType()!=null && iotGateway.getProtocolType().equals("0")){
                    analysisToolKit.talentKJsonDataHandler(iotGateway, com.alibaba.fastjson2.JSONObject.parseObject(message.toString()));
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

入库数量：

Answer 1

1有可能是数据库写入速度跟不上，可以搞一个缓存，先接收后存储。
2有可能是粘包了，两个数据被系统认为是一个。
没有用过mqtt,仅供参考。