溫馨提示×

您好，登錄后才能下訂單哦！

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

Dubbox與Zookeeper簡(jiǎn)介及入門小案例

發(fā)布時(shí)間：2020-07-28 20:35:02 來(lái)源：網(wǎng)絡(luò) 閱讀：1384 作者：Adam的blog 欄目：開(kāi)發(fā)技術(shù)

Dubbox

一：簡(jiǎn)介
       Dubbox 是一個(gè)分布式服務(wù)框架，其前身是阿里巴巴開(kāi)源項(xiàng)目Dubbo ，被國(guó)內(nèi)電商及互聯(lián)網(wǎng)項(xiàng)目中使用，后期阿里巴巴停止了該項(xiàng)目的維護(hù)，當(dāng)當(dāng)網(wǎng)便在Dubbo基礎(chǔ)上進(jìn)行優(yōu)化，并繼續(xù)維護(hù)，為了與原有的Dubbo區(qū)分，故將其命名為Dubbox。 
       Dubbox 致力于提供高性能和透明化的RPC遠(yuǎn)程服務(wù)調(diào)用方案，以及SOA服務(wù)治理方案。說(shuō)白了就是個(gè)遠(yuǎn)程服務(wù)調(diào)用的分布式框架。
 
Dubbox與Zookeeper簡(jiǎn)介及入門小案例
 
節(jié)點(diǎn)角色說(shuō)明：
? Provider: 暴露服務(wù)的服務(wù)提供方。
? Consumer: 調(diào)用遠(yuǎn)程服務(wù)的服務(wù)消費(fèi)方。
? Registry: 服務(wù)注冊(cè)與發(fā)現(xiàn)的注冊(cè)中心。
? Monitor: 統(tǒng)計(jì)服務(wù)的調(diào)用次調(diào)和調(diào)用時(shí)間的監(jiān)控中心。
? Container: 服務(wù)運(yùn)行容器。
 
調(diào)用關(guān)系說(shuō)明：
? 0. 服務(wù)容器負(fù)責(zé)啟動(dòng)，加載，運(yùn)行服務(wù)提供者。
? 1. 服務(wù)提供者在啟動(dòng)時(shí)，向注冊(cè)中心注冊(cè)自己提供的服務(wù)。
? 2. 服務(wù)消費(fèi)者在啟動(dòng)時(shí)，向注冊(cè)中心訂閱自己所需的服務(wù)。
? 3. 注冊(cè)中心返回服務(wù)提供者地址列表給消費(fèi)者，如果有變更，注冊(cè)中心將基于長(zhǎng)連接推
送變更數(shù)據(jù)給消費(fèi)者。
? 4. 服務(wù)消費(fèi)者，從提供者地址列表中，基于軟負(fù)載均衡算法，選一臺(tái)提供者進(jìn)行調(diào)用，
如果調(diào)用失敗，再選另一臺(tái)調(diào)用。
? 5. 服務(wù)消費(fèi)者和提供者，在內(nèi)存中累計(jì)調(diào)用次數(shù)和調(diào)用時(shí)間，定時(shí)每分鐘發(fā)送一次統(tǒng)計(jì)
數(shù)據(jù)到監(jiān)控中心。

Zookeeper

一：簡(jiǎn)介
       Zookeeper 是 Apacahe Hadoop 的子項(xiàng)目，是一個(gè)樹(shù)型的目錄服務(wù)，適合作為Dubbox 服務(wù)的注冊(cè)中心，注冊(cè)中心負(fù)責(zé)服務(wù)地址的注冊(cè)與查找，相當(dāng)于目錄服務(wù)，服務(wù)提供者和消費(fèi)者只在啟動(dòng)時(shí)與注冊(cè)中心交互，注冊(cè)中心不轉(zhuǎn)發(fā)請(qǐng)求，壓力較小。
