關(guān)于Dubbo初始問題

更新時間：2023年03月01日 09:06:10 作者：你好y

這篇文章主要介紹了關(guān)于Dubbo初始問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教

Dubbo架構(gòu)

消費者：調(diào)用提供者，但是不能直接調(diào)，需要借助注冊中心

節(jié)點角色說明

Provider:暴露服務(wù)的服務(wù)提供方
Container: 服務(wù)運行容器
Consumer: 調(diào)用遠程服務(wù)的服務(wù)消費方
Registry:服務(wù)注冊與發(fā)現(xiàn)的注冊中心
Monitor:統(tǒng)計服務(wù)的調(diào)用次數(shù)和調(diào)用時間的監(jiān)控中心

過程

0start：服務(wù)的提供者要運行在一個容器里面，比如運行在tomcat里面，需要將tomcat啟動起來。

1注冊：啟動起來之后，該服務(wù)就會注冊到注冊中心里（將服務(wù)調(diào)用的ip、端口、服務(wù)發(fā)布url放到注冊中心里面去。）。

2.subscribe：我想調(diào)用提供者提供的服務(wù)，我這時去找注冊中心去找（告訴服務(wù)中心將服務(wù)的相關(guān)信息給消費者）

3.notify：消費者要一次服務(wù)，注冊中心給一次。

這時消費者拿到服務(wù)的信息

4.invoke：就是rpc的過程，進行調(diào)用。不用我們管，dubbo內(nèi)部自動實現(xiàn)。

5.Monitor：服務(wù)監(jiān)控。統(tǒng)計某個服務(wù)調(diào)用了多少次。

asyn：異步。sync：同步。只有rpc調(diào)用時同步的，其他的都是異步的。

Zookeeper安裝

先安裝java1.8

解壓，進入配置文件夾，復(fù)制配置文件，并修改里面的配置使其生效。復(fù)制會話窗口，創(chuàng)建目錄，將該目錄復(fù)制修改到配置文件里面。啟動zk

zk默認端口為2181

Mode:standalone(當前沒有搭建集群，是單節(jié)點在運行)

Dubbo快速入門

注意這里的controller調(diào)用service是遠程調(diào)用，是兩個工程分別部署在兩臺機器上。

jar包依賴

        <!--Dubbo的起步依賴，版本2.7之后統(tǒng)一為rg.apache.dubb -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>${dubbo.version}</version>
        </dependency>
        <!--ZooKeeper客戶端實現(xiàn) -->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>${zookeeper.version}</version>
        </dependency>
        <!--ZooKeeper客戶端實現(xiàn) -->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>${zookeeper.version}</version>
        </dependency>

開始配置dubbo

<?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://dubbo.apache.org/schema/dubbo" xmlns:context="http://www.springframework.org/schema/context"
      xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd">

   <!--spring包掃描-->
   <!--<context:component-scan base-package="com.itheima.service"/>-->

   <!--dubbo的配置-->
   <!--1、配置項目的名稱，唯一-->
   <dubbo:application name="dubbo-service"/>
   <!--2、配置注冊中心的地址-->
   <dubbo:registry address="zookeeper://101.42.248.44:2181"/>
   <!--3、配置dubbo包掃描-->
   <dubbo:annotation package="com.itheima.service.impl"/>


</beans>

添加spring的配置，讓其掃描加載剛在配置dubbo的配置文件applicationContext.xml

配置zk

上面的掃描時掃面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:dubbo="http://dubbo.apache.org/schema/dubbo"
       xmlns:mvc="http://www.springframework.org/schema/mvc"
       xmlns:context="http://www.springframework.org/schema/context"
       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://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd">

    <!--打開注解驅(qū)動-->
    <mvc:annotation-driven/>
    <!--掃描包-->
    <context:component-scan base-package="com.itheima.controller"/>

    <!--dubbo的配置-->
    <!--1、配置項目的名稱，唯一-->
    <dubbo:application name="dubbo-web">
        <dubbo:parameter key="qos.port" value="33333"/>
    </dubbo:application>
    <!--2、配置注冊中心的地址-->
    <dubbo:registry address="zookeeper://101.42.248.44:2181"/>
    <!--3、配置dubbo包掃描-->
    <dubbo:annotation package="com.itheima.controller"/>
</beans>