文章目錄

• • • 1. dubbo的Qos
    • 2.dubbo Qos簡單使用
    • • 2.1 ls
      • 2.2 online
      • 2.3 offline
      • 2.4 help
      • 2.5 quit
    • 3.dubbo Qos 源碼剖析
    • • 3.1 Qos服務器創建時機
      • 3.2 QosProtocolWrapper
      • 3.3 com.alibaba.dubbo.qos.server.Server
      • 3.4 com.alibaba.dubbo.qos.server.handler.QosProcessHandler
      • 3.4 BaseCommand
      • • 3.4.1 ls
        • 3.4.2 online
        • 3.4.3 offline
        • 3.4.4 help
        • 3.4.5 quit
    • 4.總結

注：本文基于dubbo v2.6.1

1. dubbo的Qos

QoS的英文全稱為"Quality of Service",中文名為"服務質量"。在dubbo 2.5.8 新版本增加了 QOS 模塊，提供了新的 telnet 命令支持。dubbo管它叫在線運維命令，我們可以通過它能夠看到服務提供者狀態，服務調用者狀態，現在dubbo提供了 ls ， online，offline，help ，quit命令。

命令

用途

ls

能夠列出來該實例服務提供者與調用者狀態

online

服務上線，可以指定某個接口，也可以什么也不指定，這樣就是全部

offline

服務下線，可以指定某個接口，也可以什么也不指定，這樣就是全部

help

查看命令的用途，不帶參數顯示全部命令，帶參數只顯示指定的

quit

退出Qos

2.dubbo Qos簡單使用

我們可以在dubbo的配置文件配置參數，我這里是使用的xml的形式，其他形式可以看下官網文檔：官網文檔（文檔講的很詳細，而且是中文）

<dubbo:application name="dubbo-consumer"><dubbo:parameter key="qos.enable" value="true"/><dubbo:parameter key="qos.accept.foreign.ip" value="false"/><dubbo:parameter key="qos.port" value="8108"/> </dubbo:application>

qos.enable ：表示是否開始Qos
qos.accept.foreign.ip： 允許訪問的ip，缺省就是false，表示任何ip都可訪問
qos.port： Qos提供服務的端口
接下來我啟動服務，然后在終端上使用telnet的方式連接dubbo Qos

2.1 ls

可以看到服務提供服務與調用服務的狀態
這個 Provider Service Name 就是服務提供者名字 ， PUB 就是狀態 N是未注冊，就是沒有注冊到注冊中心，其實服務下線功能就是從注冊中心unregister ，Y表示服務在線，就是注冊到注冊中心了。

2.2 online

服務上線，就是將服務注冊到注冊中心上去，后面可以帶個參數，參數是指定具體上線的接口，不帶參數表示全部服務接口（這個得是你標識的，比如說使用了dubbo @Service注解）都注冊到注冊中心去。
我們ls小節的時候可以看到com.xuzhaocai.dubbo.provider.IUserInfoService 是N，我們可以使用online來進行服務上線


我們可以看到服務狀態是Y了，這其實就是注冊中心 調用register()，我們在后面可以看到具體代碼實現。

2.3 offline

offline 是服務下線，跟online一個使用方法，這里就不再贅述了。

2.4 help

幫助，可以指定具體的cmd，這樣就顯示指定cmd的幫助

不指定的話顯示全部的命令

2.5 quit

退出Qos，你不用這個quit可以試試，看看能不能退出去，我mac直接使用ctrl+c 反正不行。
注： 我這里就不再詳細說明這個用法了，這東西官網文檔很詳細，而且使用也簡單，主要是場景 ，直接源碼搞起

3.dubbo Qos 源碼剖析

3.1 Qos服務器創建時機

其實在dubbo進行服務暴露與服務引用的時候，我們都見過Exporter<?> exporter = protocol.export(wrapperInvoker); （com.alibaba.dubbo.config.ServiceConfig#doExportUrlsFor1Protocol）或者refprotocol.refer(interfaceClass, urls.get(0));（com.alibaba.dubbo.config.ReferenceConfig#createProxy) ，我們知道這個protocol成員是這個樣子

根據dubbo spi 自適應的規則，實際上執行的是 url中protocol 參數值對應的那個實現類，我們這個場景下就是RegistryProtocol 實現類，然后dubbo spi 還會幫你setter 注入 ，wrapper 包裝
我們可以看下都有哪些Protocol 包裝實現類

