【Netty】读书笔记 - 跟闪电侠学netty

1. 内容概要

1.1 本节实现功能

客户端：连接服务器，之后向服务器发送数据
服务端：接收数据后打印，并向客户端发送数据

1.2 本节知识点

1.2.1 ch.pipeline().addLast(new FirstClientHandler());

责任链模式：ch.pipeline()
添加处理逻辑：addLast()

1.2.2 继承 extends ChannelInboundHandlerAdapter

客户端：覆盖channelActive()方法，客户端连接成功时被调用
服务器：覆盖channelRead()方法，接收到客户端发送的数据时被调用

1.2.3 创建ByteBuf并写入数据

    private ByteBuf getByteBuf(ChannelHandlerContext ctx) {byte[] bytes = "你好，闪电侠!".getBytes(Charset.forName("utf-8"));ByteBuf buffer = ctx.alloc().buffer();buffer.writeBytes(bytes);return buffer;}

1.2.4 channelRead中Object msg转ByteBuf

ByteBuf byteBuf = (ByteBuf) msg;

1.2.5 ctx.channel().writeAndFlush(buffer)

ctx.channel()：获取ByteBuf的内存管理器
writeAndFlush()：写数据并发送（到服务器/客户端）

2　客户端

NettyClient

import io.netty.bootstrap.Bootstrap;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;import java.util.Date;
import java.util.concurrent.TimeUnit;public class NettyClient {private static final int MAX_RETRY = 5;private static final String HOST = "127.0.0.1";private static final int PORT = 8000;public static void main(String[] args) {NioEventLoopGroup workerGroup = new NioEventLoopGroup();Bootstrap bootstrap = new Bootstrap();bootstrap.group(workerGroup).channel(NioSocketChannel.class).option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 5000).option(ChannelOption.SO_KEEPALIVE, true).option(ChannelOption.TCP_NODELAY, true).handler(new ChannelInitializer<SocketChannel>() {@Overridepublic void initChannel(SocketChannel ch) {ch.pipeline().addLast(new FirstClientHandler());}});connect(bootstrap, HOST, PORT, MAX_RETRY);}private static void connect(Bootstrap bootstrap, String host, int port, int retry) {bootstrap.connect(host, port).addListener(future -> {if (future.isSuccess()) {System.out.println("连接成功!");} else if (retry == 0) {System.err.println("重试次数已用完，放弃连接！");} else {// 第几次重连int order = (MAX_RETRY - retry) + 1;// 本次重连的间隔int delay = 1 << order;System.err.println(new Date() + ": 连接失败，第" + order + "次重连……");bootstrap.config().group().schedule(() -> connect(bootstrap, host, port, retry - 1), delay, TimeUnit.SECONDS);}});}
}

FirstClientHandler：客户端器逻辑处理类

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;import java.nio.charset.Charset;
import java.util.Date;public class FirstClientHandler extends ChannelInboundHandlerAdapter {@Overridepublic void channelActive(ChannelHandlerContext ctx) {System.out.println(new Date() + ": 客户端写出数据");// 1.获取数据ByteBuf buffer = getByteBuf(ctx);// 2.写数据ctx.channel().writeAndFlush(buffer);}private ByteBuf getByteBuf(ChannelHandlerContext ctx) {byte[] bytes = "你好，闪电侠!".getBytes(Charset.forName("utf-8"));ByteBuf buffer = ctx.alloc().buffer();buffer.writeBytes(bytes);return buffer;}@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) {ByteBuf byteBuf = (ByteBuf) msg;System.out.println(new Date() + ": 客户端读到数据 -> " + byteBuf.toString(Charset.forName("utf-8")));}
}

3　服务端

NettyServer

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;public class NettyServer {private static final int PORT = 8000;public static void main(String[] args) {NioEventLoopGroup boosGroup = new NioEventLoopGroup();NioEventLoopGroup workerGroup = new NioEventLoopGroup();final ServerBootstrap serverBootstrap = new ServerBootstrap();serverBootstrap.group(boosGroup, workerGroup).channel(NioServerSocketChannel.class).option(ChannelOption.SO_BACKLOG, 1024).childOption(ChannelOption.SO_KEEPALIVE, true).childOption(ChannelOption.TCP_NODELAY, true).childHandler(new ChannelInitializer<NioSocketChannel>() {protected void initChannel(NioSocketChannel ch) {ch.pipeline().addLast(new FirstServerHandler());}});bind(serverBootstrap, PORT);}private static void bind(final ServerBootstrap serverBootstrap, final int port) {serverBootstrap.bind(port).addListener(future -> {if (future.isSuccess()) {System.out.println("端口[" + port + "]绑定成功!");} else {System.err.println("端口[" + port + "]绑定失败!");}});}
}

FirstServerHandler：服务器逻辑处理类

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;import java.nio.charset.Charset;
import java.util.Date;public class FirstServerHandler extends ChannelInboundHandlerAdapter {@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) {ByteBuf byteBuf = (ByteBuf) msg;System.out.println(new Date() + ": 服务端读到数据 -> " + byteBuf.toString(Charset.forName("utf-8")));// 回复数据到客户端System.out.println(new Date() + ": 服务端写出数据");ByteBuf out = getByteBuf(ctx);ctx.channel().writeAndFlush(out);}private ByteBuf getByteBuf(ChannelHandlerContext ctx) {byte[] bytes = "你好，欢迎关注我的微信公众号，《闪电侠的博客》!".getBytes(Charset.forName("utf-8"));ByteBuf buffer = ctx.alloc().buffer();buffer.writeBytes(bytes);return buffer;}
}

【闪电侠学netty】第6章客户端与服务端双向通信相关推荐

Netty实战 IM即时通讯系统（六）实战：客户端和服务端双向通信
## Netty实战 IM即时通讯系统(六)实战: 客户端和服务端双向通信零. 目录 IM系统简介 Netty 简介 Netty 环境配置服务端启动流程实战: 客户端和服务端双向通信数据传输载 ...
【初识Netty使用Netty实现简单的客户端与服务端的通信操作Netty框架中一些重要的类以及方法的解析】
一.Netty是什么? Netty 由 Trustin Lee(韩国,Line 公司)2004 年开发本质:网络应用程序框架实现:异步.事件驱动特性:高性能.可维护.快速开发用途:开发服务器和 ...
【闪电侠学netty】第8章客户端与服务端通信协议编解码
[Netty]读书笔记 - 跟闪电侠学 1. 内容概要 1.1 总结 1.1.1 编码与解码定义编码:把java对象根据协议封装成二进制数据包的过程解码:从二进制数据包中解析出Java对象的过程 ...
学游戏开发，从客户端还是服务端开始？
##前言近几年,游戏开发行业风生水起,入行的个个都赚个盆满钵满,这种现状反过来又吸引着更多人源源不断地进行这个行业. 那么,对于刚刚转行到游戏开发或者有意转行的朋友来说,应该从哪里开始学起呢? 这个 ...
【Netty】读书笔记 - 跟闪电侠学netty
前言:本篇只是笔者的读书总结,推荐结合原书观看(推荐指数:5星) 上篇入门实战第1章即时聊天系统简介第2章 Netty是什么第3章 Netty开发环境配置第4章服务端启动流程第5章客 ...
Netty实战 IM即时通讯系统（十）实现客户端和服务端收发消息
Netty实战 IM即时通讯系统(十)实现客户端和服务端收发消息零. 目录 IM系统简介 Netty 简介 Netty 环境配置服务端启动流程客户端启动流程实战: 客户端和服务端双向通信数据 ...
Netty实战 IM即时通讯系统（十二）构建客户端与服务端pipeline
Netty实战 IM即时通讯系统(十二)构建客户端与服务端pipeline 零. 目录 IM系统简介 Netty 简介 Netty 环境配置服务端启动流程客户端启动流程实战: 客户端和服务端双向 ...
Netty简单实现客户端与服务端收发消息
Netty简单实现客户端与服务端收发消息这个小案例主要是实现netty收发消息,分为客户端,及服务端,以及包含了相关状态处理,主要的代码会放在最后 gitHub 地址上,有需要可以看一下首先来简单 ...
【闪电侠学netty】第1章即时聊天系统简介
[Netty]读书笔记 - 跟闪电侠学 1. 内容概要 1.1 单聊流程图 1.2 单聊的指令流程图+指令集 1.3 群聊流程图 1.4 群聊的指令流程图+指令集 1.5 Netty核心知识点+客户端 ...

【闪电侠学netty】第6章客户端与服务端双向通信

【Netty】读书笔记 - 跟闪电侠学netty

1. 内容概要

1.1 本节实现功能

1.2 本节知识点

1.2.1 ch.pipeline().addLast(new FirstClientHandler());

1.2.2 继承 extends ChannelInboundHandlerAdapter

1.2.3 创建ByteBuf并写入数据

1.2.4 channelRead中Object msg转ByteBuf

1.2.5 ctx.channel().writeAndFlush(buffer)

2　客户端

3　服务端

【闪电侠学netty】第6章客户端与服务端双向通信相关推荐

最新文章

热门文章

【闪电侠学netty】第6章 客户端与服务端双向通信

【Netty】读书笔记 - 跟闪电侠学netty

1. 内容概要

1.1 本节实现功能

1.2 本节知识点

1.2.1 ch.pipeline().addLast(new FirstClientHandler());

1.2.2 继承 extends ChannelInboundHandlerAdapter

1.2.3 创建ByteBuf并写入数据

1.2.4 channelRead中Object msg转ByteBuf

1.2.5 ctx.channel().writeAndFlush(buffer)

2 客户端

3 服务端

【闪电侠学netty】第6章 客户端与服务端双向通信相关推荐

最新文章

热门文章

【闪电侠学netty】第6章客户端与服务端双向通信

2　客户端

3　服务端

【闪电侠学netty】第6章客户端与服务端双向通信相关推荐