test

沈斌

2018-02-26 a4f11cd94cb83dc59f4b9fe1871ec1f9a1b19b46

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
import io.netty.buffer.Unpooled; 
import io.netty.channel.ChannelFutureListener; 
import io.netty.channel.ChannelHandlerContext; 
import io.netty.channel.ChannelInboundHandlerAdapter; 
 
/** 
 * Created by a on 2017/7/27. 
 */ 
public class EchoServerHandler extends ChannelInboundHandlerAdapter { 
 
    @Override 
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { 
        System.out.println("server channelRead...; received:" + msg); 
        ctx.write(msg); 
    } 
 
    @Override 
    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception { 
        System.out.println("server channelReadComplete.."); 
        // 第一种方法：写一个空的buf，并刷新写出区域。完成后关闭sock channel连接。 
        ctx.writeAndFlush(Unpooled.EMPTY_BUFFER).addListener(ChannelFutureListener.CLOSE); 
        //ctx.flush(); // 第二种方法：在client端关闭channel连接，这样的话，会触发两次channelReadComplete方法。 
        //ctx.flush().close().sync(); // 第三种：改成这种写法也可以，但是这中写法，没有第一种方法的好。 
    } 
 
    @Override 
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { 
        System.out.println("server occur exception:" + cause.getMessage()); 
        cause.printStackTrace(); 
        ctx.close(); // 关闭发生异常的连接 
    } 
 
}