SSM+Netty框架搭建

package com.pt.controller.netty; import io.netty.buffer.ByteBuf; import io.netty.buffer.Unpooled; import io.netty.channel.ChannelHandler.Sharable; import io.netty.channel.ChannelHandlerAdapter; import io.netty.channel.ChannelHandlerContext; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import com.alibaba.fastjson.JSON; import com.pt.pojo.threed.AppVersion; import com.pt.service.threed.AppVersionService; import java.io.UnsupportedEncodingException; import java.text.SimpleDateFormat; import java.util.Date; import java.util.List; /** * Created by ywy on 16/9/13. */ @Sharable @Component public class HelloServerHandler extends ChannelHandlerAdapter{ private static final Logger LOGGER = LoggerFactory.getLogger(HelloServerHandler.class); @Autowired private AppVersionService appVersionService; @Override public void channelRead(ChannelHandlerContext ctx, Object msg) { try { String body = (String) msg; System.out.println("server receive msg : " + body); LOGGER.info("***********************************************************"); LOGGER.info("调用时间：{}",new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())); LOGGER.info("传入参数：{}",body); String respMsg = ""; List<AppVersion> list = appVersionService.selectAllApp(""); respMsg = JSON.toJSONString(list); respMsg += System.getProperty("line.separator"); LOGGER.info("返回值：{}",respMsg); ByteBuf resp = Unpooled.copiedBuffer(getSendByteBuf(respMsg)); ctx.writeAndFlush(resp); }catch (Exception e){ e.printStackTrace(); } } /** * 格式转换 * @param message * @return * @throws UnsupportedEncodingException */ private ByteBuf getSendByteBuf(String message) throws UnsupportedEncodingException { byte[] req = message.getBytes("UTF-8"); ByteBuf pingMessage = Unpooled.buffer(); pingMessage.writeBytes(req); return pingMessage; } @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { ctx.close(); } public AppVersionService getAppVersionService() { return appVersionService; } public void setAppVersionService(AppVersionService appVersionService) { this.appVersionService = appVersionService; } }