增加限流

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/mq/processor/AddMemberUnionRelateConsumerProcessor.java

@@ -20,8 +20,12 @@ import com.gic.haoban.manage.service.service.*;
 import com.gic.haoban.manage.service.util.EmojiFilterUtil;
 import com.gic.member.api.dto.MemberDTO;
 import com.gic.member.api.service.MemberService;
+import com.gic.redis.data.util.RedisUtil;
 import com.gic.wechat.api.service.qywx.QywxUserApiService;
 import org.apache.commons.lang3.StringUtils;
+import org.redisson.api.RRateLimiter;
+import org.redisson.api.RateIntervalUnit;
+import org.redisson.api.RateType;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -69,6 +73,9 @@ public class AddMemberUnionRelateConsumerProcessor extends AbstractConsumerProce
 
     @Override
     void doProcess(MemberUnionRelatedBO bo) {
+        RRateLimiter rateLimiter = RedisUtil.getRedisClient().getRateLimiter("add:mbr:rel:list:limit");
+        rateLimiter.trySetRate(RateType.OVERALL, 5, 1, RateIntervalUnit.SECONDS);
+        rateLimiter.acquire();
         String staffId = bo.getStaffId();
         String wxEnterpriseId = bo.getWxEnterpriseId();
         String externalUserid = bo.getExternalUserid();