pexels-szabolcs-toth-3205909.jpg
背景：
跨境支付行业下游需要对接很多个下发渠道，每个渠道的对接方式和接口、参数、逻辑都有所不同。各自需要一个独立的对接渠道的服务。
简单流程图：
流程图.png
知识点：
- WebClient
SpringWebFlux下面的一个功能模块。
是响应式编程的一个小小体现。
响应式编程定义：
在计算机领域，响应式编程是一个专注于数据流和变化传递的异步编程范式。
编程范式定义：
编程是为了解决问题，而解决问题可以有多种视角和思路，其中具有普适性的模式被归结为范式。 面向对象、面向过程都是编程范式。
响应式编程是一种从数据流和变化出发的解决问题的模式。 响应式编程，本质上是对数据流或某种变化所作出的反应，但是这个变化什么时候发生是未知的，所以是基于异步、回调的方式在处理问题。
配置：
implementation 'org.springframework.boot:spring-boot-starter-webflux:2.3.0.RELEASE'
@Bean
public WebClient getWebClient() {
TcpClient tcpClient = TcpClient
.create()
.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, connectTimeOut)
.doOnConnected(connection -> {
connection.addHandlerLast(new ReadTimeoutHandler(readTimeout, TimeUnit.MILLISECONDS));
connection.addHandlerLast(new WriteTimeoutHandler(writeTimeout, TimeUnit.MILLISECONDS));
});
WebClient webClient = WebClient.builder()
.defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
.clientConnector(new ReactorClientHttpConnector(HttpClient.from(tcpClient)))
.build();
return webClient;
}
通用方法
public WebClient.ResponseSpec post(String url, String bodyData, String token) {
WebClient.ResponseSpec responseSpec = webClient.method(HttpMethod.POST)
.uri(url)
.header("Authorization", "Bearer " + token)
.header("partnerkey", eastWestBankPropertyConfig.getPartnerkey())
.header("x-correlation-id", "ew-" + idWorker.nextId())
.contentType(MediaType.APPLICATION_JSON).body(BodyInserters.fromValue(bodyData))
.retrieve();
return responseSpec;
}
public WebClient.ResponseSpec postToken(String url, MultiValueMap<String, String> formData) {
return webClient.method(HttpMethod.POST)
.uri(url)
.contentType(MediaType.APPLICATION_FORM_URLENCODED).body(BodyInserters.fromFormData(formData))
.retrieve();
}
同步调用
private SubAccountOpenResponse postOpenSubAccount(SubAccountOpenRequest subAccountOpenRequest, EastWestBankPropertyConfig eastWestBankPropertyConfig, String token) {
return webClientUtil.post(eastWestBankPropertyConfig.getSubAccountOpenUrl(), commonService.buildCommonRequestParam(subAccountOpenRequest), token)
.bodyToMono(SubAccountOpenResponse.class).onErrorResume(Mono::error).block();
}
- RabbitMQ
- Mock
Mock渠道API文档的demo数据，方便测试，不影响交易系统的正常测试进度。
json数据存到.json文件里面，然后IO读取返回，开关控制。
private JSONObject parseJsonFromFile() {
JSONObject jsonResult = new JSONObject();
try {
File jsonFile = ResourceUtils.getFile("classpath:MockData.json");
String json = FileUtil.readAsString(jsonFile);
jsonResult = JSON.parseObject(json);
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
return jsonResult;
}
注入
private final MockData mockData;
@Autowired
public TradeService(WebClientUtil webClientUtil, CommonService<T> commonService, MockData mockData) {
this.webClientUtil = webClientUtil;
this.commonService = commonService;
this.mockData = mockData;
}
- 全局异常处理
@ControllerAdvice
@ExceptionHandler(WebClientResponseException.class)
总结：
未来可以整理一个通用的脚手架，简单的标准、模型。
