三、如何使用Dubbo

由於Dubbo無縫的集成了spring，所以我們使用起來還是很方便的，

本地服務：(Spring配置)

local.xml

<!-- 增加暴露遠程服務配置 -->
<bean id=「xxxService」 class=「com.xxx.XxxServiceImpl」 /> <bean id=「xxxAction」 class=「com.xxx.XxxAction」> <property name=「xxxService」 ref=「xxxService」 /> </bean>


遠程服務：(Spring配置)

在本地服務的基礎上，只需做簡單配置，即可完成遠程化：

• 將上面的local.xml配置拆分成兩份，將服務定義部分放在服務提供方remote-provider.xml，將服務引用部分放在服務消費方remote-consumer.xml。
• 並在提供方增加暴露服務配置<dubbo:service>，在消費方增加引用服務配置<dubbo:reference>。

如下：

服務提供者：remote-provider.xml

<bean id=「xxxService」 class=「com.xxx.XxxServiceImpl」 />
<!-- 和本地服務一樣實現遠程服務 -->
<dubbo:service interface=「com.xxx.XxxService」 ref=「xxxService」 />


服務消費者：remote-consumer.xml

<dubbo:reference id=「xxxService」 interface=「com.xxx.XxxService」 />
<!-- 增加引用遠程服務配置 -->
<bean id=「xxxAction」 class=「com.xxx.XxxAction」>
<!-- 和本地服務一樣使用遠程服務 -->
<property name=「xxxService」 ref=「xxxService」 />
</bean>


Dubbo採用全Spring配置方式，透明化接入應用，對應用沒有任何API侵入，只需用Spring載入Dubbo的配置即可，Dubbo基於Spring的Schema擴展進行載入。

1.示例

服務提供者

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

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

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

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協議在埠暴露服務 -->
<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配置：

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注入)

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 );
// 顯示調用結果
}
}


2.其他廣播方式

示例中使用的是multicast廣播暴露和發現服務的，當然還有其他的方式，現在使用最多的是ZooKeeper

如果使用ZooKeeper則配置修改為：

<dubbo:registry address="multicast://224.5.6.7:1234" />
替換為
<dubbo:registry protocol="zookeeper" address="192.168.17.129:2181,192.168.17.129:2182,192.168.17.129:2183" />
或者
<dubbo:registry address="zookeeper://192.168.17.129:2181?backup=192.168.17.129:2182,192.168.17.129:2183" />


服務提供者和服務消費者做相同的修改

3.說明

以上是Dubbo的XML配置，Dubbo還支持屬性配置，註解配置，API配置，下面介紹下API配置，另外兩種配置方式，感興趣的朋友可以去Dubbo官網去看下：Dubbo

如果不想使用Spring配置，而希望通過API的方式進行調用（官方不推薦）則

(1) 服務提供者：

import com.alibaba.dubbo.rpc.config.ApplicationConfig;
import com.alibaba.dubbo.rpc.config.RegistryConfig;
import com.alibaba.dubbo.rpc.config.ProviderConfig;
import com.alibaba.dubbo.rpc.config.ServiceConfig;
import com.xxx.XxxService;
import com.xxx.XxxServiceImpl;
// 服務實現
XxxService xxxService = new XxxServiceImpl();
// 當前應用配置
ApplicationConfig application = new ApplicationConfig();
application.setName("xxx");
// 連接註冊中心配置
RegistryConfig registry = new RegistryConfig();
registry.setAddress("10.20.130.230:9090");
registry.setUsername("aaa");
registry.setPassword("bbb");
// 服務提供者協議配置
ProtocolConfig protocol = new ProtocolConfig();
protocol.setName("dubbo");
protocol.setPort();
protocol.setThreads();
// 注意：ServiceConfig為重對象，內部封裝了與註冊中心的連接，以及開啟服務埠
// 服務提供者暴露服務配置
ServiceConfig<XxxService> service = new ServiceConfig<XxxService>();
// 此實例很重，封裝了與註冊中心的連接，請自行緩存，否則可能造成內存和連接泄漏
service.setApplication(application); service.setRegistry(registry);
// 多個註冊中心可以用setRegistries()
service.setProtocol(protocol);
// 多個協議可以用setProtocols()
service.setInterface(XxxService.class);
service.setRef(xxxService);
service.setVersion("1.0.0");
// 暴露及註冊服務
service.export();


(2) 服務消費者：

import com.alibaba.dubbo.rpc.config.ApplicationConfig;
import com.alibaba.dubbo.rpc.config.RegistryConfig;
import com.alibaba.dubbo.rpc.config.ConsumerConfig;
import com.alibaba.dubbo.rpc.config.ReferenceConfig;
import com.xxx.XxxService;
// 當前應用配置
ApplicationConfig application = new ApplicationConfig();
application.setName("yyy");
// 連接註冊中心配置
RegistryConfig registry = new RegistryConfig();
registry.setAddress("10.20.130.230:9090");
registry.setUsername("aaa"); registry.setPassword("bbb");
// 注意：ReferenceConfig為重對象，內部封裝了與註冊中心的連接，以及與服務提供方的連接
// 引用遠程服務
ReferenceConfig<XxxService> reference = new ReferenceConfig<XxxService>();
// 此實例很重，封裝了與註冊中心的連接以及與提供者的連接，請自行緩存，否則可能造成內存和連接泄漏
reference.setApplication(application); reference.setRegistry(registry);
// 多個註冊中心可以用setRegistries()
reference.setInterface(XxxService.class);
reference.setVersion("1.0.0");
// 和本地bean一樣使用xxxService
XxxService xxxService = reference.get();
// 注意：此代理對象內部封裝了所有通訊細節，對象較重，請緩存復用


四、Dubbo的一些相關疑問

1.Dubbo適用於哪些場景？

當網站變大後，不可避免的需要拆分應用進行服務化，以提高開發效率，調優性能，節省關鍵競爭資源等。

2.Dubbo的需求和依賴情況？

Dubbo運行JDK1.5之上，預設依賴javassist、netty、spring等包，但不是必須依賴，通過配置Dubbo可不依賴任何三方庫運行。

3.Dubbo的性能如何？

Dubbo通過長連接減少握手，通過NIO及線程池在單連接上並發拼包處理消息，通過二進位流壓縮數據，比常規HTTP等短連接協議更快。在阿里巴巴內部，每天支撐2000多個服務，30多億訪問量，最大單機支撐每天近1億訪問量。

4.和淘寶HSF相比，Dubbo的特點是什麼？

• Dubbo比HSF的部署方式更輕量，HSF要求使用指定的JBoss等容器，還需要在JBoss等容器中加入sar包擴展，對用戶運行環境的侵入性大，如果你要運行在Weblogic或Websphere等其它容器上，需要自行擴展容器以兼容HSF的ClassLoader載入，而Dubbo沒有任何要求，可運行在任何Java環境中。
• Dubbo比HSF的擴展性更好，很方便二次開發，一個框架不可能覆蓋所有需求，Dubbo始終保持平等對待第三方理念，即所有功能，都可以在不修改Dubbo原生代碼的情況下，在外圍擴展，包括Dubbo自己內置的功能，也和第三方一樣，是通過擴展的方式實現的，而HSF如果你要加功能或替換某部分實現是很困難的，比如支付寶和淘寶用的就是不同的HSF分支，因為加功能時改了核心代碼，不得不拷一個分支單獨發展，HSF現階段就算開源出來，也很難復用，除非對架構重寫。

• HSF依賴比較多內部系統，比如配置中心，通知中心，監控中心，單點登錄等等，如果要開源還需要做很多剝離工作，而Dubbo為每個系統的集成都留出了擴展點，並已梳理干清所有依賴，同時為開源社區提供了替代方案，用戶可以直接使用。
• Dubbo比HSF的功能更多，除了ClassLoader隔離，Dubbo基本上是HSF的超集，Dubbo也支持更多協議，更多註冊中心的集成，以適應更多的網站架構。

5.Dubbo在安全機制方面是如何解決的？

Dubbo主要針對內部服務，對外的服務，阿里有開放平台來處理安全和流控，所以Dubbo在安全方面實現的功能較少，基本上只防君子不防小人，只防止誤調用。

推薦閱讀：