聲明 本文章中所有內容僅供學習交流,抓包內容、敏感網址、數據介面均已做脫敏處理,嚴禁用於商業用途和非法用途,否則由此產生的一切後果均與作者無關,若有侵權,請聯繫我立即刪除! 本文章未經許可禁止轉載,禁止任何修改後二次傳播,擅自使用本文講解的技術而導致的任何意外,作者均不負責,若有侵權,請在公眾號【K ...
特性說明
通過對protocol進行配置,dubbo3可以支持埠的協議復用。
比如使用Triple協議啟動埠復用後,可以在相同的埠上為服務增加
Dubbo協議支持,以及Qos協議支持。這些協議的識別都是由一個統一的埠復用
伺服器進行處理的,可以用於服務的協議遷移,並且可以節約埠以及相關的資源,減少運維的複雜性。
-
在服務的創建階段,通過從Config層獲取到服務導出的協議配置從而創建不同的Protocol對象進行導出。在導出的過程
中,如果不是第一次創建埠復用的Server,那麼Exchanger會將Protcol層傳遞的數據保存到Server,用於後續處理該協議類型的消息。 -
當客戶端的消息傳遞過來後,首先會通過Server傳遞給ProtocolDetector,如果完成了識別,那麼就會標記該客戶端為對應的協議。並通過WireProtocol配置對應的處理邏輯,最後交給ChannelOperator完成底層的IO框架和對應的Dubbo框架的處理邏輯的綁定。
-
以上的協議識別完成之後,Channel已經確定瞭如何處理遠程的客戶端消息,通過對應的ServerPipeline進行處理即可(在處理的過程中也會根據配置信息決定消息的處理線程)。
使用方式
在同一主機上部署多個服務或需要通過負載均衡器訪問多個服務。
參考用例
https://github.com/apache/dubbo-samples/tree/master/dubbo-samples-port-unification
配置方式
關於Dubbo支持的配置方式,可以參考配置說明
服務多協議導出
ext-protocol參數支持配置多個不同的協議,協議之間通過","進行分隔。
xml 配置
<dubbo:protocol name="dubbo" port="-1" ext-protocol="tri,"/>
<bean id="greetingService" class="org.apache.dubbo.demo.provider.GreetingServiceImpl"/>
<dubbo:service delay="5000" version="1.0.0" group="greeting" timeout="5000" interface="org.apache.dubbo.demo.GreetingService" ref="greetingService" protocol="dubbo"/>
API 配置
ProtocolConfig config = new ProtocolConfig(CommonConstants.TRIPLE, -1);
config.setExtProtocol(CommonConstants.DUBBO+",");
yaml 配置
dubbo:
application:
name: dubbo-springboot-demo-provider
protocol:
name: tri
port: -1
ext-protocol: dubbo,
properties 配置
dubbo.protocol.name=tri
dubbo.protocol.ext-protocol=dubbo,
dubbo.protocol.port=20880
Qos接入
Qos模塊導入
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-qos</artifactId>
</dependency>
完成Qos模塊的導入之後,相關的配置項可參考Qos操作手冊進行配置。
預設情況下,基於埠復用的Qos服務在模塊導入後是啟動的。
使用方式
Qos使用
將Qos協議接入到埠復用的場景下,需要在建立連接之後,客戶端先向服務端發送消息,對比將Qos協議通過單個埠提供服務,埠復用版的Qos協議在處理telnet連接的情況下需要用戶執行一些操作,完成協議識別(二選一)。
-
直接調用命令
直接調用telnet支持的命令也可以完成識別,在用戶不熟悉的情況下可以調用help指令完成識別
-
發送telnet命令識別
通過telnet命令建立連接之後,執行以下幾個步驟:
- 使用 crtl + "]" 進入到telnet交互界面(telnet預設的escape character)
- 調用 "send ayt" 向服務端發送特殊識別欄位(為telnet協議的一個特殊欄位)
- 回車完成消息發送併進入到dubbo的交互界面
服務引用
以dubbo-samples-port-unification中的例子作為基礎, 引用不同協議的服務和非埠復用情況下的配置是一致的,下麵通過Consumer端的InvokerListener輸出調用過程中的URL信息。
ReferenceConfig<GreetingService> reference = new ReferenceConfig<>();
reference.setInterface(GreetingService.class);
reference.setListener("consumer");
reference.setProtocol(this.protocol);
// reference.setProtocol(CommonConstants.DUBBO);
// reference.setProtocol(CommonConstants.TRIPLE);
歡迎在 https://github.com/apache/dubbo 給 Dubbo Star。
搜索關註官方微信公眾號:Apache Dubbo,瞭解更多業界最新動態,掌握大廠面試必備 Dubbo 技能