v2.6.1 這個版本就這些。
我們獲得的RegistryProtocol對象，其實外面是包了這幾個wrapper類，就像下圖這個樣子（當然這個順序不一定是這個樣子的，他這邊沒有對順序做要求）

所以我們在服務暴露或者服務引用的時候，就會走這個QosProtocolWrapper類。

3.2 QosProtocolWrapper

我們可以看到export與refer方法，判斷如果protocol=registry，接著進入這個startQosServer(url)
看下這 startQosServer方法。

這個方法中我們可以看到就是判斷qos.enable 啟動參數，然后 判斷是否已經啟動，這個玩意一個服務實例就只能啟動一次，再就是獲得一個Server對象，將用戶設置的一些參數值設置進去，然后調用start方法。
我們來看下這個Server類

3.3 com.alibaba.dubbo.qos.server.Server

我們這里是創建了一個netty的server，開始的時候使用cas判斷啟動狀態，添加了一個QosProcessHandler消息處理類，我們的命令就是到這里面處理的。我們看下這個QosProcessHandler 類，傳入參數就是welcome歡迎語跟允許的ip。
我們來看下的這個QosProcessHandler消息處理類

3.4 com.alibaba.dubbo.qos.server.handler.QosProcessHandler

當消息連接上的時候，會調用channelActive方法，我們可以看到，它將這個welcome 歡迎語與 dubbo> 這個開始頭發出去了。

也就是這個東西

接著我們再輸入命令的時候，就會到decode 方法中，首先判斷buffer里面有沒有能讀的字節，如果沒有直接返回，獲取一個字節，判斷是不是http請求，因為Dubbo Qos 是支持http 與telnet的。

這里就會相應的添加handler，我們可以看到，他這個handler是動態添加與刪除的，每一次訪問都要添加與刪除。
我們這里使用的是telnet ，我們看下telnet的是怎樣實現的，http 的也就同理了。
接下來我們看下這個TelnetProcessHandler 處理類，那四個都是netty的，做相應輔助功能的，比如說使用行解析，使用utf-8解碼，然后空閑時間，TelnetProcessHandler 是主要處理我們命令的

@Overrideprotected void channelRead0(ChannelHandlerContext ctx, String msg) throws Exception {if (StringUtils.isBlank(msg)) {// 是否是空消息ctx.writeAndFlush(QosProcessHandler.prompt);// 將dubbo> 寫回去} else {CommandContext commandContext = TelnetCommandDecoder.decode(msg);commandContext.setRemote(ctx.channel());// 設置channeltry {String result = commandExecutor.execute(commandContext);if (StringUtils.equals(QosConstants.CLOSE, result)) {// 是否返回closectx.writeAndFlush(getByeLabel()).addListener(ChannelFutureListener.CLOSE);} else {// 將結果寫回去 xxx /r/n dubbo>ctx.writeAndFlush(result + QosConstants.BR_STR + QosProcessHandler.prompt);}} catch (NoSuchCommandException ex) {ctx.writeAndFlush(msg + " :no such command");ctx.writeAndFlush(QosConstants.BR_STR + QosProcessHandler.prompt);log.error("can not found command " + commandContext, ex);} catch (Exception ex) {ctx.writeAndFlush(msg + " :fail to execute commandContext by " + ex.getMessage());ctx.writeAndFlush(QosConstants.BR_STR + QosProcessHandler.prompt);log.error("execute commandContext got exception " + commandContext, ex);}}}

這里首先判斷消息是不是空，空消息就將 dubbo>這個返回給客戶端
然后將消息解析成 CommandContext， 也就是CommandContext commandContext = TelnetCommandDecoder.decode(msg); 這句，就是將消息解析成cmd與參數，調用CommandContext工廠創建CommandContext 對象。
接著就是使用CommandExecutor 執行這個命令，也就是這句String result = commandExecutor.execute(commandContext);
我們來看下這個DefaultCommandExecutor的execute方法，先是通過命令獲取對應的BaseCommand實現類，沒有找到對應的話就拋出NoSuch的異常。有的話直接調用execute執行。

這個BaseCommand我們后面再說，這個執行結果返回，接著回到TelnetProcessHandler 的channelRead0方法中，如果這個執行結果是close的話，就寫回"BYE! ";這個字符串，并且添加ChannelFutureListener.CLOSE 這個listener。
如果是正常執行結果的話，寫回去就可以了。
現在我們來看下這個BaseCommand的定義以它的子類們

3.4 BaseCommand

這個是就是命令的接口，是基于dubbo spi的，所有Qos命令都要實現它，然后重寫execute方法。

看下它的實現類

下面我們就挨個看看

3.4.1 ls

ls 這個命令是獲取該實例服務提供者接口與調用者接口及狀態。
我們來看看代碼實現

調用了listProvider()獲取了服務提供者接口，調用了服務調用者接口。
我們這里拿獲取服務提供者接口看看：

public String listProvider() {StringBuilder stringBuilder = new StringBuilder();stringBuilder.append("As Provider side: ");//通過ApplicationModel獲取所有的provider，這個是服務注冊上的時候添加到ApplicationModel 里面的Collection<ProviderModel> ProviderModelList = ApplicationModel.allProviderModels();TTable tTable = new TTable(new TTable.ColumnDefine[]{new TTable.ColumnDefine(TTable.Align.MIDDLE),new TTable.ColumnDefine(TTable.Align.MIDDLE)});//HeadertTable.addRow("Provider Service Name", "PUB");//Contentfor (ProviderModel providerModel : ProviderModelList) {tTable.addRow(providerModel.getServiceName(), isReg(providerModel.getServiceName()) ? "Y" : "N");}stringBuilder.append(tTable.rendering());return stringBuilder.toString();}

這邊有兩個點： 一個是通過ApplicationModel 獲取所有的provider，這個ApplicationModel 類，里面其實維護了幾個map，其中就有本實例服務提供者與服務調用者接口列表，當我們在暴露服務完成的時候，就會向ApplicationModel 這個類里面添加對應的服務提供者的信息，也就是走的這個方法

每當我們服務引用完，創建完proxy代理類的時候，就會往ApplicationModel 這個類里面添加對應的服務調用者的信息，也就是走的這個方法

所以我們就能拿到本實例的服務提供者接口了。接著往下看就是創建TTable ，是兩列的，然后遍歷服務提供者接口列表添加行。
到最后就是rendering 渲染了，在循環的時候其實還有一個點，使用isReg(providerModel.getServiceName()) “Y” : “N”) 是否在線，這里面判斷的其實還是invoker包裝類的isReg，注冊到注冊中心后設置這個標識。

同理本實例服務提供者也是這個樣子獲取的，到這里我們這個ls命令處理就完成了。

3.4.2 online

com.alibaba.dubbo.qos.command.impl.Online 服務上線。

這個online 命令使用參數的，如果用戶沒有指定，就是.*，在下面匹配上就會匹配到。
首先是判斷參數，接著就是從ApplicationModel 獲取本實例服務提供者列表，遍歷，看看是否符合你傳過來的參數，，符合就設置hasService = true，接著就是根據serviceName從本地注冊表中獲取對應的ProviderInvokerWrapper列表，遍歷判斷如果對應的狀態是在線的（這里還是判斷的isReg），就跳過，否則獲取對應的注冊中心，進行注冊，同時將isReg狀態設置成true。

3.4.3 offline

com.alibaba.dubbo.qos.command.impl.Offline 服務下線，我們看下代碼，它這個與online差不多，它這個循環判斷服務沒有在線就跳過去，在線的就調用注冊中心的unregister()方法進行服務下線，同時設置isReg服務在線狀態為false。

3.4.4 help

com.alibaba.dubbo.qos.command.impl.Help 幫助文檔作用，可以傳參數 指定需要幫助的命令，也可以不指定，那就是顯示全部命令的幫助。直接上代碼

我們看下這行所有命令的，這個指定命令的原理也差不多

就是使用CommandHelper.getAllCommandClass() 獲取所有的BaseCommand 子類class對象，他這個使用dubbo spi獲取所有子類的

然后獲取子類上面的@Cmd注解，就像offline上面這個，name就是命令，summary就是說明 ，example 就是列子

3.4.5 quit

com.alibaba.dubbo.qos.command.impl.Quit 退出 ，這就是直接返回了close，然后TelnetProcessHandler就會處理這個close進行退出。

4.總結

到這里我們dubbo 在線運維Qos 就解析完成了，概括一下，首先是講了 dubbo Qos ，然后簡單使用了一下，最后就是咱們的源碼解析了，從Qos服務器啟動時機到每一個commad命令的執行原理。這個Qos 使用簡單，主要還是它的使用場景，正如dubbo 官方文檔說的，服務上線 服務下線的使用場景。

總結

以上是生活随笔為你收集整理的深度解析dubbo在线运维Qos的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。