美文网首页
分布式-4-Dubbo

分布式-4-Dubbo

作者: 宠辱不惊的咸鱼 | 来源:发表于2019-10-02 09:29 被阅读0次

问题

  • 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>

相关文章

网友评论

      本文标题:分布式-4-Dubbo

      本文链接:https://www.haomeiwen.com/subject/ejilpctx.html