1. Netty简介 Netty是由JBOSS提供的一个java开源框架。它提供异步的、事件驱动的网络应用程序框架和工具，用以快速开发高性能、高可靠性的网络服务器和客户端程序。Netty是一个基于NIO的客户端/服务器端编程框架。 Netty的成功案例:Alibaba Dubbo, HornetQ, Vert.x, Apache Cassandra, and Elastic Search上述著名产品都使用Netty编写其核心的网络通信模块。   2. Netty核心组件 ■ Channels■ Callbacks■…

实时消息的推送，PC端的推送技术可以使用socket建立一个长连接来实现。传统的web服务都是客户端发出请求，服务端给出响应。但是现在直观的要求是允许特定时间内在没有客户端发起请求的情况下服务端主动推送消息到客户端。 有哪些可以实现web消息推送的技术： 不断地轮询（俗称“拉”，polling）是获取实时消息的一个手段：Ajax 隔一段时间（通常使用 JavaScript 的 setTimeout 函数）就去服务器查询是否有改变，从而进行增量式的更新。但是间隔多长时间去查询成了问题，因为性能和即时性造成了严重的反比…

Netty的主页：http://netty.io/index.html 使用的Netty的版本：netty-4.0.23.Final.tar.bz2 ‐ 15-Aug-2014 (Stable, Recommended) Http 消息格式： Http request: Method path-to-resource HTTPVersion-number Header-name-1: value1 Header-name-2: value2 Optional request body Http response: …

参考：https://blog.csdn.net/haoyuyang/article/details/53243785 1.为什么选择Netty 上一篇文章我们已经了解了Socket通信（IO/NIO/AIO）编程，对于通信模型已经有了一个基本的认识。其实上一篇文章中，我们学习的仅仅是一个模型，如果想把这些真正的用于实际工作中，那么还需要不断的完善、扩展和优化。比如经典的TCP读包写包问题，或者是数据接收的大小，实际的通信处理与应答的处理逻辑等等一些细节问题需要认真的去思考，而这些都需要大量的时间和经历，以及丰富的…

参考链接：https://blog.csdn.net/wocjy/article/details/78661464   maven依赖： <!-- Netty开始 --> <!-- https://mvnrepository.com/artifact/io.netty/netty-all --> <dependency> <groupId>io.netty</groupId> <artifactId>netty-all</artifact…

1、bio nio 2、tcp 3次握手、滑动窗口 3、socket简单使用 4、netty介绍 5、netty实现简单rpc(https://github.com/caozhiyuan/DotNetty/tree/dev/src/DotNetty.Rpc) Socket参数设置 SoReuseaddr、SoReusePort 、 SoBacklog、SoKeepalive 心跳检测 IdleStateHandler  编码解码 RpcEncoder RpcDecoder ServerHandler RpcHand…

Netty 服务端   Netty 客户端

JDK  实现 public class FutureTest { public static void main(String[] args) throws Exception { ExecutorService es = Executors.newFixedThreadPool(10); Future<Integer> f = es.submit(() ->{ Thread.sleep(5000); // 结果 return 100; }); Integer result = f.get();…

 线程池能够带来3个好处： 降低资源消耗：通过重复利用已创建的线程降低线程创建和销毁造成的消耗；提高响应速度：当任务到达时，任务可以不需要等到线程创建就能立即执行；提高线程的可管理性：线程是稀缺资源，如果无限制地创建，不仅会消耗系统资源，还会降低系统的稳定性，使用线程池可以进行统一分配、调优和监控。   超过可容纳任务数后，按策略处理 可容纳任务数 = 最大线程数（maximumPoolSize）+ 最大队列数（workQueue.size()）     线程资源必须通过线程池提供， 不允许在应用中自行显式创建线程…

ThreadPoolExecutor 介绍 简写： package com.vipsoft.Thread; import java.util.concurrent.*; import java.util.concurrent.atomic.AtomicInteger; public class ThreadPoolExecutorTest { public static void main(String[] args) throws Exception { ThreadPoolExecutor executor =…