熟人Dubbo 系列1-Dubbo什麼

          Dubbo阿里巴巴內部SOA治理方案和服務的核心框架。天天2000+ 個服務提供3,000,000,000+ 次訪問量支持，並被普遍應用於阿里巴巴集團的各成員網站。Dubbo自2011年開源後，已被不少非阿里系公司使用。

Dubbo[]是一個分佈式服務框架，致力於提供高性能和透明化的RPC遠程服務調用方案，以及SOA服務治理方案。

其核心部分包括:

• 遠程通信: 提供對多種基於長鏈接的NIO框架抽象封裝，包含多種線程模型。序列化。以及「請求-響應」模式的信息交換方式。
• 集羣容錯: 提供基於接口方法的透明遠程過程調用，包含多協議支持。以及軟負載均衡，失敗容錯，地址路由，動態配置等集羣支持。
• 本身主動發現: 基於註冊中心文件夾服務，使服務消費方能動態的查找服務提供方，使地址透明。使服務提供方可以平滑添加或下降機器。

Dubbo能作什麼？

• 透明化的遠程方法調用。就像調用本地方法同樣調用遠程方法，僅僅需簡單配置。沒有不論什麼API侵入。

• 軟負載均衡及容錯機制，可在內網替代F5等硬件負載均衡器，下降成本，下降單點。
• 服務本身主動註冊與發現，再也不需要寫死服務提供方地址，註冊中心基於接口名查詢服務提供者的IP地址，並且能夠平滑加入或刪除服務提供者。

高速啓動

 

Dubbo採用全Spring配置方式。透明化接入應用，相應用沒有不論什麼API侵入，僅僅需用Spring載入Dubbo的配置就能夠，Dubbo基於Spring的Schema擴展進行載入。

假設不想使用Spring配置。而但願經過API的方式進行調用（不推薦），請參見：API配置 (+)

服務提供者

 

完整安裝步驟，請參見：演示樣例提供者安裝 (+)

定義服務接口: (該接口需單獨打包，在服務提供方和消費方共享)

DemoService.java

package com.alibaba.dubbo.demo;   public interface DemoService {        String sayHello(String name);   }

在服務提供方實現接口：(對服務消費方隱藏實現)

DemoServiceImpl.java

package com.alibaba.dubbo.demo.provider;   import com.alibaba.dubbo.demo.DemoService;   public class DemoServiceImpl implements DemoService {        public String sayHello(String name) {          return "Hello " + name;      }   }

用Spring配置聲明暴露服務：

provider.xml

<? 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:application name = "hello-world-app"  />        <!-- 使用multicast廣播註冊中心暴露服務地址 -->      < dubbo:registry address = "multicast://224.5.6.7:1234" />        <!-- 用dubbo協議在20880port暴露服務 -->      < dubbo:protocol name = "dubbo" port = "20880" />        <!-- 聲明需要暴露的服務接口 -->      < dubbo:service interface = "com.alibaba.dubbo.demo.DemoService" ref = "demoService" />        <!-- 和本地bean同樣實現服務 -->      < bean id = "demoService" class = "com.alibaba.dubbo.demo.provider.DemoServiceImpl" />   </ beans >

載入Spring配置：

Provider.java

import org.springframework.context.support.ClassPathXmlApplicationContext;   public class Provider {        public static void main(String[] args) throws Exception {          ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext( new String[] { "http://10.20.160.198/wiki/display/dubbo/provider.xml" });          context.start();            System.in.read(); // 按隨意鍵退出      }   }

服務消費者

 

完整安裝步驟。請參見：演示樣例消費者安裝 (+)

經過Spring配置引用遠程服務：

consumer.xml

<? 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:application name = "consumer-of-helloworld-app"  />        <!-- 使用multicast廣播註冊中心暴露發現服務地址 -->      < dubbo:registry address = "multicast://224.5.6.7:1234" />        <!-- 生成遠程服務代理。可以和本地bean同樣使用demoService -->      < dubbo:reference id = "demoService" interface = "com.alibaba.dubbo.demo.DemoService" />   </ beans >

載入Spring配置，並調用遠程服務：(也可以使用IoC注入)

Consumer.java

import org.springframework.context.support.ClassPathXmlApplicationContext; import com.alibaba.dubbo.demo.DemoService;   public class Consumer {        public static void main(String[] args) throws Exception {          ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext( new String[] { "http://10.20.160.198/wiki/display/dubbo/consumer.xml" });          context.start();            DemoService demoService = (DemoService)context.getBean( "demoService" ); // 獲取遠程服務代理          String hello = demoService.sayHello( "world" ); // 運行遠程方法            System.out.println( hello ); // 顯示調用結果      }   }

版權聲明：本文博客原創文章，博客，未經贊成，不得轉載。