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