netty如何使用 ChannelInboundHandlerAdapter相关理解_netty_jrymos软件工作室

相关文章推荐

爱看书的竹笋 · 3.10 ...· 1 月前 ·

怕老婆的沙滩裤 · python提取txt中的部分信息 - ...· 2 月前 ·

礼貌的海龟 · 正则表达式取最后一个 . ...· 4 月前 ·

小眼睛的火车 · (python & go 微服务) ...· 10 月前 ·

坚韧的小刀 · MySQL可以替换多个字符吗？ ?mysql ...· 11 月前 ·

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
   <groupId>com.fly.study.netty</groupId>
    <artifactId>netty</artifactId>
    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                </configuration>
            </plugin>
        </plugins>
    </build>
    <dependencies>
        <dependency>
            <groupId>io.netty</groupId>
            <artifactId>netty-all</artifactId>
            <version>4.1.17.Final</version>
        </dependency>
    </dependencies>
</project>

package demo.back;
import demo.util.PrintHandler;
import demo.util.ServerUtils;
import io.netty.channel.ChannelHandler;
 * Created with IntelliJ IDEA
 * Description:
 * User: weijun.zou
 * Date: 2018-06-01
 * Time: 17:29
@ChannelHandler.Sharable
public class Server extends PrintHandler {
    public static void main(String[] args) throws InterruptedException {
        ServerUtils.startServer(9999, new Server());
import demo.util.ClientUtils;
import demo.util.PrintHandler;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelFutureListener;
import io.netty.channel.ChannelHandlerContext;
 * Created with IntelliJ IDEA
 * Description:
 * User: weijun.zou
 * Date: 2018-06-01
 * Time: 17:45
public class Client extends PrintHandler {
    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        super.channelActive(ctx);
        final ChannelFuture f = ctx.writeAndFlush("client active");
        f.addListener((ChannelFutureListener) future -> {
            assert f == future;
            ctx.close();
    public static void main(String[] args) throws InterruptedException {
        ClientUtils.startClient("localhost", 9999, new Client());
相关测试代码：




    

package demo.util;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
 * Created with IntelliJ IDEA
 * Description:
 * User: weijun.zou
 * Date: 2018-06-01
 * Time: 18:14
public class PrintHandler extends ChannelInboundHandlerAdapter {
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        System.out.println(info() + "read");
    @Override
    public void channelRegistered(ChannelHandlerContext ctx) throws Exception {
        System.out.println(info() + "registered");
    @Override
    public void channelUnregistered(ChannelHandlerContext ctx) throws Exception {
        System.out.println(info() + "unregistered");
    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        System.out.println(info() + "active");
    @Override
    public void channelInactive(ChannelHandlerContext ctx) throws Exception {
        System.out.println(info() + "inactive");
    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
        System.out.println(info() + "readComplete");
    @Override
    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
        System.out.println(info() + "triggered");
    @Override
    public void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception {
        System.out.println(info() + "changed");
    protected String info() {
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            e.printStackTrace();
        return System.currentTimeMillis() + " " + this.getClass().getSimpleName() + ": ";
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        cause.printStackTrace();
        ctx.close();
import io.netty.bootstrap.Bootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelHandler;
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.NioSocketChannel;
 * Created with IntelliJ IDEA
 * Description:
 * User: weijun.zou
 * Date: 2018-06-01
 * Time: 17:37
public class ClientUtils {
    public static void startClient(String host,int port,ChannelHandler... handlers) throws InterruptedException {
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        try {
            Bootstrap b = new Bootstrap(); // (1)
            b.group(workerGroup); // (2)
            b.channel(NioSocketChannel.class); // (3)
            b.option(ChannelOption.SO_KEEPALIVE, true); // (4)
            b.handler(new ChannelInitializer<SocketChannel>() {
                @Override
                public void initChannel(SocketChannel ch) throws Exception {
                    ch.pipeline().addLast(handlers);
            ChannelFuture f = b.connect(host, port).sync(); // (5)
            f.channel().closeFuture().sync();
        } finally {
            workerGroup.shutdownGracefully();
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelHandler;
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;
 * Created with IntelliJ IDEA
 * Description:
 * User: weijun.zou
 * Date: 2018-06-01
 * Time: 17:34
public class ServerUtils {
    public static void startServer(int port, ChannelHandler... handlers) throws InterruptedException {
        EventLoopGroup bossGroup = new NioEventLoopGroup(); // (1)
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        try {
            ServerBootstrap b = new ServerBootstrap(); // (2)
            b.group(bossGroup, workerGroup)
                    .channel(NioServerSocketChannel.class) // (3)
                    .childHandler(new ChannelInitializer<SocketChannel>() { // (4)
                        @Override
                        public void initChannel(SocketChannel ch) throws Exception {
                            ch.pipeline().addLast(handlers);
                    .option(ChannelOption.SO_BACKLOG, 128)          // (5)
                    .childOption(ChannelOption.SO_KEEPALIVE, true); // (6)
            ChannelFuture f = b.bind(port).sync(); // (7)
            f.channel().closeFuture().sync();
        } finally {
            workerGroup.shutdownGracefully();
            bossGroup.shutdownGracefully();
				每一个Handler都一定会处理出站或者入站（也可能两者都处理）数据，例如对于入站的Handler可能会继承SimpleChannelInboundHandler或者ChannelInboundHan...
											来自：	 huiGod的博客
				Handler在netty中，无疑占据着非常重要的地位。Handler与Servlet中的filter很像，通过Handler可以完成通讯报文的解码编码、拦截指定的报文、统一对日志错误进行处理、统一对...
											来自：	 路漫漫其修远兮，吾将上下而求索
				sigh，这这篇博客的时候老脸还是红了一下，应该算是剽窃吧，看到别人写的代码有点无地之容，好在文章的标题是“一起学”，而不是开涛大神的“跟我学”系列的文章最近工作比较忙，但闲暇之余还是看了阿里的冯家春...
											来自：	 BazingaLyncc
				一般用netty来发送和接收数据都会继承SimpleChannelInboundHandler和ChannelInboundHandlerAdapter这两个抽象类，那么这两个到底有什么区别呢？其实用...
											来自：	 weixin_30361641的博客
				Netty:ChannelInboundHandlerAdapter和ChannelOutboundHandlerAdapter 前面说到，服务端和客户端通讯，我们通常要绑定一个handler（Net...
											来自：	 TuxedoLinux的博客
				其实Netty的知识点还是很零碎的，比如这个SimpleChannelInboundHandler这个类，在《NettyinAction》该书中的原版的Helloworld的demo的客户端就是使用的...
											来自：	 z69183787的专栏
				读完这一章，我们基本上可以了解到Netty所有重要的组件，对Netty有一个全面的认识，这对下一步深入学习Netty是十分重要的，而学完这一章，我们其实已经可以用Netty解决一些常规的问题了。一、先...
											来自：	 Heaven Wang 的专栏
				在博主认为，对于入门级学习java的最佳学习方法莫过于视频+博客+书籍+总结，前三者博主将淋漓尽致地挥毫于这篇博客文章中，至于总结在于个人，实际上越到后面你会发现学习的最好方式就是阅读参考官方文档其次...
											来自：	 程序员宜春的博客
				由于我之前一直强调数据结构以及算法学习的重要性，所以就有一些读者经常问我，数据结构与算法应该要学习到哪个程度呢？，说实话，这个问题我不知道要怎么回答你，主要取决于你想学习到哪些程度，不过针对这个问题，...
											来自：	 帅地
				文章目录@[toc]spring cloud 介绍spring cloud 技术组成Spring Cloud 对比 Dubbo一、service - 服务二、commons 通用项目新建 maven ...
											来自：	 weixin_38305440的博客
				Netty到底是什么从HTTP说起有了Netty，你可以实现自己的HTTP服务器，FTP服务器，UDP服务器，RPC服务器，WebSocket服务器，Redis的Proxy服务器，MySQL的Prox...
											来自：	 weixin_34167043的博客
				今天闲着无事，就想写点东西。然后听了下歌，就打算写个播放器。于是乎用h5 audio的加上js简单的播放器完工了。演示地点演示html代码如下`	music		 								这个年纪			七月的风...
											来自：	 qq_44210563的博客
				作为一个有着 8 年 Java 编程经验的 IT 老兵，说起来很惭愧，我被 Java 当中的四五个名词一直困扰着：**对象、引用、堆、栈、堆栈**（栈可同堆栈，因此是四个名词，也是五个名词）。每次我看...
											来自：	 沉默王二
				本博客记录工作中需要的linux运维命令，大学时候开始接触linux，会一些基本操作，可是都没有整理起来，加上是做开发，不做运维，有些命令忘记了，所以现在整理成博客，当然vi，文件操作等就不介绍了，慢...
											来自：	 Nicky's blog
				Netty什么是Netty？Netty 是一个利用 Java 的高级网络的能力，隐藏其背后的复杂性而提供一个易于使用的 API 的客户端/服务器框架。Netty 是一个广泛使用的 Java 网络编程框...
											来自：	 Pannahouse的博客
				大学四年，看课本是不可能一直看课本的了，对于学习，特别是自学，善于搜索网上的一些资源来辅助，还是非常有必要的，下面我就把这几年私藏的各种资源，网站贡献出来给你们。主要有：电子书搜索、实用工具、在线视频...
											来自：	 帅地
				Docker 技术发展为微服务落地提供了更加便利的环境，使用 Docker 部署 Spring Boot 其实非常简单，这篇文章我们就来简单学习下。首先构建一个简单的 Spring Boot 项目，然...
											来自：	 weixin_34192732的博客
				引言最近也有很多人来向我"请教"，他们大都是一些刚入门的新手，还不了解这个行业，也不知道从何学起，开始的时候非常迷茫，实在是每天回复很多人也很麻烦，所以在这里统一作个回复吧。Java学习路线当然，这里...
											来自：	 java_sha的博客
				从 PC 时代至今，众人只知在 CPU、GPU、XPU、制程、工艺等战场中，英特尔在与同行硬件芯片制造商们的竞争中杀出重围，且在不断的成长进化中，成为全球知名的半导体公司。殊不知，在「刚硬」的背后，英...
											来自：	 CSDN资讯
				此篇为LeetCode刷题的汇总目录，方便大家查找，一起刷题，一起PK交流！已解题目考点LeetCode 1. 两数之和（哈希）LeetCode 2. 两数相加（单链表反转）LeetCode 9. 回...
											来自：	 Michael是个半路程序员
				作者：陈大鱼头github： KRISACHAN<input /> 标签是我们日常开发中非常常见的替换元素了，但是最近在刷 whattwg 跟 MDN 的时候发现 跟 <input ...
											来自：	 鱼头的Web海洋
				点击上方“程序员小明”，选择“星标”今晚可以不加班！网络上虽然已经有了很多关于程序员的话题，但大部分人对这个群体还是很陌生。我们在谈论程序员的时候，究竟该聊些什么呢？各位......
											来自：	 程序员小明
				文章有点长并且绕，先来个图片缓冲下！前言现在的业务场景越来越复杂，使用的架构也就越来越复杂，分布式、高并发已经是业务要求的常态。像腾讯系的不少服务，还有CDN优化、异地多备份等处理。说到分布式，就必然...
											来自：	 公众号-[程序员之道]
				作者/分享人：李艳鹏不久前，阿里巴巴发布了《阿里巴巴Java开发手册》，总结了阿里巴巴内部实际项目开发过程中开发人员应该遵守的研发流程规范，这些流程规范在一定程度上能够保证最终的项目交付质量，通过在时...
											来自：	 Arthur0923的博客
				转载自：https://www.jianshu.com/p/93ce43a0eb161. 源码分析SimpleChannelInboundHandler    @Override    public ...
											来自：	 lizhengyu891231的博客
				你知道的越多，你不知道的越多点赞再看，养成习惯前言Redis在互联网技术存储方面使用如此广泛，几乎所有的后端技术面试官都要在Redis的使用和原理方面对小伙伴们进行360°的刁难。作为一个在互联网公司...
											来自：	 敖丙
				什么是redis？Redis 本质上是一个 Key-Value 类型的内存数据库， 整个数据库加载在内存当中进行操作， 定期通过异步操作把数据库数据 flush 到硬盘上进行保存。因为是纯内存操作， ...
											来自：	 hebtu666
				功能实现如下：    支持的植物类型：太阳花，豌豆射手，寒冰射手，坚果，樱桃炸弹。新增加植物：双重豌豆射手，三重豌豆射手，食人花 ，小喷菇，土豆地雷，倭瓜。    支持的僵尸类型：普通僵尸，棋子僵尸，...
											来自：	 marble_xu的博客
				中国麻将：世界上最早的区块链项目最近区块链这个玩意又被市场搞的很是火热，相信大部分人都不太清楚这玩意到底是怎么样的一个概念，它来了，它来了，它到底是啥~ 国家都开始发文支持了，下面是一个通俗易懂的例子...
											来自：	 gao_chun
				Python 是一种代表简单思想的语言，其语法相对简单，很容易上手。不过，如果就此小视 Python 语法的精妙和深邃，那就大错特错了。本文精心筛选了最能展现 Python 语法之精妙的十个知识点，并...
											来自：	 Python作业辅导员 - 天元浪子【许向武】
				可能很多人在大一的时候，就已经接触了递归了，不过，我敢保证很多人初学者刚开始接触递归的时候，是一脸懵逼的，我当初也是，给我的感觉就是，递归太神奇了！可能也有一大部分人知道递归，也能看的懂递归，但在实际...
											来自：	 weixin_30216561的博客
				你知道的越多，你不知道的越多点赞再看，养成习惯前言Redis在互联网技术存储方面使用如此广泛，几乎所有的后端技术面试官都要在Redis的使用和原理方面对小伙伴们进行360°的刁难。作为一个在互联网公司...
											来自：	 敖丙
				来源：苦逼的码农（ID：di201805）前言天各一方的两台计算机是如何通信的呢？在成千上万的计算机中，为什么一台计算机能够准确着寻找到另外一台计算机，并且把数据发送给它......
											来自：	 Java团长的博客
				沉淀再出发：关于netty的一些理解和使用一、前言 Netty是由JBOSS提供的一个java开源框架。Netty提供异步的、事件驱动的网络应用程序框架和工具，用以快速开发高性能、高可靠性的网络服务器...
											来自：	 weixin_30745641的博客
又到深夜了，我按照以往在csdn和公众号写着数据结构！这占用了我大量的时间！我的超越妹妹严重缺乏陪伴而 怨气满满！
而女朋友时常埋怨，认为数据结构这么抽象难懂的东西没啥作用，常会问道...
				我本科学校是渣渣二本，研究生学校是985，现在毕业五年，校招笔试、面试，社招面试参加了两年了，就我个人的经历来说下这个问题。
这篇文章很长，但绝对是精华，相信我，读完以后，你会知道学历不好的解决方案...
				最近翻到一篇知乎，上面有不少用Python（大多是turtle库）绘制的树图，感觉很漂亮，我整理了一下，挑了一些我觉得不错的代码分享给大家（这些我都测试过，确实可以生成）
one 樱花树
				“Ctrl+Z”是什么操作？各位都用过，并且经常使用吧？撤销！撤销上一个操作返回上一个状态，甚至撤销好几个操作，返回到几个操作之前的状态。这个操作非常有用，一旦我们某一步操作失误，可以选择撤销操作来返...
				昨天，有网友私信我，说去阿里面试，彻底的被打击到了。问了为什么网上大量使用ThreadLocal的源码都会加上private static？他被难住了，因为他从来都没有考虑过这个问题。无独有偶，今天笔...
				最近打开电脑，系统总是自动弹出Windows许可证即将过期的弹窗，现在总结方法如下。
命令都是在运行窗口输入的
打开方式：win+R组合键或者右键点击win10开始菜单，点击“运行”
查看系统版本：w...
				IT界知名的程序员曾说：对于那些月薪三万以下，自称IT工程师的码农们，其实我们从来没有把他们归为我们IT工程师的队伍。他们虽然总是以IT工程师自居，但只是他们一厢情愿罢了。
此话一出，不知激起了多少(...
互联网应用发展到今天，从单体应用架构到SOA以及今天的微服务，随着微服务化的不断升级进化，服务和服务之间的稳定性变得越来越重要，分布式系统之所以复杂，主要原因是分布式系统需要考虑到网络的延时和...
				      11月8日，由中国信息通信研究院、中国通信标准化协会、中国互联网协会、可信区块链推进计划联合主办，科技行者协办的2019可信区块链峰会将在北京悠唐皇冠假日酒店开幕。
　　区块链技术被认为...
Hacker（黑客），往往被人们理解为只会用非法手段来破坏网络安全的计算机高手。但是，黑客其实不是这样的，真正的“网络破坏者”是和黑客名称和读音相似的骇客。
骇客，是用黑客手段进行非法操作并为己...
				网易云音乐是音乐爱好者的集聚地，云音乐推荐系统致力于通过 AI 算法的落地，实现用户千人千面的个性化推荐，为用户带来不一样的听歌体验。
本次分享重点介绍 AI 算法在音乐推荐中的应用实践，以及在算法...
				位算法的效率有多快我就不说，不信你可以去用 10 亿个数据模拟一下，今天给大家讲一讲位运算的一些经典例子。不过，最重要的不是看懂了这些例子就好，而是要在以后多去运用位运算这些技巧，当然，采用位运算，也...
				    不知觉已中码龄已突破五年，一路走来从起初铁憨憨到现在的十九线程序员，一路成长，虽然不能成为高工，但是也能挡下一面，从15年很火的android开始入坑，走过java、.Net、QT，目前仍处于...
				文章目录一、前言二、为什么要学数据结构三、数据结构无处不在3.1 数据库3.2 操作系统3.3 文件压缩3.4 游戏四、数据结构类型
在可视化化程序设计的今天，借助于集成开发环境可以很快地生...
				文章目录一、数据库简介二、MySQL数据类型(5.5版本)三、Sql语句(1)Sql语句简介(2)数据定义语言DDLcreate,alter,drop(3)数据操纵语言DMLupdate,insert...
王者荣耀大家都玩过吧，没玩过的也应该听说过，作为时下最火的手机MOBA游戏，咳咳，好像跑题了。我们今天的重点是爬取王者荣耀所有英雄的所有皮肤，而且仅仅使用20行Python代码即可完成。
准备工...
				我清晰的记得，刚买的macbook pro回到家，开机后第一件事情，就是上了淘宝网，花了500元钱，找了一个上门维修电脑的师傅，上门给我装了一个windows系统。。。。。。
表砍我。。。
当时买ma...
				每天都会收到很多读者的私信，问我：“二哥，有什么推荐的学习网站吗？最近很浮躁，手头的一些网站都看烦了，想看看二哥这里有什么新鲜货。”
今天一早做了个恶梦，梦到被老板辞退了。虽然说在我们公司，只有我辞退...
				很遗憾，这个春节注定是刻骨铭心的，新型冠状病毒让每个人的神经都是紧绷的。那些处在武汉的白衣天使们，尤其值得我们的尊敬。而我们这些窝在家里的程序员，能不外出就不外出，就是对社会做出的最大的贡献。
有些...