內(nèi)容

• 異常場(chǎng)景
• 異常信息
• 原因
• 解決方案
• 相關(guān)鏈接

異常場(chǎng)景

spring boot+Restful API

在使用quarzt的時(shí)候,我想要在調(diào)用相關(guān)api接口時(shí)能夠返回job的trigger信息

于是我在自定義的job bean中加了如下代碼

@Transient
private Trigger trigger;

public void setTrigger(Trigger trigger) {
    this.trigger = trigger;
}

public Trigger getTrigger() {
    return this.trigger;
}

當(dāng)然,這里我是偷懶,直接用的Trigger類型(這個(gè)習(xí)慣并不好,因?yàn)槲覍?duì)Trigger的數(shù)據(jù)結(jié)構(gòu)一開(kāi)始并不熟悉)

果然,我在調(diào)用相關(guān)接口的時(shí)候,出現(xiàn)了異常

異常信息

(https://github.com/prestodb/presto/issues/8457 與這個(gè)問(wèn)題相同)

com.fasterxml.jackson.databind.JsonMappingException: No serializer found for class org.quartz.JobBuilder and no properties discovered to create BeanSerializer (to avoid exception, disable SerializationFeature.FAIL_ON_EMPTY_BEANS) (through reference chain: net.skycloud.nap.common.vo.PageInfo["list"]->java.util.ArrayList[0]->net.skycloud.nap.job.model.Job["jobDetailMessage"]->org.quartz.impl.JobDetailImpl["jobBuilder"])
    com.fasterxml.jackson.databind.JsonMappingException.from(JsonMappingException.java:284)
    com.fasterxml.jackson.databind.SerializerProvider.mappingException(SerializerProvider.java:1110)
    com.fasterxml.jackson.databind.SerializerProvider.reportMappingProblem(SerializerProvider.java:1135)
    com.fasterxml.jackson.databind.ser.impl.UnknownSerializer.failForEmpty(UnknownSerializer.java:69)
    com.fasterxml.jackson.databind.ser.impl.UnknownSerializer.serialize(UnknownSerializer.java:32)
    com.fasterxml.jackson.databind.ser.BeanPropertyWriter.serializeAsField(BeanPropertyWriter.java:704)
    com.fasterxml.jackson.databind.ser.std.BeanSerializerBase.serializeFields(BeanSerializerBase.java:690)
    com.fasterxml.jackson.databind.ser.BeanSerializer.serialize(BeanSerializer.java:155)
    com.fasterxml.jackson.databind.ser.BeanPropertyWriter.serializeAsField(BeanPropertyWriter.java:704)
    com.fasterxml.jackson.databind.ser.std.BeanSerializerBase.serializeFields(BeanSerializerBase.java:690)
    com.fasterxml.jackson.databind.ser.BeanSerializer.serialize(BeanSerializer.java:155)
    com.fasterxml.jackson.databind.ser.impl.IndexedListSerializer.serializeContents(IndexedListSerializer.java:119)
    com.fasterxml.jackson.databind.ser.impl.IndexedListSerializer.serialize(IndexedListSerializer.java:79)
    com.fasterxml.jackson.databind.ser.impl.IndexedListSerializer.serialize(IndexedListSerializer.java:18)
    com.fasterxml.jackson.databind.ser.BeanPropertyWriter.serializeAsField(BeanPropertyWriter.java:704)
    com.fasterxml.jackson.databind.ser.std.BeanSerializerBase.serializeFields(BeanSerializerBase.java:690)
    com.fasterxml.jackson.databind.ser.BeanSerializer.serialize(BeanSerializer.java:155)
    com.fasterxml.jackson.databind.ser.DefaultSerializerProvider.serializeValue(DefaultSerializerProvider.java:292)
    com.fasterxml.jackson.databind.ObjectWriter$Prefetch.serialize(ObjectWriter.java:1429)
    com.fasterxml.jackson.databind.ObjectWriter.writeValue(ObjectWriter.java:951)
    org.springframework.http.converter.json.AbstractJackson2HttpMessageConverter.writeInternal(AbstractJackson2HttpMessageConverter.java:279)
    org.springframework.http.converter.AbstractGenericHttpMessageConverter.write(AbstractGenericHttpMessageConverter.java:106)
    org.springframework.web.servlet.mvc.method.annotation.AbstractMessageConverterMethodProcessor.writeWithMessageConverters(AbstractMessageConverterMethodProcessor.java:231)
    org.springframework.web.servlet.mvc.method.annotation.RequestResponseBodyMethodProcessor.handleReturnValue(RequestResponseBodyMethodProcessor.java:174)
    org.springframework.web.method.support.HandlerMethodReturnValueHandlerComposite.handleReturnValue(HandlerMethodReturnValueHandlerComposite.java:81)
    org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:113)
    org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:827)
    org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:738)
    org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:85)
    org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:963)
    org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:897)
    org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:970)
    org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:861)
    javax.servlet.http.HttpServlet.service(HttpServlet.java:635)
    org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:846)
    javax.servlet.http.HttpServlet.service(HttpServlet.java:742)
    org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:52)
    org.springframework.boot.web.filter.ApplicationContextHeaderFilter.doFilterInternal(ApplicationContextHeaderFilter.java:55)
    org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)
    org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:101)
    net.skycloud.nap.auth.security.AuthFilter.doFilterInternal(AuthFilter.java:109)
    org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)
    org.springframework.boot.actuate.trace.WebRequestTraceFilter.doFilterInternal(WebRequestTraceFilter.java:110)
    org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)
    org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:317)
    org.springframework.security.web.access.intercept.FilterSecurityInterceptor.invoke(FilterSecurityInterceptor.java:127)
    org.springframework.security.web.access.intercept.FilterSecurityInterceptor.doFilter(FilterSecurityInterceptor.java:91)
    org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331)
    org.springframework.security.web.access.ExceptionTranslationFilter.doFilter(ExceptionTranslationFilter.java:114)
    org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331)
    org.springframework.security.web.session.SessionManagementFilter.doFilter(SessionManagementFilter.java:137)
    org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331)
    org.springframework.security.web.authentication.AnonymousAuthenticationFilter.doFilter(AnonymousAuthenticationFilter.java:111)
    org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331)
    org.springframework.security.web.servletapi.SecurityContextHolderAwareRequestFilter.doFilter(SecurityContextHolderAwareRequestFilter.java:170)
    org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331)
    org.springframework.security.web.savedrequest.RequestCacheAwareFilter.doFilter(RequestCacheAwareFilter.java:63)
    org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331)
    net.skycloud.nap.auth.security.AuthFilter.doFilterInternal(AuthFilter.java:109)
    org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)
    org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331)
    org.springframework.security.web.authentication.logout.LogoutFilter.doFilter(LogoutFilter.java:116)
    org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331)
    org.springframework.security.web.header.HeaderWriterFilter.doFilterInternal(HeaderWriterFilter.java:64)
    org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)
    org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331)
    org.springframework.security.web.context.SecurityContextPersistenceFilter.doFilter(SecurityContextPersistenceFilter.java:105)
    org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331)
    org.springframework.security.web.context.request.async.WebAsyncManagerIntegrationFilter.doFilterInternal(WebAsyncManagerIntegrationFilter.java:56)
    org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)
    org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331)
    org.springframework.security.web.FilterChainProxy.doFilterInternal(FilterChainProxy.java:214)
    org.springframework.security.web.FilterChainProxy.doFilter(FilterChainProxy.java:177)
    org.springframework.web.filter.DelegatingFilterProxy.invokeDelegate(DelegatingFilterProxy.java:346)
    org.springframework.web.filter.DelegatingFilterProxy.doFilter(DelegatingFilterProxy.java:262)
    org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:99)
    org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)
    org.springframework.web.filter.HttpPutFormContentFilter.doFilterInternal(HttpPutFormContentFilter.java:105)
    org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)
    org.springframework.web.filter.HiddenHttpMethodFilter.doFilterInternal(HiddenHttpMethodFilter.java:81)
    org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)
    org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:197)
    org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)
    org.springframework.boot.actuate.autoconfigure.MetricsFilter.doFilterInternal(MetricsFilter.java:106)
    org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)

