最强开源网络应用框架 Netty，没有之一，直接“榨干”CPU！

/** * @author 闪电侠 */public class NIOServer {    public static void main(String[] args) throws IOException {        Selector serverSelector = Selector.open();        Selector clientSelector = Selector.open();
        new Thread(() -> {            try {                // 对应IO编程中的服务端启动                ServerSocketChannel listenerChannel = ServerSocketChannel.open();                listenerChannel.socket().bind(new InetSocketAddress(8000));                listenerChannel.configureBlocking(false);                listenerChannel.register(serverSelector, SelectionKey.OP_ACCEPT);
                while (true) {                    // 监测是否有新连接，这里的1指阻塞的时间为 1ms                    if (serverSelector.select(1) > 0) {                        Set<SelectionKey> set = serverSelector.selectedKeys();                        Iterator<SelectionKey> keyIterator = set.iterator();
                        while (keyIterator.hasNext()) {                            SelectionKey key = keyIterator.next();
                            if (key.isAcceptable()) {                                try {                                    // （1）每来一个新连接，不需要创建一个线程，而是直接注册到clientSelector                                    SocketChannel clientChannel = ((ServerSocketChannel) key.channel()).accept();                                    clientChannel.configureBlocking(false);                                    clientChannel.register(clientSelector, SelectionKey.OP_READ);                                } finally {                                    keyIterator.remove();                                }                            }
                        }                    }                }            } catch (IOException ignored) {            }
        }).start();

        new Thread(() -> {            try {                while (true) {                    // （2）批量轮询哪些连接有数据可读，这里的1指阻塞的时间为 1ms                    if (clientSelector.select(1) > 0) {                        Set<SelectionKey> set = clientSelector.selectedKeys();                        Iterator<SelectionKey> keyIterator = set.iterator();
                        while (keyIterator.hasNext()) {                            SelectionKey key = keyIterator.next();
                            if (key.isReadable()) {                                try {                                    SocketChannel clientChannel = (SocketChannel) key.channel();                                    ByteBuffer byteBuffer = ByteBuffer.allocate(1024);                                    // （3）面向Buffer                                    clientChannel.read(byteBuffer);                                    byteBuffer.flip();                                    System.out.println(Charset.defaultCharset().newDecoder(). decode(byteBuffer)                                            .toString());                                } finally {                                    keyIterator.remove();                                    key.interestOps(SelectionKey.OP_READ);                                }                            }
                        }                    }                }            } catch (IOException ignored) {            }        }).start();

    }}

  <dependency>        <groupId>io.netty</groupId>        <artifactId>netty-all</artifactId>        <version>4.1.6.Final</version>    </dependency>

/** * @author 闪电侠 */public class NettyServer {    public static void main(String[] args) {        ServerBootstrap serverBootstrap = new ServerBootstrap();
        NioEventLoopGroup boss = new NioEventLoopGroup();        NioEventLoopGroup worker = new NioEventLoopGroup();        serverBootstrap                .group(boss, worker)                .channel(NioServerSocketChannel.class)                .childHandler(new ChannelInitializer<NioSocketChannel>() {                    protected void initChannel(NioSocketChannel ch) {                        ch.pipeline().addLast(new StringDecoder());                        ch.pipeline().addLast(new SimpleChannelInboundHandler<String>() {                            @Override                            protected void channelRead0(ChannelHandlerContext ctx, String msg) {                                System.out.println(msg);                            }                        });                    }                })                .bind(8000);    }}

/** * @author 闪电侠 */public class NettyClient {    public static void main(String[] args) throws InterruptedException {        Bootstrap bootstrap = new Bootstrap();        NioEventLoopGroup group = new NioEventLoopGroup();
        bootstrap.group(group)                .channel(NioSocketChannel.class)                .handler(new ChannelInitializer<Channel>() {                    @Override                    protected void initChannel(Channel ch) {                        ch.pipeline().addLast(new StringEncoder());                    }                });
        Channel channel = bootstrap.connect("127.0.0.1", 8000).channel();
        while (true) {            channel.writeAndFlush(new Date() + ": hello world!");            Thread.sleep(2000);        }    }}

 如果喜欢本文欢迎 在看丨留言丨分享至朋友圈 三连
 热文推荐  
书单 | 多角度掌握知识图谱核心要义与应用
不会Netty，你永远是个Java菜鸟
俄罗斯的数学为什么这么强？
《隐私计算》重磅发布，全面、系统论述数据要素安全流通价值

▼点击阅读原文，了解本书详情~