“spring webflux所有API都报UnsupportedMediaTypeException错误。”

huangapple
go评论184阅读模式
英文:

spring webflux all api's giving UnsupportedMediaTypeException

问题

  1. 我有一个`@SpringBootApplication`，使用Gson而不是Jackson，以下是使用以下转换器的代码：
  3. ```java
  4. @Configuration
  5. public class ApplicationConfiguration {
  7.     @Bean
  8.     public GsonBuilder gsonBuilder(){
  9.         final GsonBuilder gsonBuilder = new GsonBuilder();
  10.         // 在这里注册TypeAdapter
  11.         return gsonBuilder;
  12.     }
  13. }

现在我有一个控制器（所有控制器都会失败，不仅是这个，但它们的语法相同）：

  1. @RestController("/1/api/release/")
  2. @Log
  3. @RequiredArgsConstructor
  4. public class ReleaseController {
  6.    @PostMapping("blocked")
  7.    public Mono<ServerResponse> issueIsBlocked() {
  8.        return Mono.just("test")
  9.                .flatMap(s -> ServerResponse.ok().bodyValue(s))
  10.                .onErrorResume(Throwable.class, e -> ServerResponse.status(HttpStatus.INTERNAL_SERVER_ERROR).bodyValue(e.getMessage()));
  11.    }
  12. }

而且application.properties包含：

  1. spring.http.converters.preferred-json-mapper=gson
  2. spring.codec.max-in-memory-size=10MB

然而，我得到了这个错误：

  1. org.springframework.web.reactive.function.UnsupportedMediaTypeException: Content type 'application/json' not supported for bodyType=java.util.LinkedHashMap<?, ?>

我的pom.xml文件：

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <modelVersion>4.0.0</modelVersion>
  6.     <artifactId>testing</artifactId>
  7.     <packaging>pom</packaging>
  8.     <parent>
  9.         <groupId>org.springframework.boot</groupId>
  10.         <artifactId>spring-boot-starter-parent</artifactId>
  11.         <version>2.2.5.RELEASE</version>
  12.     </parent>
  13.     <groupId>com.dummy</groupId>
  14.     <version>0.0.1-SNAPSHOT</version>
  15.     <properties>
  16.         <java.version>11</java.version>
  17.     </properties>
  19.     <dependencies>
  20.         <dependency>
  21.             <groupId>org.springframework.boot</groupId>
  22.             <artifactId>spring-boot-starter-webflux</artifactId>
  23.             <!-- 排除默认的Jackson依赖 -->
  24.             <exclusions>
  25.                 <exclusion>
  26.                     <groupId>org.springframework.boot</groupId>
  27.                     <artifactId>spring-boot-starter-json</artifactId>
  28.                 </exclusion>
  29.             </exclusions>
  30.         </dependency>
  32.         <dependency>
  33.             <groupId>org.projectlombok</groupId>
  34.             <artifactId>lombok</artifactId>
  35.             <optional>true</optional>
  36.         </dependency>
  38.         <dependency>
  39.             <groupId>org.apache.commons</groupId>
  40.             <artifactId>commons-lang3</artifactId>
  41.             <version>3.9</version>
  42.         </dependency>
  44.         <dependency>
  45.             <groupId>com.google.code.gson</groupId>
  46.             <artifactId>gson</artifactId>
  47.             <version>2.8.4</version>
  48.         </dependency>
  49.     </dependencies>
  51.     <build>
  52.         <plugins>
  53.             <plugin>
  54.                 <groupId>org.springframework.boot</groupId>
  55.                 <artifactId>spring-boot-maven-plugin</artifactId>
  56.             </plugin>
  57.             <plugin>
  58.                 <groupId>org.apache.maven.plugins</groupId>
  59.                 <artifactId>maven-surefire-plugin</artifactId>
  60.             </plugin>
  61.         </plugins>
  62.     </build>
  63. </project>

我注意到的事情：

  • 错误出现在我的方法被调用之前，因此与在方法中指定的错误处理无关。
  • 我尝试为LinkedHashMap添加类型适配器，但仍未被捕获。不过，如果需要的话，我目前只为WebClient添加了它们，但未考虑Spring如何处理转换。我在这里只是猜测，但我认为它会使用我在配置中指定的Gson bean。
  • 如果我查看BodyInserters:376中的context.messageWriters()，我看不到我明确添加的任何熟悉的内容。

我该如何使我的API正常工作？

  2. <details>
  3. <summary>英文:</summary>
  4. I have a `@SpringBootApplication` using Gson instead of jackson with the following converter:
  5. @Configuration
  6. public class ApplicationConfiguration {
  7. @Bean
  8. public GsonBuilder gsonBuilder(){
  9. final GsonBuilder gsonBuilder = new GsonBuilder();
  10. // I registerTypeAdapter &#39;s here
  11. return gson;
  12. }
  13. }
  14. I now have my controller (this fails on all of them not just this but they are the same syntax) 
  15. @RestController(&quot;/1/api/release/&quot;)
  16. @Log
  17. @RequiredArgsConstructor
  18. public class ReleaseController {
  19. @PostMapping(&quot;blocked&quot;)
  20. public Mono&lt;ServerResponse&gt; issueIsBlocked() {
  21. return Mono.just(&quot;test&quot;)
  22. .flatMap(s -&gt; ServerResponse.ok().bodyValue(s))
  23. .onErrorResume(Throwable.class, e -&gt; ServerResponse.status(HttpStatus.INTERNAL_SERVER_ERROR).bodyValue(e.getMessage()));
  24. }
  25. }
  26. And application.properties contains
  27. spring.http.converters.preferred-json-mapper=gson
  28. spring.codec.max-in-memory-size=10MB
  29. I however get this error
  30. org.springframework.web.reactive.function.UnsupportedMediaTypeException: Content type &#39;application/json&#39; not supported for bodyType=java.util.LinkedHashMap&lt;?, ?&gt;
  31. at org.springframework.web.reactive.function.BodyInserters.unsupportedError(BodyInserters.java:391)
  32. at org.springframework.web.reactive.function.BodyInserters.lambda$writeWithMessageWriters$11(BodyInserters.java:381)
  33. at java.base/java.util.Optional.orElseGet(Optional.java:369)
  34. at org.springframework.web.reactive.function.BodyInserters.writeWithMessageWriters(BodyInserters.java:381)
  35. at org.springframework.web.reactive.function.BodyInserters.lambda$fromValue$1(BodyInserters.java:98)
  36. at org.springframework.web.reactive.function.server.DefaultServerResponseBuilder$BodyInserterResponse.writeToInternal(DefaultServerResponseBuilder.java:409)
  37. at org.springframework.web.reactive.function.server.DefaultServerResponseBuilder$AbstractServerResponse.writeTo(DefaultServerResponseBuilder.java:351)
  38. at org.springframework.boot.autoconfigure.web.reactive.error.AbstractErrorWebExceptionHandler.write(AbstractErrorWebExceptionHandler.java:311)
  39. at org.springframework.boot.autoconfigure.web.reactive.error.AbstractErrorWebExceptionHandler.lambda$handle$2(AbstractErrorWebExceptionHandler.java:264)
  40. at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:118)
  41. at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:203)
  42. at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1705)
  43. at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:144)
  44. at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67)
  45. at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67)
  46. at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2267)
  47. at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2075)
  48. at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:1949)
  49. at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54)
  50. at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
  51. at reactor.core.publisher.Mono.subscribe(Mono.java:4110)
  52. at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:75)
  53. at reactor.core.publisher.Operators.complete(Operators.java:135)
  54. at reactor.core.publisher.MonoEmpty.subscribe(MonoEmpty.java:45)
  55. at reactor.core.publisher.Mono.subscribe(Mono.java:4110)
  56. at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:97)
  57. at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:100)
  58. at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:390)
  59. at reactor.core.publisher.Operators.error(Operators.java:185)
  60. at reactor.core.publisher.MonoError.subscribe(MonoError.java:52)
  61. at reactor.core.publisher.Mono.subscribe(Mono.java:4110)
  62. at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:97)
  63. at reactor.core.publisher.MonoFlatMap$FlatMapMain.onError(MonoFlatMap.java:165)
  64. at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondError(MonoFlatMap.java:185)
  65. at reactor.core.publisher.MonoFlatMap$FlatMapInner.onError(MonoFlatMap.java:251)
  66. at reactor.core.publisher.Operators$MonoSubscriber.onError(Operators.java:1752)
  67. at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreInner.onError(MonoIgnoreThen.java:235)
  68. at reactor.core.publisher.MonoFlatMap$FlatMapMain.onError(MonoFlatMap.java:165)
  69. at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onError(Operators.java:1944)
  70. at reactor.core.publisher.Operators.error(Operators.java:185)
  71. at reactor.core.publisher.MonoError.subscribe(MonoError.java:52)
  72. at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
  73. at reactor.core.publisher.Mono.subscribe(Mono.java:4110)
  74. at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:75)
  75. at reactor.core.publisher.MonoFlatMap$FlatMapMain.onComplete(MonoFlatMap.java:174)
  76. at reactor.core.publisher.MonoNext$NextSubscriber.onComplete(MonoNext.java:96)
  77. at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.drain(FluxConcatMap.java:359)
  78. at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.onSubscribe(FluxConcatMap.java:211)
  79. at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:161)
  80. at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:86)
  81. at reactor.core.publisher.Mono.subscribe(Mono.java:4110)
  82. at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:172)
  83. at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56)
  84. at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150)
  85. at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67)
  86. at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76)
  87. at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.innerNext(FluxConcatMap.java:274)
  88. at reactor.core.publisher.FluxConcatMap$ConcatMapInner.onNext(FluxConcatMap.java:851)
  89. at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
  90. at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2267)
  91. at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.request(FluxMapFuseable.java:162)
  92. at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2075)
  93. at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:1949)
  94. at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onSubscribe(FluxMapFuseable.java:90)
  95. at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54)
  96. at reactor.core.publisher.Mono.subscribe(Mono.java:4110)
  97. at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.drain(FluxConcatMap.java:441)
  98. at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.onSubscribe(FluxConcatMap.java:211)
  99. at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:161)
  100. at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:86)
  101. at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:55)
  102. at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
  103. at reactor.core.publisher.Mono.subscribe(Mono.java:4110)
  104. at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:172)
  105. at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56)
  106. at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:55)
  107. at reactor.netty.http.server.HttpServerHandle.onStateChange(HttpServerHandle.java:64)
  108. at reactor.netty.tcp.TcpServerBind$ChildObserver.onStateChange(TcpServerBind.java:228)
  109. at reactor.netty.http.server.HttpServerOperations.onInboundNext(HttpServerOperations.java:465)
  110. at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:90)
  111. at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:377)
  112. at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:363)
  113. at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:355)
  114. at reactor.netty.http.server.HttpTrafficHandler.channelRead(HttpTrafficHandler.java:170)
  115. at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:377)
  116. at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:363)
  117. at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:355)
  118. at io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:436)
  119. at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:321)
  120. at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:295)
  121. at io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:251)
  122. at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:377)
  123. at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:363)
  124. at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:355)
  125. at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
  126. at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:377)
  127. at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:363)
  128. at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
  129. at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
  130. at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:714)
  131. at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:650)
  132. at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:576)
  133. at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:493)
  134. at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
  135. at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  136. at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  137. at java.base/java.lang.Thread.run(Thread.java:834)
  138. my pom.xml
  139. &lt;?xml version=&quot;1.0&quot; encoding=&quot;UTF-8&quot;?&gt;
  140. &lt;project xmlns=&quot;http://maven.apache.org/POM/4.0.0&quot;
  141. xmlns:xsi=&quot;http://www.w3.org/2001/XMLSchema-instance&quot;
  142. xsi:schemaLocation=&quot;http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd&quot;&gt;
  143. &lt;modelVersion&gt;4.0.0&lt;/modelVersion&gt;
  144. &lt;artifactId&gt;testing&lt;/artifactId&gt;
  145. &lt;packaging&gt;pom&lt;/packaging&gt;
  146. &lt;parent&gt;
  147. &lt;groupId&gt;org.springframework.boot&lt;/groupId&gt;
  148. &lt;artifactId&gt;spring-boot-starter-parent&lt;/artifactId&gt;
  149. &lt;version&gt;2.2.5.RELEASE&lt;/version&gt;
  150. &lt;/parent&gt;
  151. &lt;groupId&gt;com.dummy&lt;/groupId&gt;
  152. &lt;version&gt;0.0.1-SNAPSHOT&lt;/version&gt;
  153. &lt;properties&gt;
  154. &lt;java.version&gt;11&lt;/java.version&gt;
  155. &lt;/properties&gt;
  156. &lt;dependencies&gt;
  157. &lt;dependency&gt;
  158. &lt;groupId&gt;org.springframework.boot&lt;/groupId&gt;
  159. &lt;artifactId&gt;spring-boot-starter-webflux&lt;/artifactId&gt;
  160. &lt;!-- Exclude the default Jackson dependency --&gt;
  161. &lt;exclusions&gt;
  162. &lt;exclusion&gt;
  163. &lt;groupId&gt;org.springframework.boot&lt;/groupId&gt;
  164. &lt;artifactId&gt;spring-boot-starter-json&lt;/artifactId&gt;
  165. &lt;/exclusion&gt;
  166. &lt;/exclusions&gt;
  167. &lt;/dependency&gt;
  168. &lt;dependency&gt;
  169. &lt;groupId&gt;org.projectlombok&lt;/groupId&gt;
  170. &lt;artifactId&gt;lombok&lt;/artifactId&gt;
  171. &lt;optional&gt;true&lt;/optional&gt;
  172. &lt;/dependency&gt;
  173. &lt;dependency&gt;
  174. &lt;groupId&gt;org.apache.commons&lt;/groupId&gt;
  175. &lt;artifactId&gt;commons-lang3&lt;/artifactId&gt;
  176. &lt;version&gt;3.9&lt;/version&gt;
  177. &lt;/dependency&gt;
  178. &lt;dependency&gt;
  179. &lt;groupId&gt;com.google.code.gson&lt;/groupId&gt;
  180. &lt;artifactId&gt;gson&lt;/artifactId&gt;
  181. &lt;version&gt;2.8.4&lt;/version&gt;
  182. &lt;/dependency&gt;
  183. &lt;/dependencies&gt;
  184. &lt;build&gt;
  185. &lt;plugins&gt;
  186. &lt;plugin&gt;
  187. &lt;groupId&gt;org.springframework.boot&lt;/groupId&gt;
  188. &lt;artifactId&gt;spring-boot-maven-plugin&lt;/artifactId&gt;
  189. &lt;/plugin&gt;
  190. &lt;plugin&gt;
  191. &lt;groupId&gt;org.apache.maven.plugins&lt;/groupId&gt;
  192. &lt;artifactId&gt;maven-surefire-plugin&lt;/artifactId&gt;
  193. &lt;/plugin&gt;
  194. &lt;/plugins&gt;
  195. &lt;/build&gt;
  196. &lt;/project&gt;
  197. things i have noticed: 
  198. - the error appears before my method is even entered, so it shouldn&#39;t really have anything to do with error handling specified there.
  199. - I tried adding type adapters for LinkedHashMap however they were still not caught. However if this is what is needed, I am currently only adding them for the WebClient not however spring is handling conversion. I am simply guessing here however I would assume it took the GSON bean i specified in my configuration, in which case it would be there. 
  200. - If i look at BodyInserters:376 context.messageWriters() I see nothing familiar to stuff I added explicitly.
  201. How can I get my api&#39;s to work? 
  202. </details>
  203. # 答案1
  204. **得分**: 2
  205. 你不应该在控制器中使用 `Mono&lt;ServerReponse&gt;`，因为它似乎没有被任何序列化器正确映射。
  206. 有两种替代方案：
  207. 1. 使用响应实体
  208. ```java
  209. @PostMapping("blocked")
  210. public Mono<ResponseEntity<String>> issueIsBlocked() {
  211. return Mono.just("test")
  212. .map(s -> new ResponseEntity<>(s, HttpStatus.OK))
  213. .onErrorResume(Throwable.class, 
  214. e -> Mono.just(new ResponseEntity<>(e.getMessage(), HttpStatus.INTERNAL_SERVER_ERROR))
  215. );
  216. }
  1. 使用 WebFlux 提供的 RouterFunction
  1. @Configuration
  2. public class RouterConfig {
  3.     
  4.     @Bean
  5.     RouterFunction<ServerResponse> home() {
  6.         return route(POST("/blocked"),
  7.                 request -> Mono.just("test")
  8.                         .flatMap(s -> ServerResponse.ok().bodyValue(s))
  9.                         .onErrorResume(Throwable.class, e ->
  10.                                 ServerResponse.status(HttpStatus.INTERNAL_SERVER_ERROR).bodyValue(e.getMessage())
  11.                         ));
  12.     }
  13. }
英文:

You are not supposed to use Mono&lt;ServerReponse&gt; in controllers, as such it doesn't appear to be mapped correctly by any serializer.

There are two alternatives

  1. Use response entity

    1.  @PostMapping(&quot;blocked&quot;)
    2. public Mono&lt;ResponseEntity&lt;String&gt;&gt; issueIsBlocked() {
    3. return Mono.just(&quot;test&quot;)
    4. .map(s -&gt; new ResponseEntity&lt;&gt;(s, HttpStatus.OK))
    5. .onErrorResume(Throwable.class, 
    6. e -&gt; Mono.just(new ResponseEntity&lt;&gt;(e.getMessage(), HttpStatus.INTERNAL_SERVER_ERROR))
    7. );
    8. }

2.Use the RouterFunction provided by webflux

  1. @Configuration
  2. public class RouterConfig {
  3. @Bean
  4. RouterFunction&lt;ServerResponse&gt; home() {
  5. return route(POST(&quot;/blocked&quot;),
  6. request -&gt; Mono.just(&quot;test&quot;)
  7. .flatMap(s -&gt; ServerResponse.ok().bodyValue(s))
  8. .onErrorResume(Throwable.class, e -&gt;
  9. ServerResponse.status(HttpStatus.INTERNAL_SERVER_ERROR).bodyValue(e.getMessage())
  10. ));
  11. }

huangapple
  • 本文由 发表于 2020年4月4日 04:52:35
  • 转载请务必保留本文链接：https://go.coder-hub.com/61020234.html
  • gson
  • java
  • spring
  • spring-webflux
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定