二： Zookeeper 在Linux系統(tǒng)的安裝

  1. Linux中安裝 jdk
  2. 把 zookeeper 的壓縮包上傳到 linux 系統(tǒng)。
  3. 解壓縮壓縮包：

    tar -zxvf zookeeper-3.4.6.tar.gz

  4. 進(jìn)入 zookeeper-3.4.6 目錄，創(chuàng)建 data 文件夾。

    mkdir data

  5. 進(jìn)入conf目錄 ，把 zoo_sample.cfg 改名為 zoo.cfg

    mv zoo_sample.cfg zoo.cfg

  6. 打開(kāi)zoo.cfg , 修改 data 屬性：

    dataDir=/root/zookeeper-3.4.6/data

三：Zookeeper 服務(wù)啟動(dòng)
進(jìn)入bin目錄，啟動(dòng)服務(wù)輸入命令

./zkServer.sh start

Demo

一：創(chuàng)建服務(wù)提供者的Maven工程
1：pom文件

<properties>        
        <spring.version>4.2.4.RELEASE</spring.version>
   </properties>

    <dependencies>
        <!-- Spring -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-beans</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-webmvc</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-aspects</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jms</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context-support</artifactId>
            <version>${spring.version}</version>
        </dependency>   

        <!-- dubbo相關(guān) -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.8.4</version>            
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.6</version>
        </dependency>
        <dependency>
            <groupId>com.github.sgroschupf</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.1</version>
        </dependency>

        <dependency>
            <groupId>javassist</groupId>
            <artifactId>javassist</artifactId>
            <version>3.11.0.GA</version>
        </dependency>

    </dependencies>
   <build>  
      <plugins>
          <plugin>  
              <groupId>org.apache.maven.plugins</groupId>  
              <artifactId>maven-compiler-plugin</artifactId>  
              <version>2.3.2</version>  
              <configuration>  
                  <source>1.7</source>  
                  <target>1.7</target>  
              </configuration>  
          </plugin>  
          <plugin>
                <groupId>org.apache.tomcat.maven</groupId>
                <artifactId>tomcat7-maven-plugin</artifactId>
                <configuration>
                    <!-- 指定端口 -->
                    <port>8081</port>
                    <!-- 請(qǐng)求路徑 -->
                    <path>/</path>
                </configuration>
          </plugin>
      </plugins>  
    </build>

2：web.xml

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns="http://java.sun.com/xml/ns/javaee"
    xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
    version="2.5">  

    <!-- 加載spring容器 -->
    <context-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>classpath:applicationContext*.xml</param-value>
    </context-param>
    <listener>
        <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
    </listener>

</web-app>

3：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.xsd
        http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.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.xsd">

    <!-- 當(dāng)前的應(yīng)用名稱 -->
    <dubbo:application name="dubboxdemo-service" />
    <!-- 指定的注冊(cè)中心地址 -->
    <dubbo:registry address="zookeeper://192.168.25.128:2181"/>
    <!-- dubbox的包掃描 -->
    <dubbo:annotation package="com.zgz.demo.serviceImpl" />

</beans>

