package com.kidgrow.ribbon.filter; import cn.hutool.core.util.StrUtil; import com.kidgrow.common.constant.CommonConstant; import com.kidgrow.common.constant.ConfigConstants; import com.kidgrow.common.context.LbIsolationContextHolder; import org.springframework.beans.factory.annotation.Value; import org.springframework.boot.autoconfigure.condition.ConditionalOnClass; import org.springframework.web.filter.OncePerRequestFilter; import javax.servlet.Filter; import javax.servlet.FilterChain; import javax.servlet.ServletException; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.IOException; /** * 石家庄喜高科技有限责任公司 版权所有 © Copyright 2020
* * @Description: 负载均衡隔离规则过滤器 * @Project:
* @CreateDate: Created in 2020/2/21 13:31
* @Author: liuke */ @ConditionalOnClass(Filter.class) public class LbIsolationFilter extends OncePerRequestFilter { @Value("${" + ConfigConstants.CONFIG_RIBBON_ISOLATION_ENABLED + ":false}") private boolean enableIsolation; @Override protected boolean shouldNotFilter(HttpServletRequest request) { return !enableIsolation; } @Override protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) throws IOException, ServletException { try { String version = request.getHeader(CommonConstant.KIDGROW_VERSION); if(StrUtil.isNotEmpty(version)){ LbIsolationContextHolder.setVersion(version); } filterChain.doFilter(request, response); } finally { LbIsolationContextHolder.clear(); } } }