Spring Cloud Feign实现动态URL-FinClip官网

Spring Cloud Feign实现动态URL

网友投稿 1663 2022-10-30

Spring Cloud Feign实现动态URL

目录需求描述具体实现使用Feign定义统一回调方法使用Spring Cloud Feign定义统一回调方法总结

需求描述

动态URL的需求场景：

有一个异步服务S，它为其他业务（业务A，业务B...）提供异步服务接口，在这些异步接口中执行完指定逻辑之后需要回调相应业务方的接口。

这在诸如风控审核，支付回调等场景中挺常见的。

那么，这个回调业务方接口该怎么实现呢？首先，需要约定好回调这些业务方接口时的请求方法（通常为POST请求），请求参数格式（通常为jsON格式，方便扩展）和响应消息格式（通常为JSON格式）。

具体调用业务方接口时有2种办法来实现：1.在服务S的每一个异步接口中都独立写一套回调的逻辑2.因为回调的方法类型和参数格式是约定好的，所以可以写一个统一的公共回调方法即可

方法1显然不是最优选择，这样做会带来大量重复的代码逻辑，而且非常不利用后期维护和升级。方法2的实现更加灵活一些，便于扩展。

如下将阐述如何使用Feign框架定义一个公共的回调方法。

具体实现

在Feign中能实现动态URL的基础是框架本身就支持，只需要在接口方法中包含一个java-.URI参数，Feign就会将该参数值作为目标主机地址，详见Interface Annotations一节中的“Overriding the Request Line”部分。

如下将分别阐述独立使用Feign和使用Spring Cloud OpenFeign实现定义统一的回调方法。

使用Feign定义统一回调方法

定义统一回调方法：

