Spring 默认消费和生产

Posted

技术标签:

【中文标题】Spring 默认消费和生产【英文标题】:Spring default consumes and produces 【发布时间】:2019-06-21 16:51:10 【问题描述】:

我正在编写一个 servlet,它将使用一堆 RestController 来提供功能。

所有这些都将几乎完全使用 JSON,所以我想用一种简洁的方式说:除非另有说明,否则为所有内容使用并生成 MediaType.APPLICATION_JSON_VALUE。

我以为我找到了一个不错的解决方案on another SO question。

但是,正如a comment there 中已经指出的那样,这种解决方案会引起麻烦。

@RestController
@RequestMapping(value = "/relationship/type", consumes = MediaType.APPLICATION_JSON_VALUE, produces = MediaType.APPLICATION_JSON_VALUE, method = 
        RequestMethod.GET
     )
public class DRelationshipTypeResource 

    // @GetMapping("/all")
    @RequestMapping(value = "/all", method = RequestMethod.GET)
    public List<DRelationshipTypeDTO> getAll() 
        return DRelationshipTypeService.getAll();
    

此控制器还将具有 POST/PUT/DELETE 以及更多 GET 功能。我暂时删除了它们以尽量减少可能的错误原因。

调用此路由会产生 415 错误。

更糟糕的是,我真的很想能够使用

@GetMapping("/all")

而不是更详细的 getAll() 方法的 @RequestMapping 重载,但这也会产生相同的 415 错误。

当请求到达时,服务器调试控制台会输出这个:

2019-01-29 10:20:54.627  WARN 10712 --- [io-9999-exec-10] .w.s.m.s.DefaultHandlerExceptionResolver : Resolved [org.springframework.web.HttpMediaTypeNotSupportedException: Content type '' not supported]

2019-01-29 10:20:54.628 ERROR 10712 --- [io-9999-exec-10] o.a.c.c.C.[Tomcat].[localhost]           : Exception Processing ErrorPage[errorCode=0, location=/error]

java.lang.NoSuchMethodError: javax.servlet.http.HttpServletRequest.getHttpServletMapping()Ljavax/servlet/http/HttpServletMapping;
    at org.apache.catalina.core.ApplicationHttpRequest.setRequest(ApplicationHttpRequest.java:690) ~[tomcat-embed-core-9.0.14.jar:9.0.14]
    at org.apache.catalina.core.ApplicationHttpRequest.<init>(ApplicationHttpRequest.java:114) ~[tomcat-embed-core-9.0.14.jar:9.0.14]
    at org.apache.catalina.core.ApplicationDispatcher.wrapRequest(ApplicationDispatcher.java:917) ~[tomcat-embed-core-9.0.14.jar:9.0.14]
    at org.apache.catalina.core.ApplicationDispatcher.doForward(ApplicationDispatcher.java:358) ~[tomcat-embed-core-9.0.14.jar:9.0.14]
    at org.apache.catalina.core.ApplicationDispatcher.forward(ApplicationDispatcher.java:312) ~[tomcat-embed-core-9.0.14.jar:9.0.14]
    at org.apache.catalina.core.StandardHostValve.custom(StandardHostValve.java:394) [tomcat-embed-core-9.0.14.jar:9.0.14]
    at org.apache.catalina.core.StandardHostValve.status(StandardHostValve.java:253) [tomcat-embed-core-9.0.14.jar:9.0.14]
    at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:175) [tomcat-embed-core-9.0.14.jar:9.0.14]
    at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92) [tomcat-embed-core-9.0.14.jar:9.0.14]
    at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:74) [tomcat-embed-core-9.0.14.jar:9.0.14]
    at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:343) [tomcat-embed-core-9.0.14.jar:9.0.14]
    at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:408) [tomcat-embed-core-9.0.14.jar:9.0.14]
    at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66) [tomcat-embed-core-9.0.14.jar:9.0.14]
    at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:834) [tomcat-embed-core-9.0.14.jar:9.0.14]
    at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1417) [tomcat-embed-core-9.0.14.jar:9.0.14]
    at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49) [tomcat-embed-core-9.0.14.jar:9.0.14]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [na:1.8.0_181]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_181]
    at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) [tomcat-embed-core-9.0.14.jar:9.0.14]
    at java.lang.Thread.run(Thread.java:748) [na:1.8.0_181]

并向发出请求的客户端返回 HTTP 状态 415 – 不支持的媒体类型。

为了进一步澄清,如果我使用这样的“哑”类,一切正常,内容正确返回为 JSON。

@RestController
@RequestMapping("relationship/type")
public class DRelationshipTypeResource 

    @GetMapping("/all")
    public List<DRelationshipTypeDTO> getAll() 
        return DRelationshipTypeService.getAll();
    

【问题讨论】:

