bjmashibing / bjmashbing-sysio Goto Github PK

Stargazers

Forkers

dczhfan houjibofa2050 lshans xu-guo wq-wq-wq lvaolin juwentus1234 marsnumone superzhou111 chengfpvoid synpore kanco115 kylejiang yangzelin eaglesy tianxiancode lxy-git-code zihuatanejolee-glenn abigeer clay4444 thronlj1 chuckie596 akingde cityofskyzm sunyaf strawberry999 zl20125058 zhuyao378273431 svenwei jianghujulebu jiangbin216 marskang 420154195 poodon-kwok raynchen yongcs jhc91 jcdd2008 iamhaizhong wangying713 fubinh hanbx niku-bjq lmtz007 skwangdl macoconne breezelk andyzhuwei joviying yangqyloki tenderblur croyances zhaohan6357 i-know-magic ningshupei ppyang010 fangzuo ahutyang whg333 cu156 xiebigbang chenhuan2020 logic-liuchengyu youyoubuxiangchifan tianhang wufeng321 zhangsongyang fanshuge-m pptvgvg wcdaren trail-gudao yonger2016 woyaodangti wuhuangandbazhahei lwaixiao qingfeng826 leonziv shorn-deng is-a-clound anught iamrukia litewater jat0513 fzon0902 johnyhi finallysays dreamraininflowingtime albatronhenry wangqi402 chozee ljyothers jiaduni n-try mrzhoujiang yedongaidiiqu dreamship007 ccmine feng87881626 wuyuejin shengenxu

public static void main(String[] args) throws Exception {

    LinkedList<SocketChannel> clients = new LinkedList<>();

    ServerSocketChannel ss = ServerSocketChannel.open();
    ss.bind(new InetSocketAddress(9090));
    ss.configureBlocking(false); //OS  NONBLOCKING!!!

    ss.setOption(StandardSocketOptions.TCP_NODELAY, false);

    while (true) {
        Thread.sleep(1000);
        SocketChannel client = ss.accept(); // -1NULL

        if (client == null) {
            System.out.println("null.....");
        } else {
            client.configureBlocking(false);
            int port = client.socket().getPort();
            System.out.println("client...port: " + port);
            clients.add(client);
        }

        ByteBuffer buffer = ByteBuffer.allocateDirect(4096);

        for (SocketChannel c : clients) {
            int num = c.read(buffer);  // >0  -1  0
            if (num > 0) {
                buffer.flip();
                byte[] aaa = new byte[buffer.limit()];
                buffer.get(aaa);

                String b = new String(aaa);
                System.out.println(c.socket().getPort() + " : " + b);
                buffer.clear();
            }


        }
    }
}