问题
- 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: 服务运行容器
-
调用关系
- 容器负责加载,启动,运行服务提供者
- 服务提供者启动时,向注册中心注册服务
- 服务消费者启动时,向注册中心订阅服务
- 注册中心返回服务提供者地址列表给消费者,如果有变更,注册中心基于长连接推送变更
- 服务消费者,从提供者地址列表中,基于软负载均衡算法,选一台提供者进行调用;如果调用失败,再选另一台调用
- 服务消费者和提供者,在内存中累计调用次数和调用时间,每分钟发送一次统计数据到监控中心
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>
网友评论