带你读《2022技术人的百宝黑皮书》——一个搞定责任链的注解（8）

@Slf4j
public class DuplicateThrottlerHandler implements MessageThrottlerHandler { 3
@Override
public boolean throttle(MessageThrottlerToken messageThrottlerToken, MessageThrottlerHandler- Context context) {
if (messageThrottlerToken.isThrottled()) { return false;
}
boolean throttleResult = context.throttle(messageThrottlerToken); messageThrottlerToken.markThrottled();
return throttleResult;
}
@Override
public boolean anyThrottle(List<MessageThrottlerToken> messageThrottlerTokens, MessageThrot- tlerHandlerContext context) {
if (CollectionUtils.isEmpty(messageThrottlerTokens)) { return false;
}
// 过滤掉已经被限流的消息
List<MessageThrottlerToken> needMessageThrottlerTokens = messageThrottlerTokens.stream()
.filter(messageThrottlerToken -> !messageThrottlerToken.isThrottled()).collect(Collectors.toList
());
if (CollectionUtils.isEmpty(needMessageThrottlerTokens)) {
return false;
  }
boolean throttleResult = context.anyThrottle(needMessageThrottlerTokens); needMessageThrottlerTokens.forEach(messageThrottlerToken -> messageThrottlerToken.mark-
Throttled());
return throttleResult;
}
@Override
public boolean allThrottle(List<MessageThrottlerToken> messageThrottlerTokens, MessageThrot-
tlerHandlerContext context) {
if (CollectionUtils.isEmpty(messageThrottlerTokens)) {

if (CollectionUtils.isEmpty(needMessageThrottlerTokens)) { return false;
}
boolean throttleResult = context.allThrottle(needMessageThrottlerTokens);
needMessageThrottlerTokens.forEach(messageThrottlerToken -> messageThrottlerToken.mark-
Throttled());
return throttleResult;
  }
  }