netty 实现socket服务端编写

1 importjava.net.InetSocketAddress;
2 
3 importio.netty.bootstrap.ServerBootstrap;
4 importio.netty.channel.ChannelFuture;
5 importio.netty.channel.ChannelInitializer;
6 importio.netty.channel.ChannelOption;
7 importio.netty.channel.EventLoopGroup;
8 importio.netty.channel.nio.NioEventLoopGroup;
9 importio.netty.channel.socket.SocketChannel;
10 importio.netty.channel.socket.nio.NioServerSocketChannel;
11 
12 public classTimeServer {
13     
14     
15     public static void main(String[] args) throwsException{
16         new TimeServer().bind("192.168.1.102", 8400);
17 }
18     
19 
20     public void bind(String addr,intport) {
21         //配置服务端的nio线程组
22         EventLoopGroup boosGroup=newNioEventLoopGroup();
23         EventLoopGroup workerGroup=newNioEventLoopGroup();
24         try{
25             ServerBootstrap b=newServerBootstrap();
26 b.group(boosGroup,workerGroup);
27             b.channel(NioServerSocketChannel.class).option(ChannelOption.SO_BACKLOG,1024)
28             .childHandler(newChildChannelHandler());
29             //绑定端口，同步等待成功
30             ChannelFuture f=b.bind(newInetSocketAddress(addr, port)).sync();
31             //等等服务器端监听端口关闭
32 f.channel().closeFuture().sync();
33         } catch(Exception e) {
34             //TODO: handle exception
35         }finally{
36 boosGroup.shutdownGracefully();
37 workerGroup.shutdownGracefully();
38 }
39 }
40     
41     private class ChildChannelHandler extends ChannelInitializer<SocketChannel>{
42 
43 @Override
44         protected void initChannel(SocketChannel ch) throwsException {
45             ch.pipeline().addLast(newTimeServerHandler());
46             
47 }
48         
49 }
50     
51     
52 }

1 importjava.nio.ByteBuffer;
2 importjava.text.SimpleDateFormat;
3 importjava.util.Date;
4 
5 importio.netty.buffer.ByteBuf;
6 importio.netty.buffer.Unpooled;
7 importio.netty.channel.ChannelHandlerAdapter;
8 importio.netty.channel.ChannelHandlerContext;
9 
10 public class TimeServerHandler extendsChannelHandlerAdapter {
11 
12 @Override
13     public void channelRead(ChannelHandlerContext ctx, Object msg) throwsException {
14         ByteBuf buf=(ByteBuf)msg;
15         byte[] bytes=new byte[buf.readableBytes()];
16 buf.readBytes(bytes);
17         String body=new String(bytes,"UTF-8");
18         SimpleDateFormat  dateFormat=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
19         String time=dateFormat.format(newDate());
20         String res="来自与服务端的回应,时间:"+time;
21         ByteBuf resp=Unpooled.copiedBuffer(res.getBytes());
22 ctx.write(resp);
23         
24 }
25 
26 @Override
27     public void channelReadComplete(ChannelHandlerContext ctx) throwsException {
28 ctx.flush();
29 }
30 
31 @Override
32     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throwsException {
33 ctx.close();
34 }
35 
36     
37 
38     
39 }