Spring Boot添加消息转换器HttpMessageConverter

简介: spring boot添加消息转换器HttpMessageConverter

问题

Spring Boot项目开发过程中,前后端分离的项目,前后端通过json的数据格式交互,接口采用@ResponseBody注解返回json数据,如果接口返回的数据类型是String,会导致中文乱码。

原因

因为我们的Http消息转换都是通过spring框架定义的消息转换器进行转换的,不同类型的消息有不同的消息类型转换器处理。大概如下:

StringHttpMessageConverter的作用:负责读取字符串格式的数据和写出二进制格式的数据(当返回值是或者接受值是String类型时,是由这个处理)

MappingJacksonHttpMessageConverter:负责读取和写入json格式的数据;(当返回值是对象或者List,就由这个处理)

ByteArrayHttpMessageConverter:负责读取二进制格式的数据和写出二进制格式的数据;

FormHttpMessageConverter:负责读取form提交的数据(能读取的数据格式为 application/x-www-form-urlencoded,不能读取multipart/form-data格式数据);负责写入application/x-www-from-urlencoded和multipart/form-data格式的数据;ResourceHttpMessageConverter:负责读取资源文件和写出资源文件数据;

SourceHttpMessageConverter:负责读取和写入 xml 中javax.xml.transform.Source定义的数据;

Jaxb2RootElementHttpMessageConverter:负责读取和写入xml 标签格式的数据;

AtomFeedHttpMessageConverter: 负责读取和写入Atom格式的数据;

RssChannelHttpMessageConverter: 负责读取和写入RSS格式的数据;

当我们的响应数据是string类型是,框架自动识别到消息类型(MediaType),会采用StringHttpMessageConverter进行消息转换,但是StringHttpMessageConverter默认的字符集是ISO-8859-1,这就导致了响应头中Content-Type为"xxx;charset=ISO-8859-1"。所以导致中文乱码

解决

  • @ReqeustMapping中指定produces属性:produces="application/json;charset=UTF-8"
  • 添加消息转换器StringHttpMessageConverter,自己创建消息转换器,并制定编码集为:UTF-8
@ConfigurationpublicclassWebConfigextendsWebMvcConfigurationSupport {
@BeanpublicHttpMessageConverter<String>responseBodyConverter() {
// 框架默认的StringHttpMessageConverter编码是ISO-8859-1,@Response注解当接口返回的是字符串时会中文乱码returnnewStringHttpMessageConverter(Charset.forName("UTF-8"));
    }
/*** 消息转换器* @param converters*/@OverrideprotectedvoidextendMessageConverters(List<HttpMessageConverter<?>>converters) {
super.extendMessageConverters(converters);
// 请注意顺序,因为其实底层就是用list进行存储的所有可以通过指定下标来指定顺序// 目前这种写法可以解决问题,但是因为我们指定的StringHttpMessageConverter// 框架也指定了StringHttpMessageConverter,所有我们要将自己的排在前面,否者依然无法使用自定义的消息转换器converters.add(0, responseBodyConverter());
    }
}

源码

Spring Boot或者说Spring或者说SpringMVC之所以能将http请求消息映射成我们controller接口的方法参数的实体,以及将响应结果转换成http消息,是因为框架Spring框架定义了很多的消息转换器,流程如下:

image.png

消息转换器都是实现了HttpMessageConverter接口的java类。HttpMessageConverter共有如下几个方法,,方法的大概意思见注释,中文注释仅供参考,详情见英文注释。

publicinterfaceHttpMessageConverter<T> {
/*** Indicates whether the given class can be read by this converter.* @param clazz the class to test for readability* @param mediaType the media type to read (can be {@code null} if not specified);* typically the value of a {@code Content-Type} header.* @return {@code true} if readable; {@code false} otherwise*/// 是否支持读mediaType类型的消息booleancanRead(Class<?>clazz, @NullableMediaTypemediaType);
/*** Indicates whether the given class can be written by this converter.* @param clazz the class to test for writability* @param mediaType the media type to write (can be {@code null} if not specified);* typically the value of an {@code Accept} header.* @return {@code true} if writable; {@code false} otherwise*/// 是否支持写mediaType类型的消息booleancanWrite(Class<?>clazz, @NullableMediaTypemediaType);
/*** Return the list of {@link MediaType} objects supported by this converter.* @return the list of supported media types, potentially an immutable copy*/// 支持消息类型集合List<MediaType>getSupportedMediaTypes();
/*** Read an object of the given type from the given input message, and returns it.* @param clazz the type of object to return. This type must have previously been passed to the* {@link #canRead canRead} method of this interface, which must have returned {@code true}.* @param inputMessage the HTTP input message to read from* @return the converted object* @throws IOException in case of I/O errors* @throws HttpMessageNotReadableException in case of conversion errors*/// 具体实现读,这里可以修改我们的请求消息Tread(Class<?extendsT>clazz, HttpInputMessageinputMessage)
throwsIOException, HttpMessageNotReadableException;
/*** Write an given object to the given output message.* @param t the object to write to the output message. The type of this object must have previously been* passed to the {@link #canWrite canWrite} method of this interface, which must have returned {@code true}.* @param contentType the content type to use when writing. May be {@code null} to indicate that the* default content type of the converter must be used. If not {@code null}, this media type must have* previously been passed to the {@link #canWrite canWrite} method of this interface, which must have* returned {@code true}.* @param outputMessage the message to write to* @throws IOException in case of I/O errors* @throws HttpMessageNotWritableException in case of conversion errors*/// 具体实现写,可以修改我们的响应消息voidwrite(Tt, @NullableMediaTypecontentType, HttpOutputMessageoutputMessage)
throwsIOException, HttpMessageNotWritableException;
}

