Okra框架(二) 搭建Socket服务器

1
public class ObjectExecutor implements Executor {
2

3
    protected Session session;
4
    protected Object request;
5

6
    public ObjectExecutor(Session session, Object request) {
7
        this.session = session;
8
        this.request = request;
9
    }
10

11
    @Override
12
    public void onExecute() {
13
        if (null == request) {
14
            throw new NullPointerException("request");
15
        }
16
        // TODO: Just send message back, do some logic on real
17
        session.writeAndFlush(String.valueOf(request));
18
    }
19

20
    @Override
21
    public void release() {
22
        this.session = null;
23
        this.request = null;
24
    }
25
}

1
public class TcpServer extends TcpProtocolServer {
2

3
    public TcpServer(int port) {
4
        setPort(port);
5
    }
6

7
    private static final ChannelHandler FRAME_PREPENDER = new LengthFieldPrepender(4, false);
8

9
    @Override
10
    protected ChannelHandler newChannelInitializer() {
11
        return new ChannelInitializer<NioSocketChannel>() {
12
            @Override
13
            protected void initChannel(NioSocketChannel ch) throws Exception {
14
                ChannelPipeline cp = ch.pipeline();
15
                cp.addLast("frame", new LengthFieldBasedFrameDecoder(Integer.MAX_VALUE, 0, 2, 0, 2));
16
                cp.addLast("prepender", FRAME_PREPENDER);
17
                // Any other useful handler
18
                cp.addLast("handler", new ExampleSocketHandler());
19
            }
20
        };
21
    }
22
}