你怎么称呼这个?并发布任何相关的堆栈跟踪? 检查您的消息转换器,并检查此答案***.com/questions/54400807/… 我更新了 OP 以澄清事情。感谢您的垂询!由于上面的代码示例正确返回了内容,我认为 JSON 转换本身不是问题。 您能否添加有关您如何拨打电话的详细信息?以及您用于测试的客户端。并添加错误的完整堆栈跟踪 经过测试的客户端是 Postman 和浏览器(经过测试的 IE、Firefox、Chrome),对 localhost:9999/api/relationship/type/all 进行了简单的调用。不确定您还需要什么?以上是完整的堆栈跟踪,调用路由时没有记录任何其他内容。 【参考方案1】:

缺少在路径开头添加/并添加方法类型GET:

@RequestMapping(value = "/relationship/type", 
                consumes = MediaType.APPLICATION_JSON_VALUE, 
                produces = MediaType.APPLICATION_JSON_VALUE,
                method = RequestMethod.GET))

【讨论】:

感谢您的评论。开头的“/”不是必需的(没有它也可以正常工作),但为了保持一致性,我应该添加它,我同意。将方法添加到上面的 RequestMapping 并没有以任何方式或形状改变响应,遗憾的是,我仍然得到相同的堆栈跟踪和 415 错误。 补充:在类级别的 RequestMapping 上拥有方法类型对任何一种方式都没有影响。没有它们也能正常工作。【参考方案2】:

作为堆栈跟踪,清楚地告诉 content-type 是空的('')。 我认为进行 GET 调用时没有传递 Content-Type 。如果您将 Content-Type 作为 'application/json' 传递,它应该可以工作。

您已经在类级别定义了消费和生产,这意味着默认情况下,所有 REST 服务都应该传递标头、Content-Type 和 Accept 才能使用该服务。

【讨论】:

解决方案是添加“Content-Type”标头。 Accept 无关紧要(之前尝试过)。我从 JaxRS 切换过来,它的设置非常相似,但 JaxRS 不会抱怨缺少标题,它只是提供在“produces”中定义的第一个,如果没有内容类型的标题存在。感谢您的帮助。 接受,没关系,因为它主要用于客户端,我猜 另外,这个控制器中的所有请求都是GET类型的。【参考方案3】:

问题在于我的请求没有明确包含 Content-Type application/json 标头,正如 https://***.com/a/54418436/2436002 所指出的那样。

为了澄清一些关于这一切的明显错误信息,现在一切都按我预期的那样工作,代码非常易读、干净且类似弹簧。也许它可以帮助其他人寻找一个例子。

@RestController
@RequestMapping(value = "relationship/type", consumes = MediaType.APPLICATION_JSON_VALUE, produces = MediaType.APPLICATION_JSON_VALUE)
public class DRelationshipTypeResource 

    @GetMapping("/all")
    public List<DRelationshipTypeDTO> getAll() 
        return DRelationshipTypeService.getAll();
    

    @GetMapping("/query")
    public DRelationshipTypeDTO get(@PathVariable("query") String query) 
        return DRelationshipTypeService.get(query);
    

    @PostMapping
    public ResponseEntity<Void> create(DRelationshipTypeDTO dto) 
        String label = DRelationshipTypeService.create(dto);
        URI uri = ServletUriComponentsBuilder.fromCurrentRequest().path("/label").buildAndExpand(label).toUri();
        return ResponseEntity.created(uri).build();
    

    @PutMapping("label")
    public ResponseEntity<Void> update(@PathVariable("label") String label, DRelationshipTypeDTO dto) 
        DRelationshipTypeService.update(label, dto);
        return ResponseEntity.noContent().build();
    

    @DeleteMapping("label")
    public ResponseEntity<Void> delete(@PathVariable("label") String label) 
        DRelationshipTypeService.delete(label);
        return ResponseEntity.noContent().build();
    

尚未 100% 了解在 POST /Create 期间构建 URI 的最佳方法,但这是一个不同的问题,它至少可以正常工作(HTTP201 响应的正确位置标头)。

【讨论】:

【参考方案4】:

要接受所有请求类型,只需覆盖消耗值。

@RequestMapping(value = "/all", consumes="*/*", method = RequestMethod.GET)
    public List<DRelationshipTypeDTO> getAll() 
        return DRelationshipTypeService.getAll();
    

【讨论】:

以上是关于Spring 默认消费和生产的主要内容,如果未能解决你的问题,请参考以下文章

Spring Cloud Stream的分区和分组

spring整合kafka项目生产和消费测试结果记录

Spring Cloud Stream如何消费自己生产的消息

Spring Boot整合Pulsar生产和消费消息 简单示例代码

Spring Boot整合Pulsar生产和消费消息 简单示例代码

Spring整合kafka消费者和生产者&redis的步骤