黑马十次方项目day07-08之交友微服务准备工作

忘是亡心i 2022-03-19 14:43 283阅读 0赞

### 文章目录 ###

*   *   *  一. 创建模块
         *  二. 添加依赖
         *  三.编写yml配置文件
         *  四.创建启动类
         *  五. 配置Jwt的拦截器

### 一. 创建模块 ###

在tensequare\_parent工程中,创建子模块tensquare\_friend

### 二. 添加依赖 ###

在tensquare\_friend 中,添加依赖.内容如下

<dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-jpa</artifactId>
            </dependency>
            <dependency>
                <groupId>com.tensquare</groupId>
                <artifactId>tensquare_common</artifactId>
                <version>1.0-SNAPSHOT</version>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-openfeign</artifactId>
            </dependency>
        </dependencies>

### 三.编写yml配置文件 ###

在resources包下,创建application.yml配置文件,内容如下

server: 
      port: 9010
    spring: 
      application:  
        name: tensquare-friend #指定服务名
      datasource:  
        driverClassName: com.mysql.jdbc.Driver
        url: jdbc:mysql://16:3306/tensquare_friend?characterEncoding=UTF8
        username: root
        password: 
      jpa: 
        database: MySQL
        show-sql: true
    jwt:
      config:
        key: itcast    # 设置token的盐为 itcast
    eureka:
      client:
        service-url:
          defaultZone: http://127.0.0.1:6868/eureka/  #此处为eureka的服务端地址
      instance:
        prefer-ip-address: true # 此处配置项的含义是,部署线上时,模块之间可以跨域访问

### 四.创建启动类 ###

在com.tensquare.friend包下,创建启动类  
内容如下.  
注意加上如下的四个注解

@SpringBootApplication
    @EnableEurekaClient
    @EnableFeignClients
    @EnableDiscoveryClient

分别代表是SpringBoot的启动类,注册Eureka的客户端,使用Feign去发现服务,开启服务的发现.

package com.tensquare.friend;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    import org.springframework.cloud.openfeign.EnableFeignClients;
    import org.springframework.context.annotation.Bean;
    import util.JwtUtil;
    
    /** * 类名称:FriendApplication * 类描述:启动类 * * @author: taohongchao * 创建时间:2019/2/17 14:41 * Version 1.0 */
    @SpringBootApplication
    @EnableEurekaClient
    @EnableFeignClients
    @EnableDiscoveryClient
    public class FriendApplication { 
    
        public static void main(String[] args){ 
            SpringApplication.run(FriendApplication.class);
        }
    
        /** * 把jwt对象注入容器中 * @return */
        @Bean
        public JwtUtil jwtUtil(){ 
            return new JwtUtil();
        }
    }

### 五. 配置Jwt的拦截器 ###

复制JwtInterceptor 和InterceptorConfig 到项目中,内容如下

package com.tensquare.friend.interceptor;
    
    import io.jsonwebtoken.Claims;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    import org.springframework.web.servlet.HandlerInterceptor;
    import util.JwtUtil;
    
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    
    /** * 类名称:JwtInterceptor * 类描述:jwt的全局拦截器 * * @author: taohongchao * 创建时间:2019/2/16 13:56 * Version 1.0 */
    @Component
    public class JwtInterceptor implements HandlerInterceptor { 
    
        @Autowired
        private JwtUtil jwtUtil;
    
        @Override
        public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception { 
            System.out.println("经过了拦截器");
            String header = request.getHeader("Authorization");
    
            if (header != null && !"".equals(header)) { 
                //header信息不为空, 那么就进行解析的操作
                if (header.startsWith("Bearer ")) { 
                   //得到token
                    String token = header.substring(7);
    
                    //对令牌进行验证
                    //解析token的过程可能会抛出异常,因此使用try catch
                    try { 
                        //解析token
                        Claims claims = jwtUtil.parseJWT(token);
    
                        //获取角色信息
                        String roles = (String) claims.get("roles");
    
                        //判断角色是否为空,或者是不是admin角色
                        if (roles != null &&  "admin".equals(roles)) { 
                            //如果角色不为空,并且是admin角色. 那么把token的信息,放入request域中,键为claims_admin, 值为token
                            request.setAttribute("claims_admin",token);
                        }
    
                        if (roles != null &&   "user".equals(roles)) { 
                            //如果角色不为空,并且是user角色. 那么把token的信息,放入request域中,键为claims_user, 值为token
                            request.setAttribute("claims_user",token);
                        }
    
                    } catch (RuntimeException e) { 
                        //解析token的过程抛出异常, 也代表权限不足
                        //异常可能的原因是token过期等等
                        throw new RuntimeException("令牌不正确!");
                    }
                }
            }
            //return true代表放行, return false 代表不放行
            //任何情况下都要放行, 最终具体的操作,要看其业务
            //拦截器只负责把请求头中包含token信息进行解析
            return true;
        }
    }

package com.tensquare.friend.config;
    
    import com.tensquare.friend.interceptor.JwtInterceptor;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
    import org.springframework.web.servlet.config.annotation.WebMvcConfigurationSupport;
    
    /** * 类名称:InterceptorConfig * 类描述: 拦截器的配置类 * * @author: taohongchao * 创建时间:2019/2/16 14:00 * Version 1.0 */
    @Configuration
    public class InterceptorConfig extends WebMvcConfigurationSupport { 
    
        @Autowired
        private JwtInterceptor jwtInterceptor;
    
        /** * 方法名: addInterceptors * 方法描述: 添加拦截器的规则 * 修改日期: 2019/2/16 14:02 * @param registry * @return void * @author taohongchao * @throws */
        @Override
        protected void addInterceptors(InterceptorRegistry registry) { 
            //添加jwt的拦截器
            registry.addInterceptor(jwtInterceptor)
                    //拦截所有的请求
                    .addPathPatterns("/**")
                    //放行登录的请求
                    .excludePathPatterns("/**/login/**");
        }
    }