() {
+ @Override
+ protected void initChannel(SocketChannel socketChannel) throws Exception {
+ socketChannel.pipeline().addLast(new SimpleClientHandler());
+ }
+ });
+
+ ChannelFuture f = b.connect(host, port).sync();
+ f.channel().closeFuture().sync();
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ } finally {
+ worker.shutdownGracefully();
+ }
+ }
+
+ public static void main(String[] args) {
+ ClientTest client = new ClientTest();
+ client.connect("127.0.0.1", 9999);
+ }
+
+
+}
diff --git a/src/main/java/com/chen/netty/client/SimpleClientHandler.java b/src/main/java/com/chen/netty/client/SimpleClientHandler.java
new file mode 100644
index 0000000..48e8fbc
--- /dev/null
+++ b/src/main/java/com/chen/netty/client/SimpleClientHandler.java
@@ -0,0 +1,62 @@
+package com.chen.netty.client;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandlerAdapter;
+
+/**
+ * @author : chen weijie
+ * @Date: 2019-10-18 20:37
+ */
+public class SimpleClientHandler extends ChannelInboundHandlerAdapter {
+
+
+ /**
+ * 本方法用于接收服务端发送过来的消息
+ *
+ * @param ctx
+ * @param msg
+ * @throws Exception
+ */
+ @Override
+ public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+ System.out.println("SimpleClientHandler.channelRead");
+ ByteBuf result = (ByteBuf) msg;
+ byte[] result1 = new byte[result.readableBytes()];
+ result.readBytes(result1);
+ System.out.println("Server said:" + new String(result1));
+ result.release();
+ }
+
+ /**
+ * 本方法用于处理异常
+ *
+ * @param ctx
+ * @param cause
+ * @throws Exception
+ */
+ @Override
+ public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+ // 当出现异常就关闭连接
+ cause.printStackTrace();
+ ctx.close();
+ }
+
+
+ /**
+ * 本方法用于向服务端发送信息
+ *
+ * @param ctx
+ * @throws Exception
+ */
+ @Override
+ public void channelActive(ChannelHandlerContext ctx) throws Exception {
+ String msg = "hello Server!";
+ ByteBuf encoded = ctx.alloc().buffer(4 * msg.length());
+ encoded.writeBytes(msg.getBytes());
+ ctx.write(encoded);
+ ctx.flush();
+ }
+
+
+}
diff --git a/src/main/java/com/chen/netty/server/ServerTest.java b/src/main/java/com/chen/netty/server/ServerTest.java
new file mode 100644
index 0000000..523b792
--- /dev/null
+++ b/src/main/java/com/chen/netty/server/ServerTest.java
@@ -0,0 +1,105 @@
+package com.chen.netty.server;
+
+import io.netty.bootstrap.ServerBootstrap;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.ChannelOption;
+import io.netty.channel.EventLoopGroup;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioServerSocketChannel;
+
+/**
+ * 服务端生产者对象
+ *
+ * Netty中，通讯的双方建立连接后，会把数据按照ByteBuf的方式进行传输，
+ * 例如http协议中，就是通过HttpRequestDecoder对ByteBuf数据流进行处理，转换成http的对象。
+ * 深入学习：
+ * https://www.cnblogs.com/katsura/p/5991428.html
+ * https://www.cnblogs.com/stevenczp/p/7581940.html
+ *
+ * @author : chen weijie
+ * @Date: 2019-10-18 18:46
+ */
+public class ServerTest {
+
+
+ /**
+ * 服务端口
+ */
+ private int port = 9999;
+
+
+ /**
+ * 开启服务
+ */
+ public void startNetty() {
+
+ /**
+ * 创建两个EventLoop的组，EventLoop 这个相当于一个处理线程，
+ 是Netty接收请求和处理IO请求的线程。不理解的话可以百度NIO图解
+ 相关资料：NioEventLoopGroup是一个处理I/O操作的多线程事件循环。
+ Netty为不同类型的传输提供了各种EventLoopGroup实现。
+ 在本例中，我们正在实现一个服务器端应用程序，因此将使用两个NioEventLoopGroup。
+ 第一个，通常称为“boss”，接受传入的连接。
+ 第二个，通常称为“worker”，当boss接受连接并注册被接受的连接到worker时，处理被接受连接的流量。
+ 使用了多少线程以及如何将它们映射到创建的通道取决于EventLoopGroup实现，甚至可以通过构造函数进行配置。
+ */
+
+ EventLoopGroup acceptor = new NioEventLoopGroup();
+ EventLoopGroup worker = new NioEventLoopGroup();
+
+ // 创建启动类
+ ServerBootstrap bootstrap = new ServerBootstrap();
+
+ //2、配置启动参数等
+ /**设置循环线程组，前者用于处理客户端连接事件，后者用于处理网络IO(server使用两个参数这个)
+ *public ServerBootstrap group(EventLoopGroup group)
+ *public ServerBootstrap group(EventLoopGroup parentGroup, EventLoopGroup childGroup)
+ */
+
+ bootstrap.group(acceptor, worker);
+
+
+ /**设置选项
+ * 参数：Socket的标准参数（key，value），可自行百度
+ * eg:
+ * bootstrap.option(ChannelOption.SO_BACKLOG, 1024);
+ *bootstrap.option(ChannelOption.SO_KEEPALIVE, true);
+ * */
+
+ bootstrap.option(ChannelOption.SO_BACKLOG,1024);
+ //用于构造socketchannel工厂
+ bootstrap.channel(NioServerSocketChannel.class);
+
+ /**
+ * 传入自定义客户端Handle（服务端在这里搞事情）
+ */
+ bootstrap.childHandler(new ChannelInitializer() {
+ @Override
+ protected void initChannel(SocketChannel socketChannel) throws Exception {
+ socketChannel.pipeline().addLast(new SimpleServerHandler());
+ }
+ });
+
+ // 绑定端口，开始接收进来的连接
+ ChannelFuture f;
+ try {
+ f = bootstrap.bind(port).sync();
+ // 等待服务器 socket 关闭 。
+ f.channel().closeFuture().sync();
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }finally {
+ acceptor.shutdownGracefully();
+ worker.shutdownGracefully();
+ }
+ }
+
+ public static void main(String[] args) {
+ new ServerTest().startNetty();
+
+ }
+
+
+}
diff --git a/src/main/java/com/chen/netty/server/SimpleServerHandler.java b/src/main/java/com/chen/netty/server/SimpleServerHandler.java
new file mode 100644
index 0000000..8b7f373
--- /dev/null
+++ b/src/main/java/com/chen/netty/server/SimpleServerHandler.java
@@ -0,0 +1,73 @@
+package com.chen.netty.server;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandlerAdapter;
+
+/**
+ * 服务端处理类
+ *
+ * @author : chen weijie
+ * @Date: 2019-10-18 20:15
+ */
+public class SimpleServerHandler extends ChannelInboundHandlerAdapter {
+
+
+ /**
+ * 本方法用于读取客户端发送的信息
+ *
+ * @param ctx
+ * @param msg
+ * @throws Exception
+ */
+ @Override
+ public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+
+ System.out.println("simpleServerHandler.channelRead ");
+ ByteBuf result = (ByteBuf) msg;
+ byte[] results1 = new byte[result.readableBytes()];
+ // msg中存储的是ByteBuf类型的数据，把数据读取到byte[]中
+ result.readBytes(results1);
+
+ String resultStr = new String(results1);
+ System.out.println("client said:" + resultStr);
+ // 释放资源，这行很关键
+ result.release();
+
+ //向客户端发送信息
+ String response = "hello client";
+ // 在当前场景下，发送的数据必须转换成byteBuf数组
+ ByteBuf encoded = ctx.alloc().buffer(4 * response.length());
+ encoded.writeBytes(response.getBytes());
+ ctx.write(encoded);
+ ctx.flush();
+ }
+
+
+ /**
+ * 本方法用作处理异常
+ *
+ * @param ctx
+ * @param cause
+ * @throws Exception
+ */
+ @Override
+ public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+ // 当出现异常就关闭连接
+ cause.printStackTrace();
+ ctx.close();
+ }
+
+ /**
+ * 信息获取完毕后操作
+ *
+ * @param ctx
+ * @throws Exception
+ */
+ @Override
+ public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
+ ctx.flush();
+ }
+
+
+}
diff --git a/src/main/test/com/chen/test/TestDate.java b/src/main/test/com/chen/test/TestDate.java
index a39cda1..58e8c75 100644
--- a/src/main/test/com/chen/test/TestDate.java
+++ b/src/main/test/com/chen/test/TestDate.java
@@ -21,6 +21,7 @@ public static void main(String[] args) {
System.out.println("socre==="+score);
+ System.out.println(1<<31-1);