4：代碼及目錄結(jié)構(gòu)
Dubbox與Zookeeper簡(jiǎn)介及入門小案例
Dubbox與Zookeeper簡(jiǎn)介及入門小案例
Dubbox與Zookeeper簡(jiǎn)介及入門小案例
二：創(chuàng)建服務(wù)消費(fèi)者的Maven工程
1：pom文件和上面的一致
2：web.xml文件

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns="http://java.sun.com/xml/ns/javaee"
    xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
    version="2.5">  
   <!-- 解決post亂碼 -->
    <filter>
        <filter-name>CharacterEncodingFilter</filter-name>
        <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
        <init-param>
            <param-name>encoding</param-name>
            <param-value>utf-8</param-value>
        </init-param>
        <init-param>  
            <param-name>forceEncoding</param-name>  
            <param-value>true</param-value>  
        </init-param>  
    </filter>
    <filter-mapping>
        <filter-name>CharacterEncodingFilter</filter-name>
        <url-pattern>/*</url-pattern>
    </filter-mapping>   

  <servlet>
    <servlet-name>springmvc</servlet-name>
    <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
    <!-- 指定加載的配置文件 ，通過(guò)參數(shù)contextConfigLocation加載-->
    <init-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>classpath:springmvc.xml</param-value>
    </init-param>
  </servlet>

  <servlet-mapping>
    <servlet-name>springmvc</servlet-name>
    <url-pattern>*.do</url-pattern>
  </servlet-mapping>

</web-app>

3：SpringMvc配置文件

<?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.xsd
        http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.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.xsd">

    <!-- 轉(zhuǎn)換器的配置：把返回值轉(zhuǎn)換成字符串輸出 -->
    <mvc:annotation-driven >
        <mvc:message-converters register-defaults="false">
            <bean class="org.springframework.http.converter.StringHttpMessageConverter">  
                <constructor-arg value="UTF-8" />
            </bean>  
        </mvc:message-converters>   
    </mvc:annotation-driven>

    <!-- 當(dāng)前的應(yīng)用名稱 -->
    <dubbo:application name="dubboxdemo-web" />
    <!-- 指定的注冊(cè)中心地址 -->
    <dubbo:registry address="zookeeper://192.168.25.128:2181"/>
    <!-- dubbox的包掃描 -->
    <dubbo:annotation package="com.zgz.demo.controller" />

</beans>

4：代碼及目錄結(jié)構(gòu)
Dubbox與Zookeeper簡(jiǎn)介及入門小案例
Dubbox與Zookeeper簡(jiǎn)介及入門小案例
Dubbox與Zookeeper簡(jiǎn)介及入門小案例
三：管理中心的部署
       我們?cè)陂_(kāi)發(fā)時(shí)，需要知道注冊(cè)中心都注冊(cè)了哪些服務(wù)，以便我們開(kāi)發(fā)和測(cè)試。我們可以通過(guò)部署一個(gè)管理中心來(lái)實(shí)現(xiàn)。其實(shí)管理中心就是一個(gè)web應(yīng)用，部署到tomcat即可。
（1）編譯源碼，得到war包在命令符下進(jìn)入dubbo-admin目錄 ，輸入maven命令

mvn package -Dmaven.skip.test=true

（2）進(jìn)入target文件夾，你會(huì)看到一個(gè)dubbo-admin-2.8.4.war ， 在linux服務(wù)器上安裝tomcat, 將此war包上傳到linux服務(wù)器的tomcat的webapps下。啟動(dòng)tomcat后自動(dòng)解壓。

（3）如果你部署在zookeeper同一臺(tái)主機(jī)并且端口是默認(rèn)的2181，則無(wú)需修改任何配置。如果不是在一臺(tái)主機(jī)上或端口被修改，需要修改WEB-INF下的dubbo.properties ，修改如下配置，修改后重新啟動(dòng)tomcat

dubbo.registry.address=zookeeper://127.0.0.1:2181

四：管理中心的使用

打開(kāi)瀏覽器，輸入http://192.168.25.128:8080/dubbo-admin ,登錄用戶名和密碼均為root 進(jìn)入首頁(yè)。
Dubbox與Zookeeper簡(jiǎn)介及入門小案例

五：?jiǎn)?dòng)demo
先啟動(dòng)服務(wù)提供方的maven工程，在啟動(dòng)服務(wù)消費(fèi)方的maven工程。（啟動(dòng)方法見(jiàn)下圖）注意zookeeper的服務(wù)要提前啟動(dòng)，直接輸入服務(wù)消費(fèi)方的地址，看到結(jié)果。
Dubbox與Zookeeper簡(jiǎn)介及入門小案例
Dubbox與Zookeeper簡(jiǎn)介及入門小案例

向AI問(wèn)一下細(xì)節(jié)

免責(zé)聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱：is@yisu.com進(jìn)行舉報(bào)，并提供相關(guān)證據(jù)，一經(jīng)查實(shí)，將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI
助
手