你以为你以为的就是你以为的吗?记一次服务器点对点通知的联调过程

Posted 2021-03-23 buguge

公司两个系统：⒈. 我们项目组负责的A系统 、 ⒉. 另一个项目组负责的B系统。

A系统要调用B系统接口上送业务签约单申请。B系统接收数据后，异步处理，签约完成后，会主动发送通知给A系统。

在联调异步通知接口时，问题来了，发现我方一直收不到对方的回调。

接口文档里说明了，通过http协议的post请求来发送异步通知，报文是json格式字符串。

 

我们A系统定义restful的http接口。

【题外话】@RequestBody注解：@RequestBody接收的参数是来自requestBody中，即请求体。适用于http post请求。请求端通过HttpEntity传递参数，并在请求头中声明数据的类型Content-Type，SpringMVC通过使用 HandlerAdapter 配置的HttpMessageConverters来解析HttpEntity中的数据，然后绑定到相应的bean上。

@RestController
@Slf4j
public class TaxNotifyController {

    @Reference
    private TaxNotifyService taxNotifyService;

    /**
     *
     * @param notifyVO
     * @return
     */
    @PostMapping("/ayncNotify")
    @UnAuthToken
    public String ayncNotify(@RequestBody NotifyVO notifyVO){
        log.info("收到回调----异步回调----异步通知----回调通知:{}", JSON.toJSONString(notifyVO));
        String respText = taxNotifyService.ayncNotify(notifyVO);
        log.info("回调----异步回调----异步通知----回调通知 回写内容：{}",respText);
        return respText;
    }
}

 

QA在测试过程中，发现对方B系统有请求，如下日志截图为证。而查看我方A系统的log文件，却并没有发现“收到回调----异步回调----异步通知----回调通知”这样的log。也就是说，我方A系统一直收不到请求。

 

难道是B系统到我们A系统的网络不通？双方都是测试环境呀！还是去找运维确认吧。运维在B系统服务器执行curl验证结果如下。因为需要POST，所以curl接收到这个错误。但至少证明这2个系统间的网络是没问题的。

[root@localhost logs]# curl http://192.168.40.84:8802/ent-boot/ayncNotify
{"code":"ERROR","message":"Request method \'GET\' not supported"}

 

 

然后，然后，再次确认我方log。发现蛛丝马迹：

2019-12-13 11:07:01.894 [http-nio-8802-exec-9] INFO  com.emaxcard.car.filter.CrosXssFilter:40 - 
CrosXssFilter.......orignal url:/ent-boot/ayncNotify,ParameterMap:{}
2019-12-13 11:07:01.895 [http-nio-8802-exec-9] WARN  o.s.w.s.m.support.DefaultHandlerExceptionResolver:197 - 
Resolved [org.springframework.web.HttpMediaTypeNotSupportedException: Content type \'text/xml;charset=UTF-8\' not supported]
2019-12-13 11:07:01.895 [http-nio-8802-exec-9] INFO  com.emaxcard.car.filter.CrosXssFilter:44 - 
CrosXssFilter..........doFilter url:/ent-boot/ayncNotify,ParameterMap:{}

 

莫非，对方给的content-type是text/xml？？

 

找B系统的开发同学，经查代码里HttpUtil，果然，指定的content-type是text/xml。 如下图。我们知道，springmvc默认接收数据的格式是json方式序列化的。你指定成xml格式，显然springmvc在反序列化成NotifyVO对象时会抛出异常。自然，就不会执行这个action方法了，所以，我们没看到那条“收到回调----异步回调----异步通知----回调通知”log。

【题外话】关于springmvc的messageconverter设置，可以查看spirng-web.jar里的RestTemplate.java源码。

Line122：jsonbPresent = ClassUtils.isPresent("javax.json.bind.Jsonb", classLoader);

 

接着说，我们让这位开发同学改成 application/json 后，问题得以解决。

 

 

But，yet，however，下午，QA在测试付款单的回调的时候，同样的问题又出现了，我们接收不到请求报文。一看log，又是text/xml搞的鬼。B系统的这个付款回调是另一个同学开发的。考虑到目前已经有外部商户接入B系统，他们不准备改了。

不改就不改吧，B系统他们不改，只好我们A系统改了。话说回来，即便他们现在不改，日后有其他商户对接联调时，也难免会出现类似的问题。那，就是以后的事儿了。

我们怎么改呢？那就不直接从RequestBody里接收NotfiyVO对象了，改成接收String字符串。然后，在方法里来做判断和反序列化。改后的代码为：

    @PostMapping("/ayncNotify")
    @UnAuthToken
    public String ayncNotify(@RequestBody String notifyStr){
        log.info("收到回调----异步回调----异步通知----回调通知:{}", notifyStr);
        if(StringUtils.isBlank(notifyStr)){
            log.info("回调通知为空");
            return "ERROR-回调通知请求参数为空";
        }
        NotifyVO notifyVO = JSON.parseObject(notifyStr,NotifyVO.class);
        log.info("回调转换NotifyVo:{}",notifyVO);
        String respText = taxNotifyService.ayncNotify(notifyVO);
        log.info("回调----异步回调----异步通知----回调通知 回写内容：{}",respText);
        return respText;
    }

 

 

THE END.

下午得知，一同学在对接付款接口时，当付款接口返回受理失败时，他把付款单的付款结果改成了失败。这可要不得呀！付款结果一定要通过付款查询接口来查。查询返回付款成功，则付款成功；查询返回付款失败，则付款失败；对于查询到的其他结果，保守起见，都视为付款中即可，然后继续查询，查询次数达到阈值则交由人工来干预。技术人员千万别自作主张，把某些不明确的结果定为付款失败。万一出现重复付款，那就尴尬了。我在2016年那时刚开始做聚合支付时，是有这样的惨痛经历的。

 

 ☞ Stay Hungry,Stay Foolish.