Netty 之Oio程序编写

     今日将android里面使用的socket 方式改成Oio，因为之前使用的是Netty框架，所以直接将Nio替换成Oio，然后修改了一些其他的代码。

    为了维护的方便我定义了一个BaseClient，用来处理停止socket线程。

    

public abstract class BaseClient {
    protected Channel m_channel;
    protected String m_tag;

    public BaseClient(String tag) {
        m_tag = tag;
    }

    public Channel getChannel() {
        return m_channel;
    }

    public void stop(boolean releaseResOnly) {
        this.stopInThread(releaseResOnly);
    }

    protected void createBootstrap() {
        System.setProperty("java.net.preferIPv4Stack", "true");
        System.setProperty("java.net.preferIPv6Addresses", "false");
    }

    protected void stopInThread(Bootstrap bootstrap, boolean releaseResOnly) {
        try {
            final Bootstrap bs = bootstrap;
            final Channel ch = m_channel;
            final boolean resOnly = releaseResOnly;

            m_channel = null;

            Thread t = new Thread(new Runnable() {
                public void run() {
                    try {
                        if (!resOnly) {
                            if (ch != null) {
                                ch.getCloseFuture().addListener(new ChannelFutureListener() {
                                    @Override
                                    public void operationComplete(ChannelFuture cf) throws Exception {
                                        if (bs != null) {
                                            final Bootstrap bs2 = bs;
                                            new Thread(new Runnable() {
                                                public void run() {
                                                    try {
                                                        System.out.println(m_tag
                                                                + "--- netty ch.close and releaseExtraRes-1");
                                                        bs2.releaseExternalResources();
                                                        System.out.println(m_tag
                                                                + "--- netty ch.close and releaseExtraRes-1 done");
                                                    } catch (Throwable th) {
                                                    }
                                                }
                                            }).start();
                                        }
                                    }
                                });
                                ch.close();
                            }
                        } else {
                            if (bs != null) {
                                try {
                                    System.out.println(m_tag + "--- netty releaseExtraRes-2");
                                    bs.releaseExternalResources();
                                    System.out.println(m_tag + "--- netty releaseExtraRes-2 done");
                                } catch (Throwable th) {
                                }
                            }
                        }

                    } catch (Exception ee) {
                        ee.printStackTrace();
                    }
                }
            });
            t.start();

        } catch (Exception e) {
            e.printStackTrace();
        }

    }//stopInThread()

    protected abstract void stopInThread(boolean releaseResOnly);

 

   CxClient继承了BaseClient，增加了一些关于不同的错误编码，方便在日志中查看

 

public class CxClient extends BaseClient {

    private ClientBootstrap m_bootstrap;
    private CxListener m_listener;
    private final Timer timer;

    public CxClient(String tag) {
        super(tag);
        timer = new HashedWheelTimer();
    }

    @Override
    protected void createBootstrap() {
        super.createBootstrap();

        m_bootstrap = new ClientBootstrap(new OioClientSocketChannelFactory(Executors.newCachedThreadPool()));
        final CxClient client = this;
        m_bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
            @Override
            public ChannelPipeline getPipeline() throws Exception {
                ChannelPipeline pip = Channels.pipeline();

                pip.addLast("timeout", new ReadTimeoutHandler(timer, 300));
                pip.addLast("decoder", new CxDecoder());
                pip.addLast("handler", new CxHandler(m_listener, client));

                return pip;
            }
        });
        m_bootstrap.setOption("tcpNoDelay", true);
        m_bootstrap.setOption("keepAlive", true);
        m_bootstrap.setOption("reuseAddress", true);
        m_bootstrap.setOption("connectTimeoutMillis", "7000");
    }

    public void start(String host, int port, CxListener li) {

        try {
            m_listener = li;
            createBootstrap();
            System.out.println("CxClient::start() Connecting... " + host + ":" + port);
            ChannelFuture f = m_bootstrap.connect(new InetSocketAddress(host, port));

            f.addListener(new ChannelFutureListener() {
                @Override
                public void operationComplete(ChannelFuture cf) throws Exception {
                    if (m_listener != null) {
                        if (cf.isSuccess()) {
                            m_channel = cf.getChannel();
                            m_listener.connected();
                        } else {
                            Throwable th = cf.getCause();
                            System.out.println("CxClient::start() A 1");
                            int errorCode = CxnetConstants.UNKNOWN_EXCEPTION;
                            if (th != null) {
                                Class<?> c = th.getClass();
                                if (c == java.net.BindException.class)
                                    errorCode = CxnetConstants.BIND_EXCEPTION;
                                else if (c == java.net.ConnectException.class)
                                    errorCode = CxnetConstants.CONNECT_EXCEPTION;
                                else if (c == java.net.MalformedURLException.class)
                                    errorCode = CxnetConstants.MAILFORMEDURL_EXCEPTION;
                                else if (c == java.net.NoRouteToHostException.class)
                                    errorCode = CxnetConstants.NOROUTETOHOST_EXCEPTION;
                                else if (c == java.net.PortUnreachableException.class)
                                    errorCode = CxnetConstants.PORTUNREACHABLE_EXCEPTION;
                                else if (c == java.net.ProtocolException.class)
                                    errorCode = CxnetConstants.PROTOCOL_EXCEPTION;
                                else if (c == java.net.SocketException.class)
                                    errorCode = CxnetConstants.SOCKET_EXCEPTION;
                                else if (c == java.net.SocketTimeoutException.class)
                                    errorCode = CxnetConstants.SOCKETTIMEOUT_EXCEPTION;
                                else if (c == java.net.UnknownHostException.class)
                                    errorCode = CxnetConstants.UNKNOWNHOST_EXCEPTION;
                                else if (c == java.net.UnknownServiceException.class)
                                    errorCode = CxnetConstants.UNKNOWNSERVICE_EXCEPTION;
                                else if (c == java.net.URISyntaxException.class)
                                    errorCode = CxnetConstants.URISYNTAX_EXCEPTION;
                                th.printStackTrace();
                                System.out.println("CxClient::start() A 2 errCode=" + errorCode);
                            }
                            m_listener.disconnected(errorCode);
                        }
                    }
                }
            });
        } catch (Exception e) {
            System.out.println("CxClient::start() excep B 1");
            e.printStackTrace();
            System.out.println("CxClient::start() excep B 2");
            m_listener.disconnected(CxnetConstants.UNKNOWN_EXCEPTION);
        }

    }//start()

    @Override
    protected void stopInThread(boolean releaseResOnly) {
        final Bootstrap bs = m_bootstrap;
        m_bootstrap = null;
        super.stopInThread(bs, releaseResOnly);
    }

}//end cls - CxClient