原因

首先讓我們看一下spring boot創(chuàng)建restful 風(fēng)格的api時(shí)他是怎么做的

• 通過(guò)controller 方法返回的值類型找到相應(yīng)的bean
• 通過(guò)bean中的get方法獲得json格式的數(shù)據(jù),這就是接口返回的http reponse body
• ....

也就是說(shuō)框架在返回http reponse的時(shí)候需要將接口對(duì)應(yīng)的方法返回值轉(zhuǎn)成json格式

而出現(xiàn)上面異常信息的原因就是框架無(wú)法直接將Trigger對(duì)象轉(zhuǎn)成相應(yīng)的json格式

解決方案

解決方案有三種

• 一.在定義一個(gè)bean,專門用來(lái)存放trigger的信息,并且這個(gè)bean可以被框架轉(zhuǎn)成json格式

  class TriggerBean{
      //自己對(duì)Trigger信息提取封裝
  }
  
  @Transient
  private TriggerBean triggerBean;
  
  public void setTriggerBean(TriggerBean triggerBean) {
      this.triggerBean = triggerBean;
  }
  
  public TriggerBean getTriggerBean() {
      return this.triggerBean;
  }
  

• 二.直接定義triggerInfo屬性類型,在set的時(shí)候?qū)rigger中的信息提取出,當(dāng)然,我這里的List<Map<String,Object>>類型只是因?yàn)樾枨?不同需求就會(huì)有不同類型

  @Transient
  private List<Map<String,Object>> triggerInfo;
  
  public List<Map<String,Object>> setTriggerInfo(TriggerInfo triggerInfo) {
      this.triggerInfo = triggerInfo;
  }
  
  public List<Map<String,Object>> getTriggerInfo() {
      return this.triggerInfo;
  }
  

• 三.如果此時(shí)我想在這個(gè)job類中有這個(gè)Trigger屬性,又想在接口返回其有用信息怎么辦呢

  在異常原因可以看見(jiàn)框架是通過(guò)bean的get方法轉(zhuǎn)化成相應(yīng)的json,在這里我們可以通過(guò)@JsonIgnore注解使得框架不返回getTrigger方法對(duì)應(yīng)的屬性,再使用@JsonProperty("trigger")注解,這樣框架就會(huì)將getTriggerInfo方法對(duì)應(yīng)的屬性轉(zhuǎn)化成json中trigger字段對(duì)應(yīng)的數(shù)據(jù)(關(guān)于這兩個(gè)注解可以了解一下)

  @Transient
  private Trigger trigger;
  public void setTrigger(Trigger trigger) {
      this.trigger = trigger;
  }
  @JsonIgnore
  public Trigger getTrigger() {
      return this.trigger;
  }
  
  @Transient
  private List<Map<String,Object>> triggerInfo;
  public List<Map<String,Object>> setTriggerInfo(TriggerInfo triggerInfo) {
      this.triggerInfo = triggerInfo;
  }
  @JsonProperty("trigger")
  public List<Map<String,Object>> getTriggerInfo() {
      return this.triggerInfo;
  }
  

  相關(guān)鏈接

  https://github.com/prestodb/presto/issues/8457