微信后台 ------ 多线程-------消息重复检查器

傷城~ 2022-02-22 04:10 150阅读 0赞

微信排重接口

1.接口定义
     
    消息重复检查器
     微信服务器在五秒内收不到响应会断掉连接，并且重新发起请求，总共重试三次
    
    public interface WxMessageDuplicateChecker {
      /**
       * 判断消息是否重复
       *
       * <p>普通消息：关于重试的消息排重，推荐使用msgid排重。
       * <p>事件消息：关于重试的消息排重，推荐使用FromUserName + CreateTime 排重。
       *
       */
      boolean isDuplicate(String messageId);
    
    }

2.实现

关键：注意多线程下只启动一次的设置方法。

启动守护线程，无限遍历

|**消息id->时间戳的**|  如果 当前时间戳-存入时间戳>存活时间，删除该消息Id

//一个消息ID在内存的过期时间：15秒.  15 * 1000L
      private final Long timeToLive;
    
      // 每隔多少周期检查消息ID是否过期：5秒.  5 * 1000L
      private final Long clearPeriod;
    
      // 消息id->消息时间戳的map.
      private final ConcurrentHashMap<String, Long> msgId2Timestamp = new ConcurrentHashMap<>();
    
      //后台清理线程是否已经开启.
      private final AtomicBoolean backgroundProcessStarted = new AtomicBoolean(false);

protected void checkBackgroundProcessStarted() {
        //初始化设置为false
        //本方法设置为true，并返回之前值
        //在第一次执行时会启动线程。只有此处会进行设置，如果设置时（因并发）发现为true,进入return。保证之初始化一次，启动一个守护线程。
        if (this.backgroundProcessStarted.getAndSet(true)) {
          return;
        }
        Thread t = new Thread(new Runnable() {
          @Override
          public void run() {
            try {
              while (true) {
                Thread.sleep(WxMessageInMemoryDuplicateChecker.this.clearPeriod);
                Long now = System.currentTimeMillis();
                for (Map.Entry<String, Long> entry :
                    WxMessageInMemoryDuplicateChecker.this.msgId2Timestamp.entrySet()) {
                  if (now - entry.getValue() > WxMessageInMemoryDuplicateChecker.this.timeToLive) {
                    WxMessageInMemoryDuplicateChecker.this.msgId2Timestamp.entrySet().remove(entry);
                  }
                }
              }
            } catch (InterruptedException e) {
              Thread.currentThread().interrupt();
            }
          }
        });
        t.setDaemon(true);
        t.start();
      }

@Override
      public boolean isDuplicate(String messageId) {
        if (messageId == null) {
          return false;
        }
        checkBackgroundProcessStarted();
        Long timestamp = this.msgId2Timestamp.putIfAbsent(messageId, System.currentTimeMillis());
        return timestamp != null;
      }