首页 > 其他分享 >【解决方案】如何使用 Http API 代替 OpenFeign 进行远程服务调用

【解决方案】如何使用 Http API 代替 OpenFeign 进行远程服务调用

时间：2024-01-22 14:23:23浏览次数：22  
标签：body Http 请求 OpenFeign url String API response name

目录

前言

看到标题大家可能会有点疑惑吧：OpenFeign 不是挺好用的吗？尤其是微服务之间的远程调用，平时用的也挺习惯的，为啥要替换呢？

背景和原因是这样的：

  1. 部门/团队在安全性上有所考虑，即尽可能地减少/消除引入外部依赖，尽量只使用自研依赖、apache、Spring等必须的开源依赖；
  2. 而 OpenFeign 的使用则是引入了 Spring Cloud 依赖（不在安全要求范围内），所以需要考虑替换；
  3. 为以后团队的项目上 Spring 6做铺垫，Spring 6 会有 Spring 内置的 Http Interface 发起远程服务调用。

下面将从介绍 OpenFeign、常见的 Http API 以及重点介绍 Spring 自带的 RestTemplate Http 模板这3个方面展开。

一、何为OpenFeign

OpenFeign 是 Spring Cloud 在 Feign 的基础上支持了 SpringMVC 的注解，如 @RequesMapping 等，其底层默认使用的是 URLConnection 实现。

OpenFeign 的 @FeignClient 注解可以解析 SpringMVC 的@RequestMapping 注解下的接口，并通过动态代理的方式产生实现类，实现类中做负载均衡并调用其他服务。

1.1@FeignClient注解

只要是使用 OpenFeign 那么这个注解是一定会使用到的，该注解的主要属性如下：

  • url：可以手动指定 @FeignClient 调用的远程服务地址，如果同时声明 url 和 name 则以 url 为准，此时 name 仅作为该 FeignClient 的名称而已；
  • name：指定当前 FeignClient 的名称，如果项目使用了 Ribbon，那么 name 属性会作为微服务的名称，用于服务的发现；
  • value：实际上和 name 是用一个属性，因为这两个属性互相使用了别名，使用的时候两者选其一即可；
  • path：定义当前 FeignClient 的统一前缀，即表示所有调用的远程服务都会走这个 path 声明的 http 前缀；
  • configuration：Feign 的配置类，可以自定义 Feign 的 Encoder、Decoder、LogLevel、Contract 等；
  • fallback：定义容错的处理类，当调用远程接口失败或超时，会调用对应接口的容错逻辑，fallback 指定的类必须实现 @FeignClient 标记的接口。

简单示例如下：

@FeignClient(url = "https://xxx.abcdef.com", name = "SubmitTaskClient", 
             configuration = OpenFeignFormConfig.class, fallback = HystrixFallbackConfig.class)
public interface SubmitTaskClient {

    /**
     * 调用远程接口实现，入参为 json 字符串
     * @param paramJsonStr
     * @param header
     * @return
     */
    @PostMapping
    String submitNormalTask(@RequestBody String paramJsonStr, @RequestHeader Map<String, String> header);

    /**
     * 调用远程接口实现，入参为 map 的表单形式
     * @param map
     * @return
     */
    @PostMapping(value = "/task/create", headers = {"content-type=application/x-www-form-urlencoded"})
    String submitTransTask(Map<String, ?> map);

}

1.2注意事项

在远程服务调用一般存在两种情况：

  1. 远程服务在注册中心

    如果远程服务的提供方已经注册到注册中心，那么 name 或者 value 的值为：注册中心的服务名称，且必须为所有客户端指定一个 name 或者 value。

    @FeignClient(name = "SubmitTaskService", configuration = OpenFeignFormConfig.class, fallback = HystrixFallbackConfig.class)

  2. 单独的远程 http 接口

    此处 name 的值为当前 feignClient 客户端的名称，指定的 url 则为远程服务的地址。

    @FeignClient(url = "https://xxx.abcdef.com", name = "SubmitTaskClient", configuration = OpenFeignFormConfig.class)

    以上两种方式都能正常进行远程服务调用。name 可以为注册中心的服务名称，同时有 url 属性时，name 就与注册中心服务名称无关。

二、常见的Http API

OpenFeign 本质上还是使用 http 请求完成服务的调用，其实使用以下的这些 Http API 经过适当的改造后，也可以达到效果。

2.1Apache

在后端领域，出现比较早而且使用仍然很广泛的 HTTP 客户端框架非 Apache HttpClien 莫属了，目前大量项目和公司仍在采用该框架。

Apache HttpClient 有着不错的性能、丰富的功能以及强大的自定义实现等特色。但是随着技术的发展和设计理念的改变，Apache HttpClient 显的有些落伍了。

个人认为其最不受欢迎的点主要在于 API 的设计过于臃肿，大量的配置需要手动声明，当见过了更多好的的 Http API 后你可能就会不太想继续用了。当然公司框架正在使用 Apache HttpClient 的情况下也无可厚非，虽然复杂点，但用还是可以用的。

引入 pom 依赖：

        <!-- https://mvnrepository.com/artifact/org.apache.httpcomponents/httpclient -->
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpclient</artifactId>
            <version>4.5.13</version>
        </dependency>

POST 请求示例如下：

    public String apacheHttpClientPost(String url, String params) throws Exception {
        CloseableHttpClient httpclient = HttpClients.createDefault();
        HttpPost httpPost = new HttpPost(url);
        httpPost.setHeader("Content-Type", "application/json");
        String charSet = "UTF-8";
        StringEntity entity = new StringEntity(params, charSet);
        httpPost.setEntity(entity);
        CloseableHttpResponse response = null;
        try {
            response = httpclient.execute(httpPost);
            StatusLine status = response.getStatusLine();
            int state = status.getStatusCode();
            if (state == 200) {
                HttpEntity responseEntity = response.getEntity();
                return EntityUtils.toString(responseEntity);
            }
        } finally {
            if (response != null) {
                try {
                    response.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            try {
                httpclient.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        return null;
    }

2.2Okhttp

OkHttp3 是 OkHttp 发展到版本3.0之后的名字。在 maven 中央仓库搜索 okhttp，可以看到 3.0 之后的版本统一称为 OkHttp3。

OKHttp3 是一个当前主流的网络请求的开源框架，由 Square 公司开发，目标是用于替代 HttpUrlConnection 和 Apache HttpClient。

        <!-- https://mvnrepository.com/artifact/com.squareup.okhttp3/okhttp -->
        <dependency>
            <groupId>com.squareup.okhttp3</groupId>
            <artifactId>okhttp</artifactId>
            <version>4.9.1</version>
        </dependency>

POST 请求示例如下：

	public String okHttpPostMethod(String url,String body,  OkHttpClient okHttpClient) throws IOException {
        MediaType JSON_TYPE = MediaType.parse("application/json");
        Request request = new Request.Builder()
                .url(url).post(RequestBody.create(JSON_TYPE, body)).addHeader("Content-Type", "application/json")
                .build();
        Response response = null;
        try {
            response = okHttpClient.newCall(request).execute();
        } catch (Exception e) {
            e.printStackTrace();
        }
        assert response != null;
        if (response.isSuccessful()) {
            return response.body() == null ? "" : response.body().string();
        }
        return null;
    }

对于需要单独处理 POST、GET 等请求的情况来说，OkHttp3 是很适合的。

但是对于一些通用请求，比如在一个通用方法的参数里只需要传入 Method 枚举（POST、GET 等）就可以实现对应类型的请求，Hutool 和 RestTemplate 可能更为合适。

2.3Hutool

Hutool 中的工具方法来自每个用户的精雕细琢，它涵盖了 Java 开发底层代码中的方方面面，是国内 Java 开发工具类库的集大成者，很多公司的很多项目都在用。

其中 Hutool 的 http 部分是基于 HttpUrlConnection 的 Http 客户端封装，大致发起调用的步骤：首先构建一个http请求，包括请求的地址、请求方式、请求头、请求参数等信息，然后执行请求返回一个 http 响应类，最后通过这个相应类可以获取响应的主体、是否请求成功等信息。

但遗憾的是，团队里也有比较明确的安全规定：不允许在项目中引入 Hutool 依赖包。

引入 pom 依赖：

        <!-- https://mvnrepository.com/artifact/cn.hutool/hutool-all -->
        <dependency>
            <groupId>cn.hutool</groupId>
            <artifactId>hutool-all</artifactId>
            <version>5.8.8</version>
        </dependency>

创建通用请求的示例如下：

    public String huToolMethod(String url, HttpMethod httpMethod, RequestBody body) {
        Map<String, String> headers = new HashMap<>();
        headers.put(HttpHeaders.CONTENT_TYPE, "application/json;charset=utf-8");
        // 创建通用请求, 可以涵盖所有常见的 HTTP 方法, 同时放入 url
        HttpRequest request = HttpUtil.createRequest(Method.valueOf(httpMethod.name()), url);
        // 放入请求的 header 和 body
        HttpResponse response = request.addHeaders(headers).body(JSON.toJSONString(body)).execute();
        return response.body();
    }

三、RestTemplate

RestTemplate 是 Spring 框架用来访问 RESTFUL 服务的客户端模板类，主要功能有：

1、发起 HTTP 请求，包括 RESTful 风格的 GET，POST，PUT，DELETE 等常见方法；

2、自动将响应结果映射为 Java 对象，不用手动解析 JSON 或 XML。

3、自定义设置请求头、消息转码、Cookie 等功能。

4、对不同的输入/输出类型提供对应的方法，如字符串、对象、多部分等。

5、同时还支持远程调用，不受同源策略限制。

引入 pom 依赖：

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-freemarker</artifactId>
        </dependency>

配置类：

@Configuration
public class RestTemplateConfig {

    @Bean
    public RestTemplate restTemplate(ClientHttpRequestFactory factory){
        return new RestTemplate(factory);
    }

    @Bean
    public ClientHttpRequestFactory simpleClientHttpRequestFactory(){
        SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();
        factory.setConnectTimeout(10000);
        factory.setReadTimeout(10000);
        return factory;
    }
}

3.1详解.execute()

.execute() 是 RestTemplate 中最常见的关于执行 HTTP 请求的方法，它允许开发人员高度定制 HTTP 请求。

先来给一段示例：

    public String restTemplateExecuteMethod(String url, String token, Object body, HttpMethodName method){
        HttpHeaders httpHeaders = new HttpHeaders();
        // headers：HttpHeaders 类型，包括所有头信息
        httpHeaders.add("Authorization", token);
        httpHeaders.add("Content-Type", "application/json;charset=utf-8");
        // body：请求体，可以是任何对象，也可以是 null
        HttpEntity<Object> httpEntity = new HttpEntity<>(JSON.toJSONString(body), httpHeaders);
        RequestCallback requestCallback = restTemplate.httpEntityCallback(httpEntity, Object.class);
        ResponseExtractor<ResponseEntity<Object>> responseExtractor = restTemplate.responseEntityExtractor(Object.class);
        // 发送请求，method.name() 表示传入的方法，包括 GET、POST、DELETE 等
        ResponseEntity<Object> entity = restTemplate.execute(url, HttpMethod.valueOf(method.name()), requestCallback, responseExtractor);
        // 直接返回 body
        Assert.notNull(entity, "返回体为空！");
        log.info("---返回的内容：{}---", JSON.toJSONString(entity.getBody()));
        return JSON.toJSONString(entity.getBody());
    }

下面是一些对象的介绍：

  • HttpEntity 对象

    它主要有两个作用：

    1、表示 HTTP 请求：当表示 HTTP 请求时，HttpEntity 有两个主要组成部分：请求头和请求体。

    2、表示 HTTP 响应：当表示 HTTP 响应时，有三个部分：状态码、响应头和响应体。

    其中的参数：

    • headers：HttpHeaders 类型，包括所有头信息；
    • body：请求或响应体，可以是任何对象，也可以是null；
    • statusCode：HttpStatus 类型，只有在表示响应时才有效。

  • RequestCallback 对象

    RequestCallback 是 RestTemplate中用来定制HTTP请求的一个接口，可以设置请求头、请求体、查询字符串参数。

    Callback接口只有一个方法：

    void doWithRequest(ClientHttpRequest request) throws IOException

四、文章小结

文章的最后，我选择了 okhttp3 和 RestTemplate 来进行 OpenFeign 的替换工作：okhttp3 处理单个 POST/GET 等请求，使用.execute() 处理通用 HTTP 请求。

那么如何使用 Http API 代替 OpenFeign 进行远程服务调用的分享到这里就结束了，如有不足和错误，还请大家指正。或者你有其它想说的，也欢迎大家在评论区交流！

标签：body,Http,请求,OpenFeign,url,String,API,response,name
From： https://www.cnblogs.com/Apluemxa/p/17979942

相关文章

  • http的form表单格式请求
    Content-Type:application/x-www-form-urlencoded是一个HTTP头部中使用的媒体类型（MIMEtype），它告诉服务器消息体的格式以键值对形式进行编码，并且键值对之间用&分隔，每个键和值都用=连接。这是表单数据被编码成一个查询字符串的方式，通常用于提交HTML表单数据。当你提交一个简......
  • 使用Go发送HTTP POST请求
    在Go语言中，我们可以使用net/http包来发送HTTPPOST请求。以下是一个简单的示例，展示了如何使用Go发送HTTPPOST请求并获取响应。go复制代码package mainimport ("bytes" "fmt" "io/ioutil" "net/http" )func main() {//创建一个HTTP客户端client:=&http.Client{}//......
  • 在Go中处理HTTPS请求：一场加密的舞蹈
    嘿，Go语言的爱好者们，你们准备好跳一场加密的舞蹈了吗？今天，我们要一起探讨如何在Go中处理那些神秘的HTTPS请求。首先，我们要明白HTTPS是什么。简单来说，HTTPS就是给HTTP穿上了一层"加密的外套"，让数据在传输过程中变得难以被窥视。这就像是在网络世界里，我们给自己的信息加了一把锁，只有拥......
  • 【OpenVINO】基于 OpenVINO C++ API 部署 RT-DETR 模型
     RT-DETR是在DETR模型基础上进行改进的，一种基于DETR架构的实时端到端检测器，它通过使用一系列新的技术和算法，实现了更高效的训练和推理，在前文我们发表了《基于OpenVINO™PythonAPI部署RT-DETR模型|开发者实战》，在该文章中，我们基于OpenVINO™PythonAPI向大家展示......
  • FastAPI学习-29 uvicorn 使用 log_config 参数设置 logger 日志格式
    前言FastAPI服务是通过uvicorn来提供的，日志都是uvicorn里配置的。官方文档地址：https://www.uvicorn.org/settings/#logginguvicorn的logging日志我们可以通过uvicorn.run()方式启动服务uvicorn.run("example:app",port=5000,reload=True,access_log=False)于是可以加......
  • FastAPI学习-30 项目代码中添加自己的日志内容
    前言前面一篇【FastAPI学习-29uvicorn使用log_config参数设置logger日志格式】已经学会了配置uvicorn的日志。如何在fastapi项目代码中添加自己的日志呢？添加日志创建一个logger实例，名称为"fast"fromfastapiimportFastAPIimportlogginglogger=logging.getLogger(......
  • FastAPI学习-28 alembic数据迁移报错：Target database is not up to date 报错解决办法
    前言当表结构有变更，数据迁移时，出现报错：Targetdatabaseisnotuptodate遇到的问题执行迁移命令alembicrevision--autogenerate-m"testv4"出现如下报错>alembicrevision--autogenerate-m"testv4"INFO[alembic.runtime.migration]ContextimplMySQLImpl.INFO[alem......
  • [转]Java Stream API入门篇
    原文地址:JavaStreamAPI入门篇-CarpenterLee-博客园本文github地址你可能没意识到Java对函数式编程的重视程度，看看Java8加入函数式编程扩充多少功能就清楚了。Java8之所以费这么大功夫引入函数式编程，原因有二：代码简洁，函数式编程写出的代码简洁且意图明确，使用stream接口......
  • [转]Java Stream API进阶篇
    原文地址:JavaStreamAPI进阶篇-CarpenterLee-博客园本文github地址上一节介绍了部分Stream常见接口方法，理解起来并不困难，但Stream的用法不止于此，本节我们将仍然以Stream为例，介绍流的规约操作。规约操作（reductionoperation）又被称作折叠操作（fold），是通过某个连接动作将所有......
  • Go语言核心36讲 44 | 使用os包中的API （上）
    我们今天要讲的是os代码包中的API。这个代码包可以让我们拥有操控计算机操作系统的能力。前导内容：os包中的API这个代码包提供的都是平台不相关的API。那么说，什么叫平台不相关的API呢？它的意思是：这些API基于（或者说抽象自）操作系统，为我们使用操作系统的功能提供高层次的支持，但是，......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99