监听 RabbitMQ 延时交换机的消息数、OpenFeign 路径参数传入斜杠无法正确转义

背景

【MQ】一套为海量消息和高并发热点消息，提供高可用精准延时服务的解决方案

我现在有一个需求，就是监听 RabbitMQ 一个延时交换机的消息数，而 RabbitTemplate 是不存在对应的方法来获取的。
而我们在 RabbitMQ 的控制台却可以发现延时交换机的消息数，所以其开放的 http-api 里存在我们需要的数据，通过抓包可得：
在这里插入图片描述
而我们查看这个包，构造请求（抓包+分析的技巧这里不做介绍）

当然你完全可以去看 RabbitMQ 的 http-api 开放文档，但是我觉得有点多，还不如直接抓包

URL：

http://rabbithost:15672/api/exchanges/{virtualHost}/{exchange}?msg_rates_age=60&msg_rates_incr=5

Method：

GET

Header：

Authorization: "Basic " + EncryptUtil.encodeBase64(String.format("%s:%s", rabbitMQConfig.getUsername(), rabbitMQConfig.getPassword()));

很快我们就能写一个 OpenFeign 客户端：


@FeignClient(name = "rabbitmq-service", url = "${okr.mq.http-api}")
public interface RabbitMQHttpFeignClient {@GetMapping("/exchanges/{virtualHost}/{exchange}?msg_rates_age=60&msg_rates_incr=5")DelayExchangeVO getMessagesDelayed(@RequestHeader(HttpHeaders.AUTHORIZATION) String authorization,@PathVariable("virtualHost") String virtualHost,@PathVariable("exchange") String exchange);}

但是你会发现，virtualHost 是带 / 的，但是最终的 url 并没有转义，导致路由出错报了 404

400 是参数未通过验证、401 未通过身份认证、403 无权限

先说结论！！！

配置一个 Contract （协议，约定），并设置 decodeSlash 为 false ！

@Component
public class OpenFeignConfig {@Beanpublic Contract notdecodeSlashContract(){// 无自定义处理器、默认的 ConversionService、取消 %2F -> / 的解码return new SpringMvcContract(Collections.emptyList(), new DefaultConversionService(), Boolean.FALSE);}}

decodeSlash，直译就是“斜杠解码”

encode: / → %2F
decode: %2F → /

而我们就是阻止 %2F → / ，那我们为什么要阻止呢？

问题分析

首先我们可能会想，它是如何转义的，是传入的时候转义，还是最终一起转义：

如果是最终一起转义，那 / 必然不能被转义，否则那些路由都会失效，所以如果是最终转义，无法满足我们的需求：

这里写了个简单的方法，方便理解

public static <P> String buildUrl(String baseUrl, Map<String, List<String>> queryParams, Map<String, P> pathParams) {queryParams = Optional.ofNullable(queryParams).orElseGet(Map::of);pathParams = Optional.ofNullable(pathParams).orElseGet(Map::of);return UriComponentsBuilder.fromHttpUrl(baseUrl).queryParams(new LinkedMultiValueMap<>(queryParams)).buildAndExpand(pathParams).encode() // 开启译码模式.toUriString();
}

如果在传入的时候转义，才能实现我们的效果：

public static <P> String buildUrl(String baseUrl, Map<String, List<String>> queryParams, Map<String, P> pathParams) {queryParams = Optional.ofNullable(queryParams).orElseGet(Map::of);pathParams = Optional.ofNullable(pathParams).orElseGet(Map::of);return UriComponentsBuilder.fromHttpUrl(baseUrl).encode() // 开启译码模式，这里之后路径参数，/ 也会被转义为 %2F！.queryParams(new LinkedMultiValueMap<>(queryParams)).buildAndExpand(pathParams).toUriString();
}