Class AbstractPush

src/main/java/top/misec/push/AbstractPush.java:31–178

推送抽象类；公共模板方法封装. @author itning @since 2021/3/22 16:36

 * @since 2021/3/22 16:36
 */
@Slf4j
public abstract class AbstractPush implements Push, RetryListener {

    private final Retryer<JsonObject> retryer;
    protected final RequestConfig requestConfig;

    public AbstractPush() {

        HttpHost proxy = ConfigLoader.helperConfig.getPushConfig().getProxy();
        RequestConfig.Builder builder = RequestConfig.custom()
                .setConnectTimeout(5000)
                .setConnectionRequestTimeout(5000)
                .setSocketTimeout(10000);
        if (null != proxy) {
            builder.setProxy(proxy);
        }
        requestConfig = builder.build();

        retryer = RetryerBuilder.<JsonObject>newBuilder()
                // 出现异常进行重试
                .retryIfException()
                // 检查结果进行重试
                .retryIfResult((it) -> !checkPushStatus(it))
                // 每次重试等待策略
                .withWaitStrategy(WaitStrategies.fixedWait(1, TimeUnit.SECONDS))
                // 重试停止策略
                .withStopStrategy(StopStrategies.stopAfterAttempt(3))
                // 持续时间限制
                .withAttemptTimeLimiter(AttemptTimeLimiters.noTimeLimit())
                // 重试监听器
                .withRetryListener(this)
                .build();
    }

    @Override
    public final PushResult doPush(PushMetaInfo metaInfo, String content) {
        String url = generatePushUrl(metaInfo);
        assert null != url : "推送URL不能为空";
        List<String> pushList = segmentation(metaInfo, content);
        PushResult pushResult = PushResult.success();
        for (String pushItemContent : pushList) {
            String pushContent = generatePushBody(metaInfo, pushItemContent);
            PushResult result = push2Target(url, pushContent);
            if (!result.isSuccess()) {
                pushResult = PushResult.failed();
                break;
            }
            if (pushList.size() > 1) {
                try {
                    // 限速
                    TimeUnit.MILLISECONDS.sleep(1500);
                } catch (InterruptedException ignore) {
                }
            }
        }
        return pushResult;
    }