springboot 容器加载后自动监听 获取access_token

package com.hmzj.callcenterim.thread;

import com.hmzj.callcenterim.dto.AccessToken;
import com.hmzj.callcenterim.enums.WeixinEnum;
import com.hmzj.callcenterim.utils.WeixinUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;

/**
 * 定时获取和更新access_token
 * 
 * @author Yangqi.Pang
 * @version V0.0.1
 */
@Service
@Slf4j
@RefreshScope
public class TokenThread implements Runnable{

    private RedisTemplate<String, String> redisTemplate;


    @Autowired
    public TokenThread(RedisTemplate<String, String> redisTemplate) {
        this.redisTemplate = redisTemplate;
    }

    @Override
    public void run() {
        while (true) {
            try {
                AccessToken accessToken = WeixinUtil.getAccessToken(WeixinEnum.APP_ID.getValue(), WeixinEnum.APP_SECRET.getValue());
                if (accessToken != null) {
                    if (accessToken.getToken() != null) {
                        redisTemplate.opsForValue().set("accessToken", accessToken.getToken());
                        log.info("获取的accessToken为"+accessToken.getToken());
                    }
                }
                if (null != accessToken.getToken()) {
                    // 休眠7000秒
                    Thread.sleep((accessToken.getExpiresIn() - 3000) * 1000);
                } else {
                    // 如果access_token为null，60秒后再获取
                    Thread.sleep(3600 * 1000);
                }
            } catch (InterruptedException e) {
                try {
                    Thread.sleep(60 * 1000);
                } catch (InterruptedException e1) {
                    log.error("{}", e1);
                }
                log.error("{}", e);
            }

        }

    }
}

package com.hmzj.callcenterim;

import com.hmzj.callcenterim.thread.TokenThread;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;
/**
 * spring boot 容器加载后自动监听
 * 执行 tokenThread 线程
 *
 * @author Yangqi.pang
 * @version V0.0.1
 */

@Component
public class MyThreadRunner implements CommandLineRunner {

    @Autowired
    private TokenThread tokenThread;

    @Override
    public void run(String... args) {
        new Thread(tokenThread).start();
    }
}