android非阻塞socket

        function testSocket() {  
            switch(plus.os.name) {  
                case "Android":  
                    // Android平台: plus.android.*  
                    SocketChannel = plus.android.importClass("java.nio.channels.SocketChannel");  
                    Selector = plus.android.importClass("java.nio.channels.Selector");  
                    SelectionKey = plus.android.importClass("java.nio.channels.SelectionKey");  
                    InetSocketAddress = plus.android.importClass("java.net.InetSocketAddress");  
                    SocketAddress = plus.android.importClass("java.net.SocketAddress");  
                    ByteBuffer = plus.android.importClass("java.nio.ByteBuffer");  
                    Iterator = plus.android.importClass("java.util.Iterator");  
                    // var iOException = plus.android.importClass("java.io.IOException");  
                    var method = plus.android.importClass("java.lang.reflect.Method");  
                    var OutputStreamWriter = plus.android.importClass("java.io.OutputStreamWriter");  
                    //BufferedReader = plus.android.importClass("java.io.BufferedReader");  
                    //var charset = plus.android.importClass("java.nio.charset");  
                    //测试改良  
                    var StrictMode = plus.android.importClass("android.os.StrictMode");  
                    var Build = plus.android.importClass("android.os.Build");  
                    if(Build.VERSION.SDK_INT > 9) {  
                        var policy = new StrictMode.ThreadPolicy.Builder().permitAll().build();  
                        StrictMode.setThreadPolicy(policy);  
                    }  
                    sendbuffer = ByteBuffer.allocate(100);  
                    receivebuffer = ByteBuffer.allocate(100);  
                    //v selectionKeys;  
                    //iterator=new Iterator();  
                    selectionKey = new SelectionKey();  
                    client = new SocketChannel();  
                    btyeSend = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 1, 2, 3, 4, 5, 6];  
                    count1 = 0;  
                    testThread();  

                    break;  
                case "iOS":  
                    // iOS平台: plus.ios.*  

                    break;  
                default:  
                    // 其它平台  
                    break;  
            }  
        }  

        function testThread() {  
            var App = plus.android.runtimeMainActivity();  
            var Thread = plus.ios.importClass("java.lang.Thread");  
            socketChannel = SocketChannel.open();  
            //ByteBuffer dst;  
            socketChannel.configureBlocking(false);  
            selector = Selector.open();  
            socketChannel.register(selector, SelectionKey.OP_READ | SelectionKey.OP_CONNECT | SelectionKey.OP_WRITE);  
            //socketAddress = new SocketAddress();  
            socketAddress = new InetSocketAddress("10.131.164.32", 1991);  
            socketChannel.connect(socketAddress);  
            var llflag = 0;  
            var Runnable = plus.android.implements("java.lang.Runnable", {  
                "run": function() {  
                    //选择一组键，其相应的通道已为 I/O 操作准备就绪。    
                    //此方法执行处于阻塞模式的选择操作。  
                    //返回此选择器的已选择键集。   
                    while(true) {  
                        selector.select();  
                        //System.out.println(selectionKeys.size());    
                        selectionKeys = selector.selectedKeys();  
                        plus.android.importClass(selectionKeys);  
                        //selectionKeys.clear();  
                        iterator = selectionKeys.iterator();  

                        plus.android.importClass(iterator);  
                        while(iterator.hasNext()) {  
                            selectionKey = iterator.next();  
                            if(selectionKey.isConnectable() && (llflag == 0)) {  
                                console.log("client connect");  
                                llflag = 1;  
                                client = selectionKey.channel();  
                                // 判断此通道上是否正在进行连接操作。    
                                // 完成套接字通道的连接过程。                                                  
                                if(client.isConnectionPending()) {  
                                    client.finishConnect();  
                                    console.log("完成连接!");  
                                    sendbuffer.clear();  
                                    // BufferedInputStream br = new BufferedInputStream(new FileInputStream(new File("D:\\BigData.zip")));    
                                    //     byte[] b = new byte[2];    
                                    //  br.read(b);      
                                    //b[0] = 53;  
                                    //b[1] = 54;  
                                    // b =[1,2,3];  

                                    sendbuffer.put(btyeSend);  
                                    sendbuffer.flip();  
                                    // System.out.println(System.currentTimeMillis());    
                                    client.write(sendbuffer);  
                                    //ystem.out.println(System.currentTimeMillis());    
                                }  
                                //  client.register(selector, SelectionKey.OP_READ);    
                            } else if(selectionKey.isReadable()) {  
                                client = selectionKey.channel();  
                                //将缓冲区清空以备下次读取    
                                receivebuffer.clear();  
                                //读取服务器发送来的数据到缓冲区中    
                                count = client.read(receivebuffer);  
                                if(count > 0) {  
                                    receiveText = new String(receivebuffer.array(), 0, count);  
                                    console.log("客户端接受服务器端数据--:" + receiveText);  
                                    //    if (client.isConnectionPending()) {    
                                    client.finishConnect();  
                                    console.log("完成连接!");  
                                    sendbuffer.clear();  
                                    // BufferedInputStream br = new BufferedInputStream(new FileInputStream(new File("D:\\BigData.zip")));    
                                    var b;  
                                    b = receivebuffer.array();  
                                    var a = []  
                                    for(var i = 0; i < count; i++)  
                                        a[i] = b[i];  
                                    sendbuffer.put(a);  
                                    sendbuffer.flip();  
                                    // System.out.println(System.currentTimeMillis());    
                                    client.write(sendbuffer);  
                                    //ystem.out.println(System.currentTimeMillis());    
                                    //   }  
                                }  
                            }  
                            if(sendFlag == 1) {  
                                client.finishConnect();  
                                sendbuffer.clear();  
                                //byte[] b = new byte[5];    
                                //  br.read(b);  
                                var b_buff = [];  
                                for(var i = 0; i < count1; i++) {  
                                    b_buff[i] = btyeSend[i];  
                                }  
                                sendbuffer.put(b_buff);  
                                sendbuffer.flip();  
                                client.write(sendbuffer);  
                                sendFlag = 0;  
                            }  

                        }  

                        //selectionKeys.clear();  
                    }  
                }  
            });  
            //方式1启动线程  
            App.runOnUiThread(Runnable);  
        }  

        function outValue() {  

            for(var i = 0; i < 16; i++)  
                btyeSend[i] = 0;  
            btyeSend[0] = 65;  
            btyeSend[1] = 66;  
            count1 = 2;  
            sendFlag = 1;  
        }