環(huán)境:
jdk: 8
spring-boot: 2.x
一、問(wèn)題描述
- 在spring-boot 項(xiàng)目中使用RestTemplate和AsyncRestTemplate,RestTemplate發(fā)送請(qǐng)求時(shí)不會(huì)出現(xiàn)亂碼,但是AsyncRestTemplate會(huì)出現(xiàn)亂碼情況
二、問(wèn)題分析
- 首先想到是加請(qǐng)求頭
application/json;charset=utf-8, RestTemplate沒問(wèn)題,AsyncRestTemplate依舊亂碼。
HttpHeaders headers = new HttpHeaders();
// 等價(jià) ContentType: application/json;charset=utf-8
headers.add(HttpHeaders.CONTENT_TYPE, ContentType.APPLICATION_JSON.getMimeType());
asyncRestTemplate.postForEntity(url, new HttpEntity<>(data,headers), ResponseModel.class);
- 斷點(diǎn)查看 MessageConverters
- RestTemplate : 有兩個(gè)
StringHttpMessageConverter,分別對(duì)應(yīng)UTF-8和ISO-8859-1編碼
RestTemplate - AsyncRestTemplate : 只有一個(gè)
StringHttpMessageConverter,對(duì)應(yīng)ISO-8859-1編碼
AsyncRestTemplate
綜上所述,可以看到 AsyncRestTemplate 默認(rèn)缺少 utf-8 的解析器 , 所以造成無(wú)法編碼成utf-8
三、解決方式 (兩種方式差不多)
- 增加一個(gè) UTF-8 解析器 (第一種)
private AsyncRestTemplate asyncRestTemplate ;
@PostConstruct
public void init(){
asyncRestTemplate = new AsyncRestTemplate() ;
// 增加一個(gè) utf-8 解析器
asyncRestTemplate.getMessageConverters().add(0, new StringHttpMessageConverter(Charset.forName("UTF-8")));
}
- 刪除原有的 StringHttpMessageConverter , 然后重新添加 UTF-8 解析器 (第二種)
private AsyncRestTemplate asyncRestTemplate ;
@PostConstruct
public void init(){
asyncRestTemplate = new AsyncRestTemplate() ;
// 刪除所有的 StringHttpMessageConverter
Iterator<HttpMessageConverter<?>> iterator = asyncRestTemplate.getMessageConverters().iterator();
while (iterator.hasNext()) {
final HttpMessageConverter<?> converter = iterator.next();
if (converter instanceof StringHttpMessageConverter) {
iterator.remove();
}
}
// 添加 UTF-8 的解析器
asyncRestTemplate.getMessageConverters().add(0, new StringHttpMessageConverter(Charset.forName("UTF-8")));
}
注意 :增加解析器后,最好在 post、put、delete 請(qǐng)求增加contentType 頭信息,類似如下
HttpHeaders headers = new HttpHeaders();
// 等價(jià) ContentType: application/json;charset=utf-8
headers.add(HttpHeaders.CONTENT_TYPE, ContentType.APPLICATION_JSON.getMimeType());
asyncRestTemplate.postForEntity(url, new HttpEntity<>(data,headers), ResponseModel.class);

