Netty在Dubbo中使用实例分析

本篇内容主要讲解“Netty在Dubbo中使用实例分析”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“Netty在Dubbo中使用实例分析”吧!

让客户满意是我们工作的目标，不断超越客户的期望值来自于我们对这个行业的热爱。我们立志把好的技术通过有效、简单的方式提供给客户，将通过不懈努力成为客户在信息化领域值得信任、有价值的长期合作伙伴，公司提供的服务项目有：域名注册、虚拟主机、营销软件、网站建设、东港网站维护、网站推广。

当配置如下信息时

Spring在启动的过程中,通过DubboNamespaceHandler解析上面的标签.

将每个标签与之对应的BeanDefinition注册到BeanFactory中.

Spring再根据BeanDefinition生成对应的Bean实例.

上面的标签最终会生成对应的ServiceBean实例.

// 源码位置: com.alibaba.dubbo.config.spring.ServiceBeanpublic class ServiceBean extends ServiceConfig implements InitializingBean, DisposableBean,        ApplicationContextAware, ApplicationListener, BeanNameAware,        ApplicationEventPublisherAware {          }

ServiceBean实现了ApplicationListener接口.

在Spring创建完所有的Bean之后,最后会发布一个ContextRefreshedEvent事件.

因此ServiceBean的onApplicationEvent()方法会被执行.

public void onApplicationEvent(ContextRefreshedEvent event) {    if (isDelay() && !isExported() && !isUnexported()) {        if (logger.isInfoEnabled()) {            logger.info("The service ready on spring started. service: " + getInterface());        }        // 暴露服务        export();    }}

接下来就进入到了服务暴露的过程.

服务暴露会完成两件事情. 第一件事情是通过Netty开启服务,监听端口.

第二件事情是将服务注册到注册中心.

跟进export()方法, 最后会来到DubboProtocol类.

大体看下它是如何开启服务,监听端口? 留意下,有个属性requestHandler.

public class DubboProtocol extends AbstractProtocol {  private ExchangeHandler requestHandler = new ExchangeHandlerAdapter() { ... };
  private ExchangeServer createServer(URL url) {    // 绑定    server = Exchangers.bind(url, requestHandler);  }
}

跟进bind()方法,最后会来到NettyServer的doOpen()方法.

留意下,有个属性nettyServerHandler.

// 源码位置: com.alibaba.dubbo.remoting.transport.netty4.NettyServerprotected void doOpen() throws Throwable {    bootstrap = new ServerBootstrap();
    bossGroup = new NioEventLoopGroup(1, new DefaultThreadFactory("NettyServerBoss", true));    workerGroup = new NioEventLoopGroup(getUrl().getPositiveParameter(Constants.IO_THREADS_KEY, Constants.DEFAULT_IO_THREADS), new DefaultThreadFactory("NettyServerWorker", true));
    // 重要的Handler    final NettyServerHandler nettyServerHandler = new NettyServerHandler(getUrl(), this);    channels = nettyServerHandler.getChannels();
    bootstrap.group(bossGroup, workerGroup)            .channel(NioServerSocketChannel.class)            .childOption(ChannelOption.TCP_NODELAY, Boolean.TRUE)            .childOption(ChannelOption.SO_REUSEADDR, Boolean.TRUE)            .childOption(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT)            .childHandler(new ChannelInitializer() {                @Override                protected void initChannel(NioSocketChannel ch) throws Exception {                    NettyCodecAdapter adapter = new NettyCodecAdapter(getCodec(), getUrl(), NettyServer.this);                    ch.pipeline()                            .addLast("decoder", adapter.getDecoder())                            .addLast("encoder", adapter.getEncoder())                            .addLast("handler", nettyServerHandler);// 处理请求和响应的Handler                }            });    // bind    ChannelFuture channelFuture = bootstrap.bind(getBindAddress());    channelFuture.syncUninterruptibly();    channel = channelFuture.channel();
}

从DubboProtocol类的requestHandler属性到NettyServer的nettyServerHandler属性.

这一路会经历很多Handler,经过层层封装,最后才封装成NettyServerHandler.

它会经历如下Handler

NettyServerHandler
-> NettyServer
-> MultiMessageHandler
-> HeartbeatHandler
-> AllChannelHandler
-> DecodeHandler
-> HeaderExchangeHandler
-> ExchangeHandler

Netty在Dubbo中使用实例分析