protobuf是谷歌的Protocol Buffers的简称，用于结构化数据和字节码之间互相转换（序列化、反序列化），一般应用于网络传输，可支持多种编程语言。protobuf怎样使用这里不再介绍，本文主要介绍在MINA、Netty、Twisted中怎样使用protobuf，不了解protobuf的同学能够去參考我的还有一篇博文。在前面的一篇博文中。有介绍到一种用一个固定为4字节的前缀Header来指定Body的字节数的一种消息切割方式。在这里相同要使用到。仅仅是当中Bod...
相信大多数Java程序员接触到的第一种序列化或者编解码技术就是.Java的默认序列化，只需要序列化的POJO对象实现java.io.Serializable接口，根据实际情况生成序列ID,这个类就能够通过java.io.Objectlnput和java.io.ObjectOutput序列化和反序列化。不需要考虑跨语言调用，对序列化的性能也没有苛刻的要求时，Java默认的序列化机制是最明智的选择之一。正因为此，虽然Java序列化机制存在着一些弊病，依然得到了广泛的应用。本章主要内容...
精进篇：netty源码死磕7 巧夺天工——Pipeline入站流程详解1. Pipeline的入站流程在讲解入站处理流程前，先脑补和铺垫一下两个知识点：（1）如何向Pipeline添加一个Handler节点（2）Handler的出站和入站的区分方式1.1. HandlerContext节点的添加在Pipeline实例创建的同时，Netty为Pipeline创建了一个Head和一个Tail，并且建立好了链接关系。代码如下：protected DefaultChannelPipeline(Channel channel) { this.channel = Obj...
netty是基于JDK NIO的，为什么不直接使用java nio呢；屏蔽了JDk的实现细节，修复了很多java nio已知的bug java共支持3种网络编程模型/io模式：BIO，NIO(同步非阻塞)，AIO（异步非阻塞）netty是基于NIO的Selector其实就是netty中的bossGroup，client就是workGroup1. 通过事件来决定选择处理哪个chanal业务2. Buffer本身是一块内存，实际上是一个数组，可指定大小，数据读写都由buffer实现3. Nio中我们是面向块（block）和buffer编程...
代码在我自己的gitlab:http://120.76.219.142/marc/nettyServerDML类:package com.wulala;import java.io.FileInputStream; import java.sql.Connection; import java.sql.DriverManager; import java.sql.Statement; import java.util.Properties; import java.util.UUID;public class ExecuteDML {private String driver;private String url;private String user;private String password;public void initParam(String paramFil...
HTTP协议应该是目前使用最多的应用层协议了，用浏览器打开一个网站就是使用HTTP协议进行数据传输。HTTP协议也是基于TCP协议，所以也有服务器和客户端。HTTP客户端一般是浏览器，当然还有可能是其他东西。HTTP服务器，也就是Web服务器，目前已经有很多成熟的产品，例如Apache HTTP Server、Tomcat、Nginx、IIS等。本文的内容不是讲解如何使用以上的HTTP服务器，而是要分别用MINA、Netty、Twisted实现一个简单的HTTP服务器。首先，要...
1. 背景1.1. 宕机的代价1.1.1. 电信行业毕马威国际(KPMG International)在对46个国家的74家运营商进行调查后发现，全球通信行业每年的收益流失约为400亿美元，占总收入的1%-3%。导致收益流失的因素有多种，主要原因就是计费BUG。1.1.2. 互联网行业美国太平洋时间8月16日下午3点50分到3点55分（北京时间8月17日6点50分到6点55分），谷歌遭遇了宕机。根据事后统计，短短的5分钟，谷歌损失了54.5万美元。也就是服务每中断一分钟，损失...
Netty源码分析第三章: 客户端接入流程 第四节: NioSocketChannel注册到selector 我们回到最初的NioMessageUnsafe的read()方法:publicvoid read() {//必须是NioEventLoop方法调用的, 不能通过外部线程调用assert eventLoop().inEventLoop();//服务端channel的configfinal ChannelConfig config = config();//服务端channel的pipelinefinal ChannelPipeline pipeline = pipeline();//处理服务端接入的速率final RecvByteBufAllocator...
引言上一篇文章介绍了Netty的线程模型及EventLoop机制，相信大家对Netty已经有一个基本的认识。那么本篇文章我会根据Netty提供的Demo来分析一下Netty启动流程。启动流程概览开始之前，我们先来分析下Netty服务端的启动流程，下面是一个简单的流程图启动流程大致分为五步创建ServerBootstrap实例，ServerBootstrap是Netty服务端的启动辅助类，其存在意义在于其整合了Netty可以提供的所有能力，并且尽可能的进行了封装，以方便我们使...
Netty3 源码分析 - ChannelUpstreamHandlerChannelUpstreamHandler处理上行的通道事件，并且在流水线中传送事件。这个接口最常用的场景是拦截IO工作现场产生的事件，传输消息或者执行相关的业务逻辑。在大部分情况下，我们是使用SimpleChannelUpstreamHandler 来实现一个具体的upstream handler，因为它为每个事件类型提供了单个的处理方法。大多数情况下ChannelUpstreamHandler 是向上游发送事件，虽然发送下行事件也是允许的（如...
netty深入学习之一: 入门篇本文代码下载：http://download.csdn.net/detail/cheungmine/84975491）Netty是什么Netty是Java NIO之上的网络库（API）。Netty 提供异步的、事件驱动的网络应用程序框架和工具，用以快速开发高性能、高可靠性的网络服务器和客户端程序。2）Netty的特性统一的API，适用于不同的协议（阻塞和非阻塞）。基于灵活、可扩展的事件驱动模型。高度可定制的线程模型。可靠的无连接数据Socket支持（UDP）性能。更好...
Netty是建立在NIO基础之上，Netty在NIO之上又提供了更高层次的抽象。在Netty里面，Accept连接可以使用单独的线程池去处理，读写操作又是另外的线程池来处理。Accept连接和读写操作也可以使用同一个线程池来进行处理。而请求处理逻辑既可以使用单独的线程池进行处理，也可以跟放在读写线程一块处理。线程池中的每一个线程都是NIO线程。用户可以根据实际情况进行组装，构造出满足系统需求的并发模型。Netty提供了内置的常用编解码器，...
geek，Netty源码解析与实战，需要的加我v：dd80868086原文：https://www.cnblogs.com/yansum/p/13178571.html
在TCP长连接或者WebSocket长连接中一般我们都会使用心跳机制–即发送特殊的数据包来通告对方自己的业务还没有办完，不要关闭链接。网络的传输是不可靠的，当我们发起一个链接请求的过程之中会发生什么事情谁都无法预料，或者断电，服务器重启，断网线之类。如果有这种情况的发生对方也无法判断你是否还在线。所以这时候我们引入心跳机制，在长链接中双方没有数据交互的时候互相发送数据(可能是空包，也可能是特殊数据)，对方收到该...
上篇文章中我们梳理了ChannelPipeline中入站事件的传播，这篇文章中我们看下出站事件的传播，也就是ChannelOutboundHandler接口的实现。1、出站事件的传播示例我们对上篇文章中的示例代码进行改造，在ChannelPipeline中加入ChannelOutboundHandler出站实现publicclass ServerApp {publicstaticvoid main(String[] args) {EventLoopGroup boss = new NioEventLoopGroup();EventLoopGroup work = new NioEventLoopGroup(2);try {Serv...