1.简述dubbo的源码分层设计
2.Dubboç®ä»
简述dubbo的分层设计
简述dubbo的分层设计。
简述dubbo的源码分层设计
跟大家说一说简述dubbo的分层设计的相关经验,请看下面详细的源码介绍。
Service,源码ClassLoader源码分析业务层,源码就是源码咱们开发的业务逻辑层。Config,源码配置层,源码主要围绕ServiceConfig和ReferenceConfig,源码初始化配置信息。源码Proxy,源码usb源码驱动代理层,源码服务提供者还是源码消费者都会生成一个代理类,使得服务接口透明化,源码代理层做远程调用和返回结果。源码Register,涨停macd源码注册层,封装了服务注册和发现。Cluster,路由和集群容错层,负责选取具体调用的源码 相似度节点,处理特殊的调用要求和负责远程调用失败的容错措施。Monitor,监控层,负责监控统计调用时间和次数。Portocol,流程管理 源码远程调用层,主要是封装RPC调用,主要负责管理Invoker。Exchange,信息交换层,用来封装请求响应模型,同步转异步。Transport,网络传输层,抽象了网络传输的统一接口,Netty、Mina等。Serialize,序列化层,将数据序列化成二进制流,以及反序列化。
图例如下:
以上就是带来的简述dubbo的分层设计的全部内容,您了解了吗?
Dubboç®ä»
Dubboæ¯Alibabaå¼æºçåå¸å¼æå¡æ¡æ¶ï¼å®æç §åå±çæ¹å¼æ¥æ¶æï¼ä½¿ç¨è¿ç§æ¹å¼å¯ä»¥ä½¿åå±è§£è¦ã
Dubboå¨è°ç¨è¿ç¨çæå¡çæ¶ååæ¬å°æä¸ä¸ªæ¥å£ï¼å°±æ³è°ç¨æ¬å°æ¹æ³ä¸æ ·å»è°ç¨ï¼åºå±å®ç°å¥½åæ°ä¼ è¾åè¿ç¨æå¡è¿è¡ç»æä¼ åä¹åçè¿åã
Dubboçç¹ç¹ï¼
ï¼1ï¼å®ä¸»è¦ä½¿ç¨é«æçç½ç»æ¡æ¶ååºååæ¡æ¶ï¼è®©åå¸å¼æå¡ä¹é´è°ç¨æçæ´é«ã
ï¼2ï¼éç¨æ³¨åä¸å¿ç®¡çä¼å¤çæå¡æ¥å£å°åï¼å½ä½ æ³è°ç¨æå¡çæ¶ååªéè¦è·æ³¨åä¸å¿è¯¢é®å³å¯ï¼ä¸å使ç¨WebServiceä¸æ ·æ¯ä¸ªæå¡é½å¾è®°å½å¥½æ¥å£è°ç¨æ¹å¼ã
ï¼3ï¼çæ§ä¸å¿æ¶å®ç°æå¡æ¹åè°ç¨æ¹ä¹é´è¿è¡ç¶æççæ§ï¼è¿è½æ§å¶æå¡çä¼å 级ãæéãæéãä¸ä¸çº¿çï¼è®©æ´ä¸ªåºå¤§çåå¸å¼æå¡ç³»ç»çç»´æ¤åæ²»çæ¯è¾æ¹ä¾¿ã
ï¼4ï¼é«å¯ç¨ï¼å¦æææå¡æäºï¼æ³¨åä¸å¿å°±ä¼ä»æå¡å表å»æ该èç¹ï¼å®¢æ·ç«¯ä¼å注åä¸å¿è¯·æ±å¦ä¸å°å¯ç¨çæå¡èç¹éæ°è°ç¨ãåæ¶æ³¨åä¸å¿ä¹è½å®ç°é«å¯ç¨ï¼ZooKeeperï¼ã
ï¼5ï¼è´è½½åè¡¡ï¼éç¨è½¯è´è½½åè¡¡ç®æ³å®ç°å¯¹å¤ä¸ªç¸åæå¡çèç¹ç请æ±è´è½½åè¡¡ã
Dubboéè¦å大åºæ¬ç»ä»¶ï¼Rigistry,Monitor,Provider,Consumerã
1ãçæ§ä¸å¿çé ç½®æ件-dubbo.propertiesæ件
ï¼1ï¼å®¹å¨ï¼çæ§ä¸å¿æ¯å¨jettyåspringç¯å¢ä¸è¿è¡ï¼ä¾èµäºæ³¨åä¸å¿ï¼æ¥å¿ç³»ç»æ¯log4j
dubbo.container = log4j,spring,registry,jetty
ï¼2ï¼çæ§æå¡çå称ï¼çæ§ç³»ç»å¯¹æ´ä¸ªDubboæå¡ç³»ç»æ¥è¯´ä¹æ¯ä¸ä¸ªæå¡
dubbo.application.name = simple-monitor
ï¼3ï¼æå¡çææè ï¼è¿æ¯Dubbboçæå¡çåè½ï¼å¯ä»¥æå®æå¡çè´è´£äºº
dubbo.application.owner = coselding
ï¼4ï¼æ³¨åä¸å¿çå°åï¼é ç½®åçæ§ä¸å¿å°±è½éè¿æ³¨åä¸å¿è·åå½åå¯ç¨çæå¡å表åå ¶ç¶æï¼å¨é¡µé¢åä½ æ±æ¥Dubboä¸çæå¡è¿è¡æ åµã
dubbo.registr.address = multicast://{ ip}:{ port} //广æ
dubbo.registr.address = zookeeper://{ ip}:{ port} //zookeper
dubbo.registr.address = redis://{ ip}:{ port} //redis
dubbo.registr.address = dubbo://{ ip}:{ port} //dubbo
ï¼5ï¼dubboå议端å£å·
dubbo.protocol.port =
ï¼6ï¼jettyå·¥ä½ç«¯å£å·
dubbo.jetty.port =
ï¼7ï¼å·¥ä½ç®å½ï¼ç¨äºåæ¾çæ§ä¸å¿çæ°æ®
dubbo.jetty.directory = ${ user.home}/monitor
ï¼8ï¼çæ§ä¸å¿æ¥è¡¨åæ¾ç®å½
dubbo.charts.directory=${ dubbo.jetty.directory}/charts
ï¼9ï¼çæ§ä¸å¿æ°æ®èµæç®å½
dubbo.statistics.directory=${ user.home}/monitor/statistics
ï¼ï¼çæ§ä¸å¿æ¥å¿æ件路å¾
dubbo.log4j.file=logs/dubbo-monitor-simple.log
ï¼ï¼çæ§ä¸å¿æ¥å¿è®°å½çº§å«
dubbo.log4j.level=WARN
2ãDubboæä¾è´è½½åè¡¡æ¹å¼
ï¼1ï¼Randomï¼éæºï¼ææéé ç½®éæºæ¦çï¼è°ç¨éè¶å¤§åå¸è¶ååï¼é»è®¤æ¹å¼ã
ï¼2ï¼RounRobinï¼è½®è¯¢ï¼ææé设置轮询æ¯ä¾ï¼å¦æåå¨æ¯è¾æ ¢çæºå¨å®¹æå¨è¿å°æºå¨ä¸è¯·æ±é»å¡è¾å¤ã
ï¼3ï¼LeastActiveï¼æå°æ´»è·è°ç¨æ°ï¼ä¸æ¯ææéï¼åªè½æ ¹æ®èªå¨è¯å«çæ´»è·æ°åé ï¼ä¸è½çµæ´»è°é ã
ï¼4ï¼ConsistenHashï¼ä¸è´æ§hashï¼å¯¹ç¸ååæ°ç请æ±è·¯ç±å°ä¸ä¸ªæå¡æä¾è ä¸ï¼å¦ææ类似ç°åº¦åå¸éæ±å¯éç¨ã
3ãDubboè¿æ»¤å¨
Dubboåå§åè¿ç¨å è½½ClassPathä¸çMETA-INF/dubbo/internal/ï¼META-INF/dubbo/ï¼META-INF/services/ä¸ä¸ªè·¯å¾ä¸çcom.alibaba.dubbo.rpc.Filteræ件ãæ件å 容ï¼
Name = FullClassName,è¿äºç±»å¿ é¡»å®ç°Filteræ¥å£ã
èªå®ä¹Filterç±»ï¼
é ç½®æ件å¨é ç½®è¿æ»¤å¨ï¼consumer.xmlä¸ï¼
Dubbo对è¿æ»¤å¨çå è½½è¿ç¨ï¼
å å è½½ä¸ä¸ªè·¯å¾ä¸çcom.alibaba.dubbo.rpc.Filteræ件éé¢çé®å¼å¯¹ï¼key为è¿æ»¤å¨å称ï¼value为è¿æ»¤å¨çç±»çå ¨éå®å(è¿ä¸ªç±»å¿ é¡»å®ç°Dubboä¸çFilteræ¥å£)ã
èªå®ä¹çç±»ä¸@Active注解æ¯è¿æ»¤å¨è®¾å®çå ¨å±åºæ¬å±æ§ã
Springå¨å è½½consumer.xmlæ件æ¶ï¼éè¿ <dubbo:consumer filter="xxx" id = "xxx" retrries = "0">è¿ä¸ªé ç½®æå®æ¶è´¹è 端è¦å è½½çè¿æ»¤å¨ï¼éè¿filterå±æ§æå®è¿æ»¤å¨å称ã
@Activate注解-èªå¨æ¿æ´»ï¼groupå±æ§æ¯è¡¨ç¤ºå¹é äºå¯¹åºçè§è²æ被å è½½ï¼value表示表æè¿æ»¤æ¡ä»¶ï¼ä¸åå表示æææ¡ä»¶é½ä¼è¢«å è½½ï¼åäºååªædubbo URLä¸å å«è¯¥åæ°åä¸åæ°å¼ä¸ä¸ºç©ºæ被å è½½ï¼è¿ä¸ªåæ°ä¼ä»¥dubboåè®®çä¸ä¸ªåæ°K-Vå¯¹ä¼ å°Providerã
4ãDubboçProvideré ç½®
5ãDubboçConsumeré ç½®
1ãDubboæ¯ä»ä¹ï¼
Dubboæ¯é¿éå·´å·´å¼æºçåºäºJavaçé«æ§è½RPCåå¸å¼æ¡æ¶ã
2ã为ä»ä¹ä½¿ç¨Dubboï¼
å¾å¤å ¬å¸é½å¨ä½¿ç¨ï¼ç»è¿å¾å¤çº¿ä¸çèéªï¼å é¨ä½¿ç¨äºNettyï¼Zookeeperï¼ä¿è¯äºé«æ§è½å¯ç¨æ§ã
使ç¨Dubboå¯ä»¥å°æ ¸å¿ä¸å¡æ½ååºæ¥ï¼ä½ä¸ºç¬ç«çæå¡ï¼éæ¸å½¢æ稳å®çæå¡ä¸å¿ï¼å¯ä»¥æé«ä¸å¡å¤ç¨çµæ´»æ§æ©å±ï¼ä½¿å端åºç¨è½å¿«éçååºå¯¹è¾¹çå¸åºéæ±ãåå¸å¼æ¶æå¯ä»¥æ¿åæ´å¤§è§æ¨¡ç并åæµéã
Dubboçæå¡æ²»çå¾ï¼
3ãDubboåSpring Cloudçåºå«
两个没æå ³èï¼ä½æ¯éè¦è¯´åºå«ï¼æå¦ä¸å ç¹ï¼
ï¼1ï¼éä¿¡æ¹å¼ä¸åï¼Dubbo使ç¨RPCéä¿¡ï¼Spring Cloud使ç¨HTTP Restfulæ¹å¼
ï¼2ï¼ç»æé¨åä¸å
4ãDubboæ¯æçåè®®
dubbo:// ï¼æ¨èï¼ï¼rmi:// ï¼hessian:// ï¼.weidian.dubbo.IMyDemo" version="1.0" id="myDemo" url="dubbo://.0.0.1:/"></dubbo:reference>
ãDubboå¤åè®®
Dubboå 许é ç½®å¤åè®®ï¼å¨ä¸åæå¡å¨ä¸æ¯æä¸ååè®®ï¼æè åä¸æå¡æ¯æå¤ç§åè®®ã
ãå½ä¸ä¸ªæå¡æå¤ç§å®ç°æ¶æä¹åï¼
å½ä¸ä¸ªæ¥å£æå¤ç§æ¯ç°å®ï¼å¯ä»¥ç¨groupå±æ§æ¥åç»ï¼æå¡æä¾æ¹åæ¶è´¹æ¹é½æå®åä¸ä¸ªgroupå³å¯ã
ãå ¼å®¹æ§çæ¬
使ç¨çæ¬å·è¿åº¦ï¼å¤ä¸ªä¸åçæ¬çæå¡æ³¨åå°æ³¨åä¸å¿ï¼çæ¬å·ä¸åçæå¡ç¸äºé´ä¸å¼ç¨ã
ãDubboå¯ä»¥ç¼ååï¼
Dubboæä¾å£°æå¼ç¼åï¼ç¨äºå éçé¨æ°æ®ç访é®é度ï¼ä»¥åå°ç¨æ·å ç¼åçå·¥ä½éã
ãDubboæå¡ä¹é´çè°ç¨æ¶é»å¡çåï¼
é»è®¤æ¯åæ¥çå¾ ç»æé»å¡çï¼æ¯æå¼æ¥è°ç¨ãDubboæ¯åºäºNIOçéé»å¡å®ç°å¹¶è¡è°ç¨çï¼å®¢æ·ç«¯ä¸éè¦å¯å¨å¤çº¿ç¨å³å¯å®æ并è¡è°ç¨å¤ä¸ªè¿ç¨æå¡ï¼ç¸å¯¹å¤çº¿ç¨å¼éè¾å°ï¼å¼æ¥è°ç¨ä¼è¿åä¸ä¸ªFuture对象ã
ãDubboä¸æ¯æåå¸å¼äºå¡
ãDubboå¿ é¡»ä¾èµçå
Dubboå¿ é¡»ä¾èµJDKï¼å ¶ä»ä¸ºå¯éã
ãDubbo使ç¨è¿ç¨ä¸çé®é¢
Dubboç设计ç®çæ¯ä¸ºäºæ»¡è¶³é«å¹¶åå°æ°æ®éçrpc请æ±ï¼å¨å¤§æ°æ®éä¸æ§è½è¡¨ç°ä¸æ¯å¾å¥½ï¼å»ºè®®ä½¿ç¨rmiæ/artifact/com.alibaba.boot/dubbo-spring-boot-project -->
<dependency>
<groupId>com.alibaba.boot</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>0.1.0</version>
</dependency>
<!-- /artifact/com.tec/zkclient -->
<dependency>
<groupId>com.tec</groupId>
<artifactId>zkclient</artifactId>
<version>0.</version>
</dependency>
ï¼2ï¼é ç½®dubbo
## Dubbo æå¡æä¾è é ç½®
spring.dubbo.application.name=provider
spring.dubbo.registry.address=zookeeper://.0.0.1:
spring.dubbo.protocol.name=dubbo
spring.dubbo.protocol.port=
spring.dubbo.scan=org.spring.springboot.dubbo
## Dubbo æå¡æ¶è´¹è é ç½®
spring.dubbo.application.name=consumer
spring.dubbo.registry.address=zookeeper://.0.0.1:
spring.dubbo.scan=org.spring.springboot.dubbo