From 38179780b2f728abe6dd0e5aaa284c6ee6aa8380 Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Wed, 09 Mar 2022 14:19:56 +0800 Subject: [PATCH] init otc --- src/main/java/com/xcong/excoin/netty/common/NettyTools.java | 11 +++++++++++ 1 files changed, 11 insertions(+), 0 deletions(-) diff --git a/src/main/java/com/xcong/excoin/netty/common/NettyTools.java b/src/main/java/com/xcong/excoin/netty/common/NettyTools.java index ead90db..dd13d4e 100644 --- a/src/main/java/com/xcong/excoin/netty/common/NettyTools.java +++ b/src/main/java/com/xcong/excoin/netty/common/NettyTools.java @@ -1,5 +1,7 @@ package com.xcong.excoin.netty.common; +import com.alibaba.fastjson.JSONObject; +import com.xcong.excoin.netty.bean.ResponseBean; import io.netty.buffer.ByteBuf; import io.netty.buffer.Unpooled; import io.netty.handler.codec.http.websocketx.TextWebSocketFrame; @@ -21,7 +23,16 @@ return Unpooled.copiedBuffer((msg + "_split").getBytes()); } + public static TextWebSocketFrame wsSendMsg(ResponseBean responseBean) { + String res = JSONObject.toJSONString(responseBean); + return new TextWebSocketFrame(res); + } + public static TextWebSocketFrame webSocketBytes(String msg) { return new TextWebSocketFrame(msg); } + + public static TextWebSocketFrame webSocketJson(Object object) { + return webSocketBytes(JSONObject.toJSONString(object)); + } } -- Gitblit v1.9.1