好得很程序员自学网

<tfoot draggable='sEl'></tfoot>

Feign如何解决服务之间调用传递token

解决服务之间调用传递token

现在的微服务基本就是SpringSecurity+Oauth2做的授权和认证,假如多个服务直接要通过Fegin来调用,会报错401

a、有做权限处理的服务接口直接调用会造成调用时出现http 401未授权的错误,继而导致最终服务的http 500内部服务器错误 b、解决方式:最方便的就是往请求头里加上token,一起带过去;

Feign有提供一个接口RequestInterceptor

只要实现这个接口,简单做一些处理,比如说我们验证请求头的token叫Access-Token,我们就先取出当前请求的token,然后放到feign请求头上;

?

1

2

3

4

5

6

7

8

9

public class FeignConfig implements RequestInterceptor {

        @Override

        public void apply(RequestTemplate requestTemplate) {

            ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();

            HttpServletRequest request = attributes.getRequest();

            //添加token

            requestTemplate.header(HttpHeaders.AUTHORIZATION, request.getHeader(HttpHeaders.AUTHORIZATION));

        }

    }

调用方式

?

1

2

3

4

5

    @FeignClient (name = "qtjuaa" , configuration = FeignConfig. class )

    public interface UaaClient {

        @RequestMapping (value = "/api/test" , method= RequestMethod.GET)

        String test();

    }

Feign调用服务各种坑处理

编写被调用服务

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

@RefreshScope

@RestController

public class XXXController extends BaseController implements IndicatorsFeignApi{

     @Resource

     private XXXService xxx;

     @Override

     public Wrapper<CommonVo> getXXXX( @RequestBody CommonDto commonDto) {

         try {

             CommonVo vo = xxx.getdata(commonDto);

             return WrapMapper.ok(vo);

         } catch (Exception e) {

             e.printStackTrace();

             return WrapMapper.error( "系统异常,请联系管理员!" );

         }

     }

}

//Service不进行展示,注意参数传递至service层时要加入注解@RequestBody等才能获取参数

在配置文件添加feign相关配置

编写调用api

pom文件中添加相关依赖

?

1

2

3

4

org.springframework.cloud

spring-cloud-starter-hystrix

org.springframework.cloud

spring-cloud-starter-netflix-hystrix-dashboard

调用Api

?

1

2

3

4

5

6

@FeignClient (value = "被调用服务名" )

public interface IndicatorsFeignApi {

    

     @PostMapping (value = "/api/getXXXX" ,consumes= "application/json" , headers = { "Accept=application/json" , "Content-Type=application/json" })

     Wrapper<CommonVo> getXXXX( @RequestBody CommonDto commonDto); 

}

Feign调用错误处理,发生相关错误是会跳转至fallback处理

?

1

2

3

4

5

6

7

8

@Component

public class IndicatorsFeignApiHystrix implements IndicatorsFeignApi {

     @Override

     public Wrapper<CommonVo> getXXXX(CommonDto commonDto) {

         System.out.println( "=====调用服务获数据发生异常======" );

         return null ;

     }

}

当启用fallback后,有些报错不会打印在控制台上,这时可以修改配置中的

?

1

2

3

feign:

   hystrix:

    enabled: true

将enabled改为false,错误发生后将不会跳转fallback。

此处有一个坑,当时调用的时候服务是可以调用成功的,但是有一个报错:

Could not extract response: no suitable HttpMessageConverter found for response type [XXXX] and content type [text/html;charset=UTF-8]

貌似是返回数据的编码与接收实体类不一样,导致报错。加上headers = {"Accept=application/json", "Content-Type=application/json"}解决了相关问题.

编写客户端服务

?

1

2

3

4

5

6

7

8

9

10

11

12

13

//serviceImp层

    @Autowired

     private IndicatorsFeignApi api; //声明调用api

    

     @Override

     public CommonVo getXXX(CommonDto commonDto) {

         Wrapper<CommonVo> result =   api.getXXXX(commonDto); //服务调用

         if (result!= null ) {

             return result.getResult();

         } else {

             return new CommonVo();

         }

     }

以上为个人经验,希望能给大家一个参考,也希望大家多多支持。

原文链接:https://dalianpai.blog.csdn.net/article/details/104708854

查看更多关于Feign如何解决服务之间调用传递token的详细内容...

  阅读:15次