分布式-4-Dubbo

问题

• dubbo支持的协议
  • dubbo、rmi、hessian、http、webservice、thrift、redis
• dubbo协议
  • 基于mina + hessian
  • 默认单一长连接NIO，适合小数据（小于100K）高并发，消费者多于提供者
  • 为什么不适合大数据
    • 单一连接下，一个请求堵在那，别的请求怎么办，TPS低
  • 为什么需要消费者多于提供者
    • 以千兆网卡举例，128MB带宽，测试数据下单一消费者只能达到7MB，网卡无法被压满，浪费
  • 为什么多采用单一长连接
    • 常规场景下，少提供者，多消费者，连接多了建立连接损耗性能，而且提供者容易被压垮，避免C10K
  • 需要传输大数据量时，可以设置connections，用多个连接；缺省值为0，表示JVM共享长连接
  • 当需要定义多个protocol时，可以用id作区分
  • accepts设置提供者最大连接数，保护提供者

<dubbo:protocol name="dubbo" port="20880" server="netty" client="netty" codec="dubbo" 
serialization="hessian2" charset="UTF-8" threadpool="fixed" threads="100" queues="0" iothreads="8" 
buffer="8192" accepts="1000" payload="8388608" connections="2" />

概述

• 特点

  • 分布式服务框架
  • 高性能和透明化的RPC方案

  • SOA服务治理方案

    
    dubbo-001.jpg

• 节点说明

  • Provider: 暴露服务的服务提供方
  • Consumer: 调用远程服务的服务消费方
  • Registry: 服务注册与发现的注册中心
  • Monitor: 统计服务调用次数和调用时间的监控中心
  • Container: 服务运行容器

• 调用关系

  1. 容器负责加载，启动，运行服务提供者
  2. 服务提供者启动时，向注册中心注册服务
  3. 服务消费者启动时，向注册中心订阅服务
  4. 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心基于长连接推送变更
  5. 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用；如果调用失败，再选另一台调用
  6. 服务消费者和提供者，在内存中累计调用次数和调用时间，每分钟发送一次统计数据到监控中心

demo搭建

组成模块

• dubbo-api，dubbo-provider，dubbo-consumer

dubbo-api

• 依赖
  • dubbo
• 调用接口

dubbo-provider

• 依赖
  • dubbo，zk，curator，spring-beans，dubbo-api

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd
       http://code.alibabatech.com/schema/dubbo
       http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    <!-- 定义了提供方应用信息，用于计算依赖关系；在dubbo-admin或dubbo-monitor会显示这个名字，方便辨识 -->
    <dubbo:application name="demo-provider" owner="programmer" organization="dubbo"/>
    <!-- zk做注册中心 -->
    <dubbo:registry address="zookeeper://192.168.99.101:2181"/>
    <!-- dubbo协议，20880端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="20880"/>
    <!-- dubbo协议，service接口 -->
    <dubbo:service interface="com.fjh.dubbo.service.DemoService" ref="demoService" protocol="dubbo"/>
    <!-- 接口实现bean -->
    <bean id="demoService" class="com.fjh.dubbo.service.impl.DemoServiceImpl"/>
</beans>

• spring.handlers

http\://code.alibabatech.com/schema/dubbo=com.alibaba.dubbo.config.spring.schema.DubboNamespaceHandler

• DubboNamespaceHandler
  • DubboBeanDefinitionParser（处理其他标签，以构造函数参数区分；required参数是用来判别是否需要生成id）
  • AnnotationBeanDefinitionParser（仅处理annotation标签）

dubbo-consumer

• 依赖
  • dubbo，zk，curator，spring-beans，dubbo-api

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
       http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    <!-- 定义了提供方应用信息，用于计算依赖关系；在dubbo-admin或dubbo-monitor会显示这个名字，方便辨识 -->
    <dubbo:application name="demo-consumer" owner="programmer" organization="dubbo"/>
    <!-- 向zookeeper订阅provider的地址 -->
    <dubbo:registry address="zookeeper://192.168.99.101:2182"/>
    <!-- dubbo协议，调用定义好的service接口 -->
    <dubbo:reference id="demoService" interface="com.fjh.dubbo.service.DemoService"/>
</beans>