From 36be00e0f3cbe0d559c646fd2977e6e3a74aa6f9 Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Mon, 30 Sep 2024 16:57:22 +0800 Subject: [PATCH] Merge branch 'bea' of http://120.27.238.55:7000/r/exchange into bea --- 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