天天看點

Dubbo

    dubbo 是一個分布式服務架構,緻力于提供高性能和透明化的rpc遠端服務調用方案,以及soa服務治理方案。

    dubbo 就是個服務架構,如果沒有分布式的需求,其實是不需要用的,隻有在分布式的時候,才有dubbo這樣的分布式服務架構的需求,并且本質上是個服務調用的東東。

    說白了就是個遠端服務調用的分布式架構(告别web service模式中的wsdl,以服務者與消費者的方式在dubbo上注冊)

其核心部分包含:

    1. 遠端通訊: 提供對多種基于長連接配接的nio架構抽象封裝,包括多種線程模型,序列化,以及“請求-響應”模式的資訊交換方式。

    2. 叢集容錯: 提供基于接口方法的透明遠端過程調用,包括多協定支援,以及軟負載均衡,失敗容錯,位址路由,動态配置等叢集支援。

    3. 自動發現: 基于注冊中心目錄服務,使服務消費方能動态的查×××提供方,使位址透明,使服務提供方可以平滑增加或減少機器。

    1.透明化的遠端方法調用,就像調用本地方法一樣調用遠端方法,隻需簡單配置,沒有任何api侵入。      

    2.軟負載均衡及容錯機制,可在内網替代f5等硬體負載均衡器,降低成本,減少單點。

    3. 服務自動注冊與發現,不再需要寫死服務提供方位址,注冊中心基于接口名查詢服務提供者的ip位址,并且能夠平滑添加或删除服務提供者。

dubbo采用全spring配置方式,透明化接入應用,對應用沒有任何api侵入,隻需用spring加載dubbo的配置即可,dubbo基于spring的schema擴充進行加載。

dubbo架構圖如下所示:

Dubbo

       provider: 暴露服務的服務提供方。

       consumer: 調用遠端服務的服務消費方。

       registry: 服務注冊與發現的注冊中心。

       monitor: 統計服務的調用次調和調用時間的監控中心。

       container: 服務運作容器。

    0 服務容器負責啟動,加載,運作服務提供者。

dubbo采用全spring配置方式,透明化接入應用,對應用沒有任何api侵入,隻需用spring加載dubbo的配置即可,dubbo基于spring的schema擴充進行加載。如果不想使用spring配置,而希望通過api的方式進行調用(不推薦)

下面我們就來看看spring配置方式的寫法:

1. 下載下傳 zookeeper 注冊中心,

    下載下傳位址:http://www.apache.org/dyn/closer.cgi/zookeeper/  

    下載下傳後解壓即可,進入d:\apach-zookeeper-3.4.5\bin,

    輕按兩下zkserver.cmd啟動注冊中心服務。

package com.unj.dubbotest.provider;  

import java.util.list;  

public interface demoservice {  

    string sayhello(string name);  

    public list getusers();  

}  

import java.util.arraylist;  

import java.util.linkedlist;  

public class demoserviceimpl implements demoservice{  

     public string sayhello(string name) {  

            return "hello " + name;  

     }  

     public list getusers() {  

         list list = new arraylist();  

         list.add("u1");  

         list.add("u2");  

         list.add("u3");  

         return list;  

用spring配置聲明暴露服務:

<?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  

        ">  

    <!-- 具體的實作bean -->  

    <bean id="demoservice" class="com.unj.dubbotest.provider.demoserviceimpl" />  

    <!-- 提供方應用資訊,用于計算依賴關系 -->  

    <dubbo:application name="xixi_provider"  />  

    <!-- 使用multicast廣播注冊中心暴露服務位址   

    <dubbo:registry address="multicast://224.5.6.7:1234" />-->  

    <!-- 使用zookeeper注冊中心暴露服務位址 -->  

    <dubbo:registry address="zookeeper://127.0.0.1:2181" />   

    <!-- 用dubbo協定在20880端口暴露服務 -->  

    <dubbo:protocol name="dubbo" port="20880" />  

    <!-- 聲明需要暴露的服務接口 -->  

    <dubbo:service interface="com.unj.dubbotest.provider.demoservice" ref="demoservice" /> 

</beans>  

加載spring配置,啟動服務:

package com.unj.dubbotest.provider;  

import org.springframework.context.support.classpathxmlapplicationcontext;  

public class provider {  

    public static void main(string[] args) throws exception {  

        classpathxmlapplicationcontext context = new classpathxmlapplicationcontext(new string[] {"applicationcontext.xml"});  

        context.start();  

        system.in.read(); // 為保證服務一直開着,利用輸入流的阻塞來模拟  

    }  

}  

 applicationcontext-dubbo.xml 中注冊自己需要調用的接口,我剛開始測試的時候需要的接口很多,是以把這個檔案寫的滿滿的,後來熟悉了把接口按業務類型分開,寫了n多個 applicationcontext-dubbo-***.xml 簡練多了 》。 

1.通過spring配置引用遠端服務:

    xmlns:xsi="http://www.w3.org/2001/xmlschema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"  

    <!-- 消費方應用名,用于計算依賴關系,不是比對條件,不要與提供方一樣 -->  

    <dubbo:application name="hehe_consumer" />  

    <!-- <dubbo:registry address="multicast://224.5.6.7:1234" /> -->  

    <dubbo:registry address="zookeeper://127.0.0.1:2181" />  

    <!-- 生成遠端服務代理,可以像使用本地bean一樣使用demoservice -->  

    <dubbo:reference id="demoservice"  

        interface="com.unj.dubbotest.provider.demoservice" />  

2.加載spring配置,并調用遠端服務:

package com.alibaba.dubbo.demo.pp;  

import java.util.list;  

import com.unj.dubbotest.provider.demoservice;  

public class consumer {  

        classpathxmlapplicationcontext context = new classpathxmlapplicationcontext(  

                new string[] { "applicationcontext.xml" });  

        context.start();  

        demoservice demoservice = (demoservice) context.getbean("demoservice"); //  

        string hello = demoservice.sayhello("tom"); //   

        system.out.println(hello); //   

        //   

        list list = demoservice.getusers();  

        if (list != null && list.size() > 0) {  

            for (int i = 0; i < list.size(); i++) {  

                system.out.println(list.get(i));  

            }  

        }  

        // system.out.println(demoservice.hehe());  

        system.in.read();  

    }  

調用結果為:

Dubbo

dubbo管理頁面:

這個管理頁面還需要部署一個環境的,一開始我還以為是dubbo自帶的,找了半天沒有找到....

Dubbo

應用頁面:

Dubbo

提供者頁面:

Dubbo

消費者頁面:

Dubbo

服務頁面:

Dubbo

測試是否成功,我覺得隻要看看狀态是否正常,就ok了 ....

案例代碼下載下傳:http://download.csdn.net/detail/yiyu1/7116319

繼續閱讀