系統間通信dubbo

如何實現遠程通信？

1、Webservice：效率不高基於soap協議。項目中不推薦使用。

2、使用restful形式的服務：http+json。很多項目中應用。如果服務太多，服務之間調用關系混亂，需要治療服務。

3、使用dubbo。使用rpc協議進行遠程調用，直接使用socket通信。傳輸效率高，並且可以統計出系統之間的調用關系、調用次數。

1.1.1.   什么是dubbo

隨着互聯網的發展，網站應用的規模不斷擴大，常規的垂直應用架構已無法應對，分布式服務架構以及流動計算架構勢在必行，亟需一個治理系統確保架構有條不紊的演進。

 

• 單一應用架構
• 當網站流量很小時，只需一個應用，將所有功能都部署在一起，以減少部署節點和成本。
• 此時，用於簡化增刪改查工作量的 數據訪問框架(ORM) 是關鍵。
• 垂直應用架構

• 當訪問量逐漸增大，單一應用增加機器帶來的加速度越來越小，將應用拆成互不相干的幾個應用，以提升效率。
• 此時，用於加速前端頁面開發的 Web框架(MVC) 是關鍵。

• 分布式服務架構

• 當垂直應用越來越多，應用之間交互不可避免，將核心業務抽取出來，作為獨立的服務，逐漸形成穩定的服務中心，使前端應用能更快速的響應多變的市場需求。
• 此時，用於提高業務復用及整合的 分布式服務框架(RPC) 是關鍵。

• 流動計算架構

• 當服務越來越多，容量的評估，小服務資源的浪費等問題逐漸顯現，此時需增加一個調度中心基於訪問壓力實時管理集群容量，提高集群利用率。
• 此時，用於提高機器利用率的 資源調度和治理中心(SOA) 是關鍵。

Dubbo就是資源調度和治理中心的管理工具。

 

1.1.2.   Dubbo的架構

 

節點角色說明：

• Provider: 暴露服務的服務提供方。

• Consumer: 調用遠程服務的服務消費方。

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

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

• Container: 服務運行容器。

調用關系說明：

1. 服務容器負責啟動，加載，運行服務提供者。

2. 服務提供者在啟動時，向注冊中心注冊自己提供的服務。

3. 服務消費者在啟動時，向注冊中心訂閱自己所需的服務。

4. 注冊中心返回服務提供者地址列表給消費者，如果有變更，注冊中心將基於長連接推送變更數據給消費者。

5. 服務消費者，從提供者地址列表中，基於軟負載均衡算法，選一台提供者進行調用，如果調用失敗，再選另一台調用。

6. 服務消費者和提供者，在內存中累計調用次數和調用時間，定時每分鍾發送一次統計數據到監控中心。

1.1.3.   使用方法

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

 

單一工程中spring的配置

<bean id="xxxService" class="com.xxx.XxxServiceImpl" />

<bean id="xxxAction" class="com.xxx.XxxAction">

        <property name="xxxService" ref="xxxService" />

</bean>

 

遠程服務：

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

將上面的local.xml配置拆分成兩份，將服務定義部分放在服務提供方remote-provider.xml，將服務引用部分放在服務消費方remote-consumer.xml。

並在提供方增加暴露服務配置<dubbo:service>，在消費方增加引用服務配置<dubbo:reference>。

發布服務：

<!-- 和本地服務一樣實現遠程服務 -->

<bean id="xxxService" class="com.xxx.XxxServiceImpl" />

<!-- 增加暴露遠程服務配置 -->

<dubbo:service interface="com.xxx.XxxService" ref="xxxService" />

 

調用服務：

<!-- 增加引用遠程服務配置 -->

<dubbo:reference id="xxxService" interface="com.xxx.XxxService" />

<!-- 和本地服務一樣使用遠程服務 -->

<bean id="xxxAction" class="com.xxx.XxxAction">

        <property name="xxxService" ref="xxxService" />

</bean>

 

1.1.4.   注冊中心

注冊中心負責服務地址的注冊與查找，相當於目錄服務，服務提供者和消費者只在啟動時與注冊中心交互，注冊中心不轉發請求，壓力較小。使用dubbo-2.3.3以上版本，建議使用zookeeper注冊中心。

Zookeeper是Apacahe Hadoop的子項目，是一個樹型的目錄服務，支持變更推送，適合作為Dubbo服務的注冊中心，工業強度較高，可用於生產環境，並推薦使用

 

Zookeeper的安裝：

第一步：安裝jdk

第二步：解壓縮zookeeper壓縮包

第三步：將conf文件夾下zoo_sample.cfg復制一份，改名為zoo.cfg

第四步：修改配置dataDir屬性，指定一個真實目錄，如/usr/local/zookeeper/zookeeper-3.4.6/data  ，data目錄需要自己創建一個

　　　　clientport 是客戶端連接zookeeper的端口號默認2181

第五步：

啟動zookeeper：bin/zkServer.sh start

