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;
|
|
/**
|
* @author wzy
|
* @date 2019-05-14
|
*/
|
public class NettyTools {
|
|
|
/**
|
* socket字符串传输转码
|
*
|
* @param msg
|
* @return
|
*/
|
public static ByteBuf textBytes(String msg) {
|
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));
|
}
|
}
|