具体有如下几种实现:之所以有图和代码,是方便读者看见的时候如果想看源码可以方便粘贴代码到开发工具中(如idea)进行搜索。

publicabstractclassAbstractHttpMessageConverter<T>implementsHttpMessageConverter<T>{
// ......}
publicclassFormHttpMessageConverterimplementsHttpMessageConverter<MultiValueMap<String, ?>> {
// ......}
publicclassBufferedImageHttpMessageConverterimplementsHttpMessageConverter<BufferedImage>// ......}
publicinterfaceGenericHttpMessageConverter<T>extendsHttpMessageConverter<T> {
// ...... }

image.png

传统的业务接口代码常用的两种Http消息转换器有两种一种是字符串转换器一种是JSON转换器,分别对应StringHttpMessageConverter和MappingJackson2HttpMessageConverter。

StringHttpMessageConverter继承AbstractHttpMessageConverter<string>,AbstractHttpMessageConverter<string>实现HttpMessageConverter<T>如上图和上面的代码

publicclassStringHttpMessageConverterextendsAbstractHttpMessageConverter<String> {
// ...... } 

MappingJackson2HttpMessageConverter和HttpMessageConverter的关系就比较深一些,直接上图:

image.png

publicclassMappingJackson2HttpMessageConverterextendsAbstractJackson2HttpMessageConverter {
// ......}

如果我们要添加自己的消息转换器到框架中,那么我们就应该知道消息转换器是什么时候在哪里被创建的。

消息转换器是在项目启动的时候通过WebMvcConfigurationSupport进行加载,当getMessageConverters被调用的时候会通过configureMessageConverters、addDefaultHttpMessageConverters和extendMessageConverters三个方法进行初始话消息转换器。生成的消息转换器放在 List<HttpMessageConverter<?>> messageConverters集合中。

系统默认加载的消息转换器就是在addDefaultHttpMessageConverters方法中加载的。

publicclassWebMvcConfigurationSupportimplementsApplicationContextAware, ServletContextAware {
// ......// 初始话消息转换器集合protectedfinalList<HttpMessageConverter<?>>getMessageConverters() {
if (this.messageConverters==null) {
this.messageConverters=newArrayList<>();
// 1、加载消息转换器configureMessageConverters(this.messageConverters);
if (this.messageConverters.isEmpty()) {
// 2、如果消息转换器集合为空那么久系统默认加载addDefaultHttpMessageConverters(this.messageConverters);
            }
// 3、扩展开发者自己的加载器extendMessageConverters(this.messageConverters);
        }
returnthis.messageConverters;
    }
protectedfinalvoidaddDefaultHttpMessageConverters(List<HttpMessageConverter<?>>messageConverters) {
messageConverters.add(newByteArrayHttpMessageConverter());
messageConverters.add(newStringHttpMessageConverter());
messageConverters.add(newResourceHttpMessageConverter());
messageConverters.add(newResourceRegionHttpMessageConverter());
try {
messageConverters.add(newSourceHttpMessageConverter<>());
        }
catch (Throwableex) {
// Ignore when no TransformerFactory implementation is available...        }
messageConverters.add(newAllEncompassingFormHttpMessageConverter());
if (romePresent) {
messageConverters.add(newAtomFeedHttpMessageConverter());
messageConverters.add(newRssChannelHttpMessageConverter());
        }
if (jackson2XmlPresent) {
Jackson2ObjectMapperBuilderbuilder=Jackson2ObjectMapperBuilder.xml();
if (this.applicationContext!=null) {
builder.applicationContext(this.applicationContext);
            }
messageConverters.add(newMappingJackson2XmlHttpMessageConverter(builder.build()));
        }
elseif (jaxb2Present) {
messageConverters.add(newJaxb2RootElementHttpMessageConverter());
        }
if (jackson2Present) {
Jackson2ObjectMapperBuilderbuilder=Jackson2ObjectMapperBuilder.json();
if (this.applicationContext!=null) {
builder.applicationContext(this.applicationContext);
            }
messageConverters.add(newMappingJackson2HttpMessageConverter(builder.build()));
        }
elseif (gsonPresent) {
messageConverters.add(newGsonHttpMessageConverter());
        }
elseif (jsonbPresent) {
messageConverters.add(newJsonbHttpMessageConverter());
        }
if (jackson2SmilePresent) {
Jackson2ObjectMapperBuilderbuilder=Jackson2ObjectMapperBuilder.smile();
if (this.applicationContext!=null) {
builder.applicationContext(this.applicationContext);
            }
messageConverters.add(newMappingJackson2SmileHttpMessageConverter(builder.build()));
        }
if (jackson2CborPresent) {
Jackson2ObjectMapperBuilderbuilder=Jackson2ObjectMapperBuilder.cbor();
if (this.applicationContext!=null) {
builder.applicationContext(this.applicationContext);
            }
messageConverters.add(newMappingJackson2CborHttpMessageConverter(builder.build()));
        }
    }
// ......}

下图是我们自己添加了一个消息转换器后消息转换器的集合和框架默认的消息转换器的集合对比

image.png

小结

根据以上所述,知道了消息转换器的加载顺,所有我们可以通过继承WebMvcConfigurationSupport类,重extendMessageConverters方法实现添加自己的消息转换器。

调用

HttpMessageConverter的调用是RequestResponseBodyMethodProcessor类的解析请求参数的方法resolveArgument和处理返回值的方法handleReturnValue中进行调用的。这是关于@RequestBody和@ResponseBody两个注解的原理,有兴趣的可以去翻一翻源码。

目录
相关文章
|
6月前
|
Java 应用服务中间件 Maven
SpringBoot 项目瘦身指南
SpringBoot 项目瘦身指南
145 0
|
6月前
SpringBoot+Mybatis-Plus+PageHelper分页+多条件查询
SpringBoot+Mybatis-Plus+PageHelper分页+多条件查询
165 0
|
6天前
|
存储 运维 安全
Spring运维之boot项目多环境(yaml 多文件 proerties)及分组管理与开发控制
通过以上措施,可以保证Spring Boot项目的配置管理在专业水准上,并且易于维护和管理,符合搜索引擎收录标准。
17 2
|
1月前
|
SQL JSON Java
mybatis使用三:springboot整合mybatis,使用PageHelper 进行分页操作,并整合swagger2。使用正规的开发模式:定义统一的数据返回格式和请求模块
这篇文章介绍了如何在Spring Boot项目中整合MyBatis和PageHelper进行分页操作,并且集成Swagger2来生成API文档,同时定义了统一的数据返回格式和请求模块。
54 1
mybatis使用三:springboot整合mybatis,使用PageHelper 进行分页操作,并整合swagger2。使用正规的开发模式:定义统一的数据返回格式和请求模块
|
1月前
|
缓存 NoSQL Java
Springboot自定义注解+aop实现redis自动清除缓存功能
通过上述步骤,我们不仅实现了一个高度灵活的缓存管理机制,还保证了代码的整洁与可维护性。自定义注解与AOP的结合,让缓存清除逻辑与业务逻辑分离,便于未来的扩展和修改。这种设计模式非常适合需要频繁更新缓存的应用场景,大大提高了开发效率和系统的响应速度。
58 2
|
5月前
|
运维 Java 关系型数据库
Spring运维之boot项目bean属性的绑定读取与校验
Spring运维之boot项目bean属性的绑定读取与校验
54 2
|
5月前
|
存储 运维 Java
Spring运维之boot项目开发关键之日志操作以及用文件记录日志
Spring运维之boot项目开发关键之日志操作以及用文件记录日志
63 2
|
5月前
|
Java Maven
springboot项目打jar包后,如何部署到服务器
springboot项目打jar包后,如何部署到服务器
423 1
|
5月前
|
XML 运维 Java
Spring运维之boot项目打包jar和插件运行并且设置启动时临时属性和自定义配置文件
Spring运维之boot项目打包jar和插件运行并且设置启动时临时属性和自定义配置文件
54 1
|
5月前
springboot2.4.5使用pagehelper分页插件
springboot2.4.5使用pagehelper分页插件
152 0