關閉zookeeper：bin/zkServer.sh stop

查看zookeeper狀態：bin/zkServer.sh status

注意要關閉linux的防火牆。

---

關閉Linux防火牆端口：2181

/sbin/iptables -I INPUT -p tcp --dport 2181 -j ACCEPT
/etc/rc.d/init.d/iptables save
/etc/init.d/iptables status

---

 zookeeper加入到開機啟動中

一、以root用戶登錄系統：
二、進入init.d文件夾：

cd /etc/init.d/ 

三、創建並打開zookeeper文件：

vi zookeeper

四、zookeeper文件如下：　　

#!/bin/bash
#chkconfig:2345 20 90
#description:zookeeper
#processname:zookeeper
export JAVA_HOME=/usr/local/java/jdk1.7.0_72
export PATH=$JAVA_HOME/bin:$PATH
case $1 in
         start) su root /usr/local/zookeeper/zookeeper-3.4.6/bin/zkServer.sh start;;
         stop) su root /usr/local/zookeeper/zookeeper-3.4.6/bin/zkServer.sh stop;;
         status) su root /usr/local/zookeeper/zookeeper-3.4.6/bin/zkServer.sh status;;
         restart) su root /usr/local/zookeeper/zookeeper-3.4.6/bin/zkServer.sh restart;;
         *)  echo "requirestart|stop|status|restart"  ;;
esac

五、保存退出    ：wq
六、加權限，把 zookeeper修改為可運行的文件,命令參考如下：

 chmod 755 zookeeper
 chmod a+x zookeeper  

七、使用chkconfig命令把 zookeeper命令加入到系統啟動隊列中：

chkconfig --add zookeeper

八、查看zookeeper的狀態：

chkconfig --list zookeeper

九、測試

service zookeeper start
service zookeeper stop
service zookeeper restart
service zookeeper statu

springmvc，服務發布spring配置：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"
    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.2.xsd
    http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.2.xsd
    http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.2.xsd
    http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd
    http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.2.xsd">
    
    <!-- 配置包掃描器，掃描所有帶@Service注解的類 -->
    <context:component-scan base-package="com.taotao.service"/>
    
    <!-- 發布dubbo服務 -->
    <!-- 提供方應用信息，用於計算依賴關系 -->
    <dubbo:application name="taotao-manager" />
    <!-- 注冊中心的地址 -->
    <dubbo:registry protocol="zookeeper" address="192.168.66.130:2181" />
    <!-- 用dubbo協議在20880端口暴露服務 -->
    <dubbo:protocol name="dubbo" port="20880" />
    <!-- 聲明需要暴露的服務接口 -->
    <dubbo:service interface="com.taotao.service.ItemService" ref="itemServiceImpl" timeout="300000"/>
    <dubbo:service interface="com.taotao.service.ItemCatService" ref="itemCatServiceImpl" timeout="300000"/>
</beans>

服務引用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:p="http://www.springframework.org/schema/p"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    xmlns:mvc="http://www.springframework.org/schema/mvc"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.2.xsd
        http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.2.xsd
        http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.2.xsd">

    <!-- 加載屬性文件 -->
    <context:property-placeholder location="classpath:resource/resource.properties"/>
    <!-- 配置注解驅動 -->
    <mvc:annotation-driven />
    <!-- 視圖解析器 -->
    <bean
        class="org.springframework.web.servlet.view.InternalResourceViewResolver">
        <property name="prefix" value="/WEB-INF/jsp/" />
        <property name="suffix" value=".jsp" />
    </bean>
    <!-- 配置包掃描器，掃描@Controller注解的類 -->
    <context:component-scan base-package="com.taotao.controller"/>
    <!-- 配置資源映射 -->
    <mvc:resources location="/css/" mapping="/css/**"/>
    <mvc:resources location="/js/" mapping="/js/**"/>
    <!-- 多媒體解析器 -->
    <!-- 配置文件上傳解析器 -->
    <bean id="multipartResolver"
        class="org.springframework.web.multipart.commons.CommonsMultipartResolver">
        <!-- 設定默認編碼 -->
        <property name="defaultEncoding" value="UTF-8"></property>
        <!-- 設定文件上傳的最大值5MB，5*1024*1024 -->
        <property name="maxUploadSize" value="5242880"></property>
    </bean>
    <!-- 引用dubbo服務 -->
    <dubbo:application name="taotao-manager-web"/>
    <dubbo:registry protocol="zookeeper" address="192.168.66.130:2181"/>    
    
    <dubbo:reference interface="com.taotao.service.ItemService" id="itemService" />
    <dubbo:reference interface="com.taotao.service.ItemCatService" id="itemCatService" />
    <dubbo:reference interface="com.taotao.content.service.ContentService" id="contentService" />
    <dubbo:reference interface="com.taotao.content.service.ContentCategoryService" id="contentCategoryService" />
    <dubbo:reference interface="com.taotao.search.service.SearchItemService" id="searchItemService" />
</beans>