K8S下SpringCloud应用无损下线-Toy模板网

这篇具有很好参考价值的文章主要介绍了K8S下SpringCloud应用无损下线。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

废话不多说直接上代码，一种2个步骤

步骤一：添加以下代码到SpringCloud应用中



import cn.hutool.extra.spring.SpringUtil;
import com.alibaba.cloud.nacos.registry.NacosAutoServiceRegistration;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletRequest;
import java.net.InetAddress;
import java.net.UnknownHostException;

/**
 * 使用了nacos注册中心的服务关闭端点配置
 */
@ConditionalOnClass(NacosAutoServiceRegistration.class)
@RestController
@RequestMapping("actuator")
@RequiredArgsConstructor
@Slf4j
public class NacosStopEndpoint {
    private final NacosAutoServiceRegistration nacosAutoServiceRegistration;
    /**
     * 注销服务后关闭应用前等待的时间(毫秒)
     */
    private int waitTime = 30000;


    /**
     * 关闭服务 <br>
     * 只接收localhost发起的请求
     *
     * @param request
     * @return
     */
    @PostMapping("stopService")
    public ResponseEntity<Boolean> stopNacosService(
            HttpServletRequest request) throws UnknownHostException {
        if (!request.getRemoteHost().equalsIgnoreCase("127.0.0.1")) {
            log.warn("非法访问 尝试关闭应用 远程地址[{}]", request.getRemoteHost());
            return ResponseEntity.status(HttpStatus.UNAUTHORIZED).body(false);//非本机访问直接return 防止外部攻击
        }
        new Thread(() -> {
            log.info("Nacos instance has been de-registered");
            nacosAutoServiceRegistration.stop();

            log.info("Waiting {} milliseconds...", waitTime);
            try {
                Thread.sleep(waitTime);
            } catch (InterruptedException e) {
                log.info(Thread.currentThread().getName() + " interrupted!", e);
            }
            log.info("Spring close……");
            ((ConfigurableApplicationContext) SpringUtil.getApplicationContext()).close();
            log.info("Spring closed……");
            System.exit(0);
        }, "Application Closed Thread").start();


        return ResponseEntity.ok(true);
    }
}

步骤二：

配置K8S的工作负载的preStop函数，如下

["curl","-X","POST","http://127.0.0.1:8080/actuator/stopService","&&","sleep","30"]

大功告成！从此以后应用下线再也不会丢流量了！文章来源地址https://www.toymoban.com/news/detail-642177.html

到了这里，关于K8S下SpringCloud应用无损下线的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！

K8S下SpringCloud应用无损下线

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

微信扫一扫打赏

支付宝扫一扫领取红包，优惠每天领

二维码1

二维码2