fegin调用不到本地微服务(微服务之间调用feign)

通常来说,很多人用feign是用于内部环境的spring cloud微服务调用。但feign其实是封装了http请求,那调用外部restful api是没有问题的。

fegin调用不到本地微服务(微服务之间调用feign)

在此讲下集成步骤,还有几种配置方法,以及一些注意点。

包引入

<dependency>    <groupId>org.springframework.cloud</groupId>    <artifactId>spring-cloud-starter-openfeign</artifactId>    <version>3.1.1</version></dependency>

这里要注意的是,和springboot版本匹配问题. 一开始使用了2.* 的feign版本,而我的springboot 是 2.6.5,然后报spring boot configration类找不到。更新feign到3.1.1就可以了。

feign编写

这个各种文章都有,

  1. 在Application类,增加注解 @EnableFeignClients
  2. 编写ApiClient interface
  3. 注入实例就可以调用了
  4. 请求得到的对象,可以直接反序列化为自定义的类。这个还挺方便。当然,也可以返回String,自己做json反序列化
  5. 当返回的状态不是200时,会异常的形式返回,这个需要处理

代码示例:

@SpringBootApplication@EnableFeignClientspublic class Application {    public static void main(String[] args) {        SpringApplication.run(Application.class, args);    }}@FeignClient(name = "api",        url = "https://abc.abc.com/api")public interface AbcApi {    @RequestMapping(value = "/", method = RequestMethod.POST)    String query(@RequestParam Map<String, Object> param);}@SpringBootTest@Slf4jclass KaolaApiTest {    @Resource    AbcApi api;    @Test    void query() {        Map<String, Object> param = new HashMap<>();        param.put("sortType", "1");        param.put("pageIndex", "1");        try {            String responseEntity = api.query(param);            log.info("responseEntity {}", responseEntity);        }        catch (Exception e){ // 非200的返回            log.warn("fail to request {}", e);        }    }}

还是比较简洁的,不过,似乎依赖spring框架比较多,不知道在其他环境集成是不是还是这么简单。

Request配置及统一处理

因为配置请求参数,和统一的业务处理我是放在一起的,所以这里也一起说明。

API请求的参数,主要包括像格式、字符集等。而统一业务处理,比如像加签、加密这些。

feign的配置有三种方式,按照作用域如下

  1. 全局配置
  2. 实例配置
  3. 单个请求配置

根据我的日志打印,是先调用2的实例配置,再调用全局配置。假如两个都配置,需要注意这个优先级。

======= local ApiInterceptor start ========

======= local ApiInterceptor end ========

======= global ApiInterceptor start ========

======= global ApiInterceptor end ========

全局配置

使用 @Configuration 的配置注入,并且需要 实现 RequestInterceptor 接口。

作用域是全局的,所以不适合做业务相关的处理。不过你假如只有一个client配置,写这里也无妨。

业务处理的方式,是获取body或者query参数,处理后,再放到header, query, body中去。

@Configuration  // a  global feign client interceptorpublic class FeignConfig implements RequestInterceptor {    @Override    public void apply(RequestTemplate template) {        log.info("=======  FeignClientsConfigurationInterceptor ========");        template.header("Content-Type", "application/json;charset=utf-8");        // 读取业务参数 template.queries or template.body        JSONObject requestBody= (JSONObject) JSON.parse(new String(template.body()));        String appid= (String) requestBody.get("appid");        // 处理业务数据 bodyText,并写回        template.body(bodyText);    }}

实例配置

因为全局配置会影响所有的feign,所以假如项目中有不同的feign client,使用的时候不应该采用全局。

实例配置,自己建立一个interceptor,然后在ApiClient中配置

注意,实例的配置不应该加入@Configuration 的注解 ,防止被注入。

public class ApiConfig {    @Bean    public RequestInterceptor apiInterceptor(){        return template -> {            log.info("=======  apiInterceptor start ========");            handleRequestType(template); // 处理方式同全局            log.info("=======  apiInterceptor end ========");        };    }}@FeignClient(name = "api",        url = "https://abc.abc.com/api",        configuration = ApiConfig.class)  // 这里配置上public interface AbcApi {    @RequestMapping(value = "/", method = RequestMethod.POST)    String query(@RequestParam Map<String, Object> param);}

单个请求配置

这种配置方式就是直接在requestMap上增加,其实之前写的 method 就是如此。还可以增加其他的,比如如下,就是请求乱码可以增加一下header。

@FeignClient(name = "api",        url = "https://abc.abc.com/api")public interface AbcApi {    @RequestMapping(value = "/", method = RequestMethod.POST,          produces = "application/json;charset=UTF-8", consumes = "application/json;charset=UTF-8")    String query(@RequestParam Map<String, Object> param);}

好了,集成入门就到此。简单使用应该问题不大了。假如生产使用,还需要测试性能,连接池等问题。

我是窝牛,专注于各种大杂烩,各种都写,都写不好。欢迎讨论交流。

本站部分内容由互联网用户自发贡献,该文观点仅代表作者本人,本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。

如发现本站有涉嫌抄袭侵权/违法违规等内容,请联系我们举报!一经查实,本站将立刻删除。