youaremoon
- 浏览: 31564 次
- 性别:
- 来自: 重庆
-
最新评论
-
chenzh1314：
太厉害了，虽然看不懂，但还是感觉很厉害！！
dubbo源码分析-consumer端1-consumer代理生成
文章列表
从前面一篇创建注册中心的流程当中，我们知道在从注册中心获取到provider的连接信息后，会通过连接创建Invoker。代码见com.alibaba.dubbo.registry.integration.RegistryDirectory的toInvokers方法：
// protocol实现为com.alibaba.dubbo.rpc.Protocol$Adpative，
// 之前已经讲过，这是dubbo在运行时动态创建的一个类；
// serviceType为服务类的class, 如demo中的com.alibaba.dubbo.demo.DemoServi ...
Javassit提供了运行时操作Java字节码的方法，其效率低于asm。javassist主要是提供了代码级别的修改(也有bytecode级别)，相比与asm的字节码级别的修改，学习成本低，开发效率高。因此，在实际应用中javassist是一个非常不错的选择。以下是在使用javassist的过程中碰到的问题及处理方法：
1、ClassLoader问题
我们知道java中有ExtClassLoader、AppClassLoader等来加载运行时需要的字节码，同时系统也允许我们自定义ClassLoader来实现不同的加载方式（如tomcat实现的加载机制）。在实际应用中会有这样的问题，如ACl ...
前面一篇文章我们分析了consumer代理的生成。在代理生成的过程中，会创建注册服务(com.alibaba.dubbo.registry.Registry)。通过注册服务提供url注册、订阅、查找的功能。
public interface RegistryService {
/**
* 注册数据，比如：提 ...
dubbo（官网地址）是一个分布式服务框架，致力于提供高性能和透明化的RPC远程服务调用方案，是阿里巴巴SOA服务化治理方案的核心框架。目前，阿里巴巴内部已经不再使用dubbo，但对很对未到一定量级的公司来说，dubbo依然是一个很好的选择。
之前在使用duubo的时候，对dubbo有了一些初步的了解，但没有深入，有些问题还是不清楚。所以准备静下心来看下dubbo源码。这里假设你对dubbo有一定的了解，不再详细的讲解dubbo的架构。如果没接触过dubbo，可以先从其官网了解。
dubbo号称通过spring的方式可以透明化接入应用，对应 ...
前面几篇文章，我们从服务端的视角，分析了从启动到接收连接，到连接的read-write-close。现在我们开始切换到客户端的视角，看看客户端连接服务端的一些实现细节。
还是从snoop的example代码开始，见HttpSnoopClient（稍有修改）：
public static void main(String[] args) throws Exception {
// 配制client.
EventLoopGroup group = new NioEventLoopGroup();
try {
...
NioSocketChannel之服务端视角
上篇文章我们对NioServerSocketChannel进行了分析，了解了它是如何接收客户端连接的。本篇我们将详细的了解接收到的连接的生命周期。需要说明的是由于采用的是服务端视角，因此一个连接的生命周期主要包括：
创建
读取数据
写数据
关闭
创建
创建过程主要是做一些基础属性的初始化（废话）：
public NioSocketChannel(Channel parent, SocketChannel socket) {
// parent自然就是NioServerSocketChann ...
前面我们讲了server的启动过程，同时介绍了其中非常重要的几个概念,ChannelPipeline,ChannelHandlerContext等。接下来我们看看server启动起来以后是如何运转的。
先回忆下之前的几个重要的点，如果要监听某个端口，首先用ServerBootstrap引导启动，启动时创建一个ServerSocketChannel，并注册到bossGroup的EventLoop中，关注的事件为OP_ACCEPT。boss EventLoop开始运行，并不停的尝试从Selector中查看是否有准备好的连接。由于ServerSocketChannel关注的是OP_ACCEPT，因 ...
上面一篇文章介绍了ChannelPipeline，它维护了一个有序的ChannelHandler列表，但并非是直接关联，而是通过维护ChannelHandlerContext进行关联。ChannelPipeline的每一个节点都是一个ChannelHandlerContext实例，不存在线程安全问题，而对应的ChannelHandler如果未标记Sharable也是新建的实例，也不存在线程安全问题。对于Sharable的ChannelHandler则由实现者去处理线程安全问题。可以说ChannelHandlerContext起到了一个桥梁的作用，它可以方便的为ChannelHandler传递数 ...
上一篇文章中，我们介绍了ServerBootstrap的启动过程，在这个过程中引出了一个很重要的类ChannelPipeline。如果说内存池，线程模型是netty的基础，我们接触的相对来说并不是那么直接，那么ChannelPipeline则是我们开发中直接能够接触到的概念，如果对其不了解，很容易造成一些不正确的使用姿势或一些然并卵的优化。现在我们就来看看ChannelPipeline的作用到底是啥。
ChannelPipeline包含了一个ChannelHander形成的列表。其中ChannelHander是用于处理连接的Inbound或者Outbound事件，也是所有开发者都会直接接触到 ...
前面我们分析了netty内存池、线程模型，比较难的两个点已经被一一消化，接下来我们开始进入大家最关心的环节，总体流程分析。 这里我选了io.netty.example.http.snoop来作为分析的入口，分别从server端、client端的维度来看看netty是如果设计的。这里你将了解比较详细的netty处理流程，让你在今后的应用中不再感到疑惑 。 如果还有不清楚的地方，可以直接交流，通过交流发现问题，并不断完善这系列文章。 本文假设你对netty已有大致了解，需要更深入的了解它的运作流程。如果是初学者，可能会发现头晕、眼花、脑抽经等症状。
配置篇
首先看看snoop包的server端 ...
NioEventLoop里面使用了MpscLinkedQueue作为taskQueue，替换了父类中默认的LinkedBlockingQueue队列。taskQueue主要用于存放可执行任务，其调用的频率非常高，因此使用一个更高效的队列能带来很大的收益。 为什么在NioEvnetLoop里用MpscLinkedQueue替换了LinkedBlockingQueue，是使用了更好的算法？还是通过舍弃一些功能的情况来达到更高效的目的？
我们知道LinkedBlockingQueue也是一个高效的线程安全的队列，它使用了takeLock和putLock两个锁分别作用与消费线程和生产线程，避免了消 ...
并发的一个很大的朋友就是锁，因为锁可以在并发的情况下保护一些公共的变量；并发的一个很大的敌人也是锁，因为锁带来了很大的性能开销。
很多时候我们必须加锁来应对并发带来的线程安全问题，而ThreadLocal则给我们开辟了另外一个思路，将数据保存在线程的私有字段中，使一个线程无法读到其他线程的数据， 这样的数据存储方式，自然就线程安全。 那么ThreadLocal本身还有没有可以挖掘的优化点呢，netty告诉你，有！
我们知道ThreadLocal的实现是在Thread里放一个类似map（虽然叫map，但实际上是纯数组实现）的数据结构来存数据，而这个自定义的map要查找一个元素主要分成两步：1 ...
NioEventLoop相对NioEventLoopGroup来说就复杂很多了，需要一定的耐心来看这篇文章。
首先从NioEventLoop的启动讲起，对于线程池来说，启动一般都是从第一个任务的添加开始的。经过跟踪，找到execute()方法在SingleThreadEventExecutor类中：
...
阅读本文之前，你需要对java的线程池有一定的了解，因为这里不会过多的讲解。
今天我们主要的任务就是看下netty中一个非常重要的类EventLoop，通过这系列文章，你应该了解EventLoop适用的场景，不会滥用它而导致你的应用缓慢。Netty使用了典型的Reactor模型结构，这其中一个很重要的角色就是EventLoop，它使用循环的方式来处理IO或者其他事件。
上图是EventLoop的接口继承关系，其中Executor、ExecutorService、ScheduledExecutorService是java提供的线程池管理接口：
ScheduledExecutorS ...
冬天实在太冷了，习惯了广东的天气，突然换个地方还真有点不适应, 早就想写的学习笔记也一直拖到现在。下面进入正题，一起来学习下netty的线程池实现。 我们知道java本身实现了一套线程池，即我们常见的ExecutorService。那么netty为什么还要定义自己的线程模型，什么时候适合用netty线程池，什么时候适合用ExecutorService。相信你看了这几篇文章就会有眉目。
先来张大图，直观的看下netty线程模型和java自带线程池的区别：
需要注意，此图对线程模型进行了简化。图左netty中的executor指jdk中的Executor接口。
了解Promise前我们先 ...