直接輸出JSON對象?

@GetMapping("selectMy") public Mono<Void> selectMy(ServerHttpRequest request, ServerHttpResponse response) {String pageNumber= request.getQueryParams().getFirst("pageNumber");AuthUser authUser= LoginProcess.getCurrentUser(request.getCookies());Map<String,String> result=new HashMap<String,String>(){{put("aa","1");put("bb","21dd");}};return response.writeWith(Flux.create(sink -> {NettyDataBufferFactory nettyDataBufferFactory = new NettyDataBufferFactory(new UnpooledByteBufAllocator(false));try {DataBuffer dataBuffer= nettyDataBufferFactory.wrap(JSON.toJSONString(result).getBytes("utf8"));//DataBuffer dataBuffer= nettyDataBufferFactory.wrap("asdf".getBytes("utf8"));sink.next(dataBuffer);} catch (UnsupportedEncodingException e) {e.printStackTrace();}sink.complete();})); }

通用方法輔助類封裝：

import com.alibaba.fastjson.JSON; import io.netty.buffer.UnpooledByteBufAllocator; import org.springframework.core.io.buffer.DataBuffer; import org.springframework.core.io.buffer.NettyDataBufferFactory; import org.springframework.http.server.reactive.ServerHttpResponse; import reactor.core.publisher.Flux; import reactor.core.publisher.Mono;import java.io.UnsupportedEncodingException;/*** Created by wanghongqi on 2019/5/11* ServerHttpResponse輔助類*/ public class ServerHttpResponseUtil {/*** JSON輸出形式輸出對象* @param response* @param object* @return*/public static Mono<Void> writeObjectAsJson(ServerHttpResponse response,Object object){return response.writeWith(Flux.create(sink -> {NettyDataBufferFactory nettyDataBufferFactory = new NettyDataBufferFactory(new UnpooledByteBufAllocator(false));try {DataBuffer dataBuffer= nettyDataBufferFactory.wrap(JSON.toJSONStringWithDateFormat(object,JSON.DEFFAULT_DATE_FORMAT).getBytes("utf8"));//DataBuffer dataBuffer= nettyDataBufferFactory.wrap("asdf".getBytes("utf8"));sink.next(dataBuffer);} catch (UnsupportedEncodingException e) {e.printStackTrace();}sink.complete();}));}/*** html輸出* @param response* @param html* @return*/public static Mono<Void> writeHtml(ServerHttpResponse response,String html){return response.writeWith(Flux.create(sink -> {NettyDataBufferFactory nettyDataBufferFactory = new NettyDataBufferFactory(new UnpooledByteBufAllocator(false));try {DataBuffer dataBuffer= nettyDataBufferFactory.wrap(html.getBytes("utf8"));sink.next(dataBuffer);} catch (UnsupportedEncodingException e) {e.printStackTrace();}sink.complete();}));} }

?

總結

以上是生活随笔為你收集整理的webflux databuffer输出的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。