public interface CallbackAPI {

/**

* 统一回调接口方法，请求消息体格式为JSON，响应消息体格式也为JSON

* @param host 接口主机地址，如：http://localhost:8080，该参数是实现动态URL的关键

* @param path 接口路径，如：/test/hello

* @param queryMap 动态URL参数集合

* @param body 请求消息体对象

* @return

@RequestLine("POST {path}")

@Headers({

"Content-Type: application/json",

"Accept: application/json"

})

Object callback(URI host, @Param("path") String path, @QueryMap Map queryMap, Subject body);

/**

* 统一回调接口方法，请求消息体格式为JSON，响应消息体格式也为JSON

* @param uri 完整的请求路径地址，如：http://localhost:8080/test/hello

* @param queryMap 动态URL参数集合

* @param body 请求消息体对象

* @return

@RequestLine("POST")

@Headers({

"Content-Type: application/json",

"Accept: application/json"

})

Object callback(URI uri, @QueryMap Map queryMaeyCLwqGp, Subject body);

}

调用回调方法：

CallbackAPI callbackAPI = Feign.builder()

.encoder(new GsonEncoder())

.decoder(new GsonDecoder())

.logger(new Slf4jLogger())

.logLevel(Logger.Level.FULL)

.target(CallbackAPI.class, "EMPTY"); // 注意：这里的url参数不能为空字符串，但是可以设置为任意字符串值，在这里设置为“EMPTY”

String uri = "http://localhost:8080";

Map queryMap = new HashMap<>(0);

queryMap.put("k", "v");

Subject body = Subject.builder().id(10).build();

// 请求主机地址与路径分开传递

callbackAPI.callback(URI.create(uri), "/test/simple/post/json", queryMap, body);

// 直接将完整请求完整路径作为uri类型参数

callbackAPI.callback(URI.create("http://localhost:8080/test/simple/post/json"), queryMap, body);

详细请求日志如下：

2022-02-14 15:32:13,118 DEBUG [main] f.Logger [Slf4jLogger.java:72] [CallbackAPI#callback] ---> POST http://localhost:8080/test/simple/post/json?k=v HTTP/1.12022-02-14 15:32:13,118 DEBUG [main] f.Logger [Slf4jLogger.java:72] [CallbackAPI#callback] Accept: application/json2022-02-14 15:32:13,118 DEBUG [main] f.Logger [Slf4jLogger.java:72] [CallbackAPI#callback] Content-Length: 142022-02-14 15:32:13,118 DEBUG [main] f.Logger [Slf4jLogger.java:72] [CallbackAPI#callback] Content-Type: application/json2022-02-14 15:32:13,118 DEBUG [main] f.Logger [Slf4jLogger.java:72] [CallbackAPI#callback] 2022-02-14 15:32:13,118 DEBUG [main] f.Logger [Slf4jLogger.java:72] [CallbackAPI#callback] { "id": 10}2022-02-14 15:32:13,118 DEBUG [main] f.Logger [Slf4jLogger.java:72] [CallbackAPI#callback] ---> END HTTP (14-byte body)2022-02-14 15:32:13,153 DEBUG [main] f.Logger [Slf4jLogger.java:72] [CallbackAPI#callback] <--- HTTP/1.1 200 (32ms)2022-02-14 15:32:13,153 DEBUG [main] f.Logger [Slf4jLogger.java:72] [CallbackAPI#callback] connection: keep-alive2022-02-14 15:32:13,153 DEBUG [main] f.Logger [Slf4jLogger.java:72] [CallbackAPI#callback] content-length: 92022-02-14 15:32:13,153 DEBUG [main] f.Logger [Slf4jLogger.java:72] [CallbackAPI#callback] content-type: application/json2022-02-14 15:32:13,153 DEBUG [main] f.Logger [Slf4jLogger.java:72] [CallbackAPI#callback] date: Mon, 14 Feb 2022 07:32:13 GMT2022-02-14 15:32:13,153 DEBUG [main] f.Logger [Slf4jLogger.java:72] [CallbackAPI#callback] keep-alive: timeout=602022-02-14 15:32:13,153 DEBUG [main] f.Logger [Slf4jLogger.java:72] [CallbackAPI#callback] 2022-02-14 15:32:13,153 DEBUG [main] f.Logger [Slf4jLogger.java:72] [CallbackAPI#callback] {"id":10}2022-02-14 15:32:13,153 DEBUG [main] f.Logger [Slf4jLogger.java:72] [CallbackAPI#callback] <--- END HTTP (9-byte body)

显然，动态设置目标主机和接口路径已经成功了。

使用Spring Cloud Feign定义统一回调方法

在Spring Cloud Feign中实现定义统一回调接口方法可以直接使用注解进行标注，非常简洁。

定义统一回调方法：

// 注意：这里的url属性值不能为空字符串，但是可以设置为任意字符串值，在这里设置为“EMPTY”

@FeignClient(value = "CallbackAPI", url = "EMPTY", configuration = CallbackConfiguration.class)

public interface CallbackAPI {

/**

* 统一回调接口方法，请求消息体格式为JSON，响应消息体格式也为JSON

* @param host 接口主机地址，如：http://localhost:8080

* @param path 接口路径，如：/test/hello

* @param queryMap 动态URL参数集合

* @param body 请求消息体对象

* @return

@RequestMapping(value = "{path}", method = RequestMethod.POST, consumes = MediaType.APPLICATION_JSON_VALUE, produces = MediaType.APPLICATION_JSON_VALUE)

Object callback(URI host,

@PathVariable("path") String path,

@SpringQueryMap Map queryMap,

@RequestBody Object body);

/**

* 统一回调接口方法，请求消息体格式为JSON，响应消息体格式也为JSON

* @param uri 完整的请求路径地址，如：http://localhost:8080/test/hello

* @param queryMap 动态URL参数集合

* @param body 请求消息体对象

* @return

@RequestMapping(method = RequestMethod.POST, consumes = MediaType.APPLICATION_JSON_VALUE, produces = MediaType.APPLICATION_JSON_VALUE)

Object callback(URI uri,

@SpringQueryMap Map queryMap,

@RequestBody Object body);

}

// 回调接口配置

public class CallbackConfiguration {

@Bean

public Encoder feignEncoder() {

return new GsonEncoder();

}

@Bean

public Decoder feignDecoder() {

return new GsonDecoder();

}

@Bean

public Retryer feignRetryer() {

return new Retryer.Default();

}

@Bean

public Logger feignLogger() {

return new Slf4jLogger();

}

@Bean

public Logger.Level feignLoggerLevel() {

return Logger.Level.FULL;

}

调用回调方法：

@Autowired

CallbackAPI callbackAPI;

String uri = "http://localhost:8080";

Map queryMap = new HashMap<>(0);

queryMap.put("k", "v");

Subject subject = Subject.builder().id(10).build();

// 请求主机地址与路径分开传递

this.callbackAPI.callback(URI.create(uri), "/test/simple/post/json", queryMap, subject);

// 直接将完整请求完整路径作为uri类型参数

this.callbackAPI.callback(URI.create("http://localhost:8080/test/simple/post/json"), queryMap, subject);

详细请求日志如下：

2022-02-14 15:38:38.908 DEBUG 20184 --- [ main] feign.Logger : [CallbackAPI#callback] ---> POST http://localhost:8080/test/simple/post/json?k=v HTTP/1.12022-02-14 15:38:38.908 DEBUG 20184 --- [ main] feign.Logger : [CallbackAPI#callback] Accept: application/json2022-02-14 15:38:38.908 DEBUG 20184 --- [ main] feign.Logger : [CallbackAPI#callback] Content-Length: 142022-02-14 15:38:38.908 DEBUG 20184 --- [ main] feign.Logger : [CallbackAPI#callback] Content-Type: application/json2022-02-14 15:38:38.908 DEBUG 20184 --- [ main] feign.Logger : [CallbackAPI#callback] 2022-02-14 15:38:38.908 DEBUG 20184 --- [ main] feign.Logger : [CallbackAPI#callback] { "id": 10}2022-02-14 15:38:38.908 DEBUG 20184 --- [ main] feign.Logger : [CallbackAPI#callback] ---> END HTTP (14-byte body)2022-02-14 15:38:38.924 DEBUG 20184 --- [ main] s.n.protocol.http.HttpURLConnection : sun-.MessageHeader@539c48307 pairs: {POST /test/simple/post/json?k=v HTTP/1.1: null}{Accept: application/json}{Content-Type: application/json}{User-Agent: Java/1.8.0_271}{Host: localhost:8080}{Connection: keep-alive}{Content-Length: 14}2022-02-14 15:38:38.945 DEBUG 20184 --- [ main] s.n.protocol.http.HttpURLConnection : sun-.MessageHeader@681e913c6 pairs: {null: HTTP/1.1 200}{Content-Type: application/json}{Content-Length: 9}{Date: Mon, 14 Feb 2022 07:38:38 GMT}{Keep-Alive: timeout=60}{Connection: keep-alive}2022-02-14 15:38:38.952 DEBUG 20184 --- [ main] feign.Logger : [CallbackAPI#callback] <--- HTTP/1.1 200 (37ms)2022-02-14 15:38:38.952 DEBUG 20184 --- [ main] feign.Logger : [CallbackAPI#callback] connection: keep-alive2022-02-14 15:38:38.952 DEBUG 20184 --- [ main] feign.Logger : [CallbackAPI#callback] content-length: 92022-02-14 15:38:38.952 DEBUG 20184 --- [ main] feign.Logger : [CallbackAPI#callback] content-type: application/json2022-02-14 15:38:38.952 DEBUG 20184 --- [ main] feign.Logger : [CallbackAPI#callback] date: Mon, 14 Feb 2022 07:38:38 GMT2022-02-14 15:38:38.953 DEBUG 20184 --- [ main] feign.Logger : [CallbackAPI#callback] keep-alive: timeout=602022-02-14 15:38:38.953 DEBUG 20184 --- [ main] feign.Logger : [CallbackAPI#callback] 2022-02-14 15:38:38.955 DEBUG 20184 --- [ main] feign.Logger : [CallbackAPI#callback] {"id":10}2022-02-14 15:38:38.955 DEBUG 20184 --- [ main] feign.Logger : [CallbackAPI#callback] <--- END HTTP (9-byte body)

从日志详情看，在Spring Cloud Feign中同样实现动态URL的效果。

总结

在Feign中实现动态URL时：1.可以使用URI类型的参数作为请求目标主机地址或者完整请求地址2.如果URI类型的参数值仅为主机部分，请求路径部分可以使用表达式进行替换

【参考】https://cnblogs.com/syui-terra/p/14386188.html Feign 动态URL 解决记录https://blog.csdn-/kysmkj/article/details/89672952 Feign 访问远程api，动态指定url

标签：js

于 Linux 环境中开发微信小程序的相关事宜

1663 2022-10-30

Spring Cloud Feign实现动态URL

怎样在小程序里实现标题的更改

于 Linux 环境中开发微信小程序的相关事宜

探索小程序使用 MD5 的方式与技巧

最近发表

更多内容

小程序SDK

Finclip技术文档

小程序开发

小程序容器

小程序框架

Finclip小程序平台

Finclip用户投稿

车联网

推荐文章

小程序SDK是什么意思？小程序sdk和插件有什么区别？

小程序支付功能怎么实现？

企业app开发流程是什么？

app运营模式有哪些？

小程序多端引流怎么做？

小程序生态分析的机会和威胁

Flutter入门这一篇效率文章就够了

原生与跨平台解决方案分析,跨平台软件开发技术方案

热更新技术：让软件更新变得更加轻松快速

解决方案

银行解决方案

证券解决方案

互联网解决方案

政企OA解决方案

科技解决方案

loT解决方案

信任解决方案

热评文章

AppCan:基于混合模式的移动应用开发,移动混合模

Hybrid App混合模式开发的了解

小程序容器技术助力券商数字营销突围，小程序容器化的意

用mpvue开发微信小程序基础知识（vue.js开发

小程序多端框架全面测评对比，强烈推荐！

券商app架构 - 解析券商应用程序的构建与设计