init otc

Helius

2022-03-09 38179780b2f728abe6dd0e5aaa284c6ee6aa8380

 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));
    }
}