webflux databuffer输出

直接输出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输出相关推荐

node.js把前台传来的base64码转成图片存放
最近项目有个功能,更换用户个人头像,裁剪后上传保存. 裁剪用了cropper.js,裁剪后的图片为base64编码格式,传到node中,进行转换成图片在保存到数据库中,代码如下: var fs = r ...
springboot 使用webflux响应式开发教程（一）
什么是webFlux 左侧是传统的基于Servlet的Spring Web MVC框架,右侧是5.0版本新引入的基于Reactive Streams的Spring WebFlux框架,从上到下依次是R ...
使用webflux提升数据导出效率
为什么80%的码农都做不了架构师?>>> 序本文主要研究一下如何使用webflux提升数据导出效率传统导出 @GetMapping("/download-old& ...
Kotlin 使用 Spring WebFlux 实现响应式编程
Kotlin 使用 Spring WebFlux 实现响应式编程 IBM的研究称,整个人类文明所获得的全部数据中,有90%是过去两年内产生的.在此背景下,包括NoSQL,Hadoop, Spark, ...
Spring Boot 集成 WebFlux 开发 Reactive Web 应用
Spring Boot 集成 WebFlux 开发 Reactive Web 应用 <Spring Boot 实战开发>-- 基于 Gradle + Kotlin的企业级应用开发最佳实践 ...
Spring Boot 2 快速教程：WebFlux 快速入门（二）
2019独角兽企业重金招聘Python工程师标准>>> 摘要: 原创出处 https://www.bysocket.com 「公众号:泥瓦匠BYSocket 」欢迎关注和转载,保留摘 ...
Spring Boot 2 快速教程：WebFlux Restful CRUD 实践（三）
摘要: 原创出处 https://www.bysocket.com 「公众号:泥瓦匠BYSocket 」欢迎关注和转载,保留摘要,谢谢! 这是泥瓦匠的第102篇原创 03:WebFlux Web CR ...
WebFlux基础之响应式编程
上篇文章,我们简单的了解了WebFlux的一些基础与背景,并通过示例来写了一个demo.我们知道WebFlux是响应式的web框架,其特点之一就是可以通过函数式编程方式配置route.另外究竟什么是响 ...
Spring Boot WebFlux-02——WebFlux Web CRUD 实践
Spring Boot WebFlux-02--WebFlux Web CRUD 实践第02课:WebFlux Web CRUD 实践上一篇基于功能性端点去创建一个简单服务,实现了 Hello.这 ...

webflux databuffer输出

webflux databuffer输出相关推荐

最新文章

热门文章