特性說明
通過對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" />
<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 技能
轉載請註明出處,本文鏈接:https://www.uj5u.com/houduan/541254.html
標籤:其他
下一篇:使用java代碼呼叫rabbitmq介面進行新增編輯mq用戶、虛擬機vhost、動態創建交換機exchange、佇列queue以及設定權限,系結vhost與exchange等操作
