JacksonClientHandler.java
843 字节
/**
*
*/
package com.waylau.netty.demo.codec.jackcon;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
/**
* 说明:处理器
*
* @author <a href="http://www.waylau.com">waylau.com</a> 2015年11月7日
*/
public class JacksonClientHandler extends
SimpleChannelInboundHandler<Object> {
@Override
protected void channelRead0(ChannelHandlerContext ctx, Object obj)
throws Exception {
String jsonString = "";
if (obj instanceof JacksonBean) {
JacksonBean user = (JacksonBean) obj;
jsonString = JacksonMapper.getInstance().writeValueAsString(user); // 对象转为json字符串
} else {
jsonString = JacksonMapper.getInstance().writeValueAsString(obj); // 对象转为json字符串
}
System.out.println("Client get msg form Server -" + jsonString);
}
}