直接输出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();}));}
}