zuul升级为gateway

说明： 我们首先知道的是，我们使用了JWT认证，所以将以前的session认证全部取消掉，改为jwt企业级认证。

我们一个个模块来看，首先看用户模块：

排除依赖

去除注解

去除配置文件

上面的操作是其它模块也要做的，跟着此模块操作即可。

查找相关session代码

接下来修改session有关代码，升级为jwt.

首先是Controller层

说明：

相关线程池的使用参考SpringCloud之线程池和Threadlocal在项目中的应用

配置过滤器与实现

先查看下两者之间关系：

package com.imooc.cloud.mall.practice.user.filter;
 
import org.springframework.boot.web.servlet.FilterRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
/**
 * 描述：     User过滤器的配置
 */
@Configuration
public class UserFilterConfig {
 
    @Bean
    public UserInfoFilter userInfoInterceptor() {
        return new UserInfoFilter();
    }
 
    @Bean(name = "userFilterConf")
    public FilterRegistrationBean userFilterConfig() {
        FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean();
        filterRegistrationBean.setFilter(userInfoInterceptor());
        filterRegistrationBean.addUrlPatterns("/cart/*");
        filterRegistrationBean.addUrlPatterns("/order/*");
        filterRegistrationBean.addUrlPatterns("/user/update");
        filterRegistrationBean.setName("userFilterConf");
        return filterRegistrationBean;
    }
}

先查看：

SpringBoot系列教程web篇之过滤器Filter使用指南 - 腾讯云开发者社区-腾讯云

接下来实现过滤器:

package com.imooc.cloud.mall.practice.user.filter;
 
import com.imooc.cloud.mall.practice.common.common.Constant;
import com.imooc.cloud.mall.practice.user.model.pojo.User;
import java.io.IOException;
import java.util.Enumeration;
import javax.servlet.Filter;
import javax.servlet.FilterChain;
import javax.servlet.FilterConfig;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
import javax.servlet.http.HttpServletRequest;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.context.request.RequestAttributes;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
 
/**
 * 把Header里的用户信息，放到本地的ThreadLocal里
 */
@Configuration
@EnableFeignClients
public class UserInfoFilter implements Filter {
 
    public static ThreadLocal<User> userThreadLocal = new ThreadLocal();
    public User currentUser = new User();
 
 
    @Override
    public void init(FilterConfig filterConfig) throws ServletException {
 
    }
 
    @Override
    public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
        //通过RequestContextHolder获取本地请求
        RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes();
        if (requestAttributes == null) {
            return;
        }
        //获取本地线程绑定的请求对象
        HttpServletRequest request = ((ServletRequestAttributes) requestAttributes).getRequest();
        //给请求模板附加本地线程头部信息，把User信息放到ThreadLocal里
        Enumeration<String> headerNames = request.getHeaderNames();
        if (headerNames != null) {
            while (headerNames.hasMoreElements()) {
                String name = headerNames.nextElement();
                Enumeration<String> values = request.getHeaders(name);
                while (values.hasMoreElements()) {
                    String value = values.nextElement();
                    if (name.equals(Constant.USER_ID)) {
                        currentUser.setId(Integer.valueOf(value));
                    }
                    if (name.equals(Constant.USER_NAME)) {
                        currentUser.setUsername(value);
                    }
                    if (name.equals(Constant.USER_ROLE)) {
                        currentUser.setRole(Integer.valueOf(value));
                    }
                    //必须保证User的3个字段都完整，否则意味着网关传递信息时出错了
                    if (currentUser.getId() != null && currentUser.getUsername() != null && currentUser.getRole() != null) {
                        userThreadLocal.set(currentUser);
                    }
                }
            }
        }
        filterChain.doFilter(servletRequest, servletResponse);
    }
 
    @Override
    public void destroy() {
 
    }
}