Apache Dubbo概述

一、課程目標

1. 【了解】軟件架構的演進過程
2. 【理解】什么是RPC
3. 【掌握】Dubbo架構
4. 【理解】注冊中心Zookeeper
5. 【掌握】Zookeeper的安裝和使用
6. 【掌握】Dubbo入門程序
7. 【掌握】Dubbo管理控制臺的安裝和使用
8. 【理解】Dubbo配置

二、分布式RPC框架Apache Dubbo

1. 軟件架構的演進過程

軟件架構的發展經歷了由單體架構、垂直架構、SOA架構到微服務架構的演進過程，下面我們分別了解一下這幾個架構。

1.1 單體架構

[外鏈圖片轉存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-0V9GEg3j-1691767408227)(assets/1.png)]

架構說明：

? 全部功能集中在一個項目內（All in one）。

架構優點：

? 架構簡單，前期開發成本低、開發周期短，適合小型項目。

架構缺點：

? 全部功能集成在一個工程中，對于大型項目不易開發、擴展和維護。

? 技術棧受限，只能使用一種語言開發。

? 系統性能擴展只能通過擴展集群節點，成本高。

1.2 垂直架構

[外鏈圖片轉存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-4fcUtnOW-1691767408229)(assets/18.png)]

架構說明：

? 按照業務進行切割，形成小的單體項目。

架構優點：

? 技術棧可擴展（不同的系統可以用不同的編程語言編寫）。

架構缺點：

? 功能集中在一個項目中，不利于開發、擴展、維護。

? 系統擴張只能通過集群的方式。

? 項目之間功能冗余、數據冗余、耦合性強。

1.3 SOA架構

SOA全稱為Service-Oriented Architecture，即面向服務的架構。它可以根據需求通過網絡對松散耦合的粗粒度應用組件(服務)進行分布式部署、組合和使用。一個服務通常以獨立的形式存在于操作系統進程中。

站在功能的角度，把業務邏輯抽象成可復用的服務，通過服務的編排實現業務的快速再生，目的：把原先固有的業務功能轉變為通用的業務服務，實現業務邏輯的快速復用。

[外鏈圖片轉存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-UpIl91jL-1691767408230)(assets/19.png)]

架構說明：

? 將重復功能或模塊抽取成組件的形式，對外提供服務，在項目與服務之間使用ESB（企業服務總線）的形式作為通信的橋梁。

架構優點：

? 重復功能或模塊抽取為服務，提高開發效率。

? 可重用性高。

? 可維護性高。

架構缺點：

? 各系統之間業務不同，很難確認功能或模塊是重復的。

? 抽取服務的粒度大。

? 系統和服務之間耦合度高。

1.4 微服務架構

[外鏈圖片轉存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-xSByUAVR-1691767408232)(assets/20.png)]

架構說明：

? 將系統服務層完全獨立出來，抽取為一個一個的微服務。

? 抽取的粒度更細，遵循單一原則。

? 采用輕量級框架協議傳輸。

架構優點：

? 服務拆分粒度更細，有利于提高開發效率。

? 可以針對不同服務制定對應的優化方案。

? 適用于互聯網時代，產品迭代周期更短。

架構缺點：

? 粒度太細導致服務太多，維護成本高。

? 分布式系統開發的技術成本高，對團隊的挑戰大。

2. Apache Dubbo概述

2.1 Dubbo簡介

Apache Dubbo是一款高性能的Java RPC框架。其前身是阿里巴巴公司開源的一個高性能、輕量級的開源Java RPC框架，可以和Spring框架無縫集成。

什么是RPC？

RPC全稱為remote procedure call，即遠程過程調用。比如兩臺服務器A和B，A服務器上部署一個應用，B服務器上部署一個應用，A服務器上的應用想調用B服務器上的應用提供的方法，由于兩個應用不在一個內存空間，不能直接調用，所以需要通過網絡來表達調用的語義和傳達調用的數據。

需要注意的是RPC并不是一個具體的技術，而是指整個網絡遠程調用過程。

RPC是一個泛化的概念，嚴格來說一切遠程過程調用手段都屬于RPC范疇。各種開發語言都有自己的RPC框架。Java中的RPC框架比較多，廣泛使用的有RMI、Hessian、Dubbo等。

Dubbo官網地址：http://dubbo.apache.org

Dubbo提供了3大核心能力：面向接口的遠程方法調用，智能容錯和負載均衡，以及服務自動注冊和發現。

2.2 Dubbo架構

Dubbo架構圖（Dubbo官方提供）如下：

[外鏈圖片轉存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-wC7Ajfi2-1691767408236)(assets/2.png)]

節點角色說明：

節點角色名稱
Provider暴露服務的服務提供方
Consumer調用遠程服務的服務消費方
Registry服務注冊與發現的注冊中心
Monitor統計服務的調用次數和調用時間的監控中心
Container服務運行容器

虛線都是異步訪問，實線都是同步訪問
藍色虛線:在啟動時完成的功能
紅色虛線(實線)都是程序運行過程中執行的功能

調用關系說明:

  1. 服務容器負責啟動，加載，運行服務提供者。
  2. 服務提供者在啟動時，向注冊中心注冊自己提供的服務。
  3. 服務消費者在啟動時，向注冊中心訂閱自己所需的服務。
  4. 注冊中心返回服務提供者地址列表給消費者，如果有變更，注冊中心將基于長連接推送變更數據給消費者。
  5. 服務消費者，從提供者地址列表中，基于軟負載均衡算法，選一臺提供者進行調用，如果調用失敗，再選另一臺調用。
  6. 服務消費者和提供者，在內存中累計調用次數和調用時間，定時每分鐘發送一次統計數據到監控中心。

3. 服務注冊中心Zookeeper

通過前面的Dubbo架構圖可以看到，Registry（服務注冊中心）在其中起著至關重要的作用。Dubbo官方推薦使用Zookeeper作為服務注冊中心。

3.1 Zookeeper介紹

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

為了便于理解Zookeeper的樹型目錄服務，我們先來看一下我們電腦的文件系統(也是一個樹型目錄結構)：

[外鏈圖片轉存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-7Y3mGPd7-1691767408242)(assets/4.png)]

我的電腦可以分為多個盤符（例如C、D、E等），每個盤符下可以創建多個目錄，每個目錄下面可以創建文件，也可以創建子目錄，最終構成了一個樹型結構。通過這種樹型結構的目錄，我們可以將文件分門別類的進行存放，方便我們后期查找。而且磁盤上的每個文件都有一個唯一的訪問路徑，例如：C:\Windows\yh\hello.txt。

Zookeeper樹型目錄服務：

[外鏈圖片轉存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-yTW5iuRI-1691767408245)(assets/3.png)]

流程說明：

  • 服務提供者(Provider)啟動時: 向 /dubbo/com.foo.BarService/providers 目錄下寫入自己的 URL 地址
  • 服務消費者(Consumer)啟動時: 訂閱 /dubbo/com.foo.BarService/providers 目錄下的提供者 URL 地址。并向 /dubbo/com.foo.BarService/consumers 目錄下寫入自己的 URL 地址
  • 監控中心(Monitor)啟動時: 訂閱 /dubbo/com.foo.BarService 目錄下的所有提供者和消費者 URL 地址

3.2 安裝Zookeeper

下載地址：http://archive.apache.org/dist/zookeeper/

本課程使用的Zookeeper版本為3.4.6，下載完成后可以獲得名稱為zookeeper-3.4.6.tar.gz的壓縮文件。

安裝步驟：

第一步：安裝 jdk（略）
第二步：把 zookeeper 的壓縮包（zookeeper-3.4.6.tar.gz）上傳到 linux 系統
第三步：解壓縮壓縮包
? tar -zxvf zookeeper-3.4.6.tar.gz
第四步：進入zookeeper-3.4.6目錄，創建data目錄
? mkdir data
第五步：進入conf目錄 ，把zoo_sample.cfg 改名為zoo.cfg
? cd conf
? mv zoo_sample.cfg zoo.cfg
第六步：打開zoo.cfg文件, 修改data屬性：dataDir=/root/zookeeper-3.4.6/data

配置日志：dataLogDir=/root/zookeeper-3.4.6/logs

3.3 啟動、停止Zookeeper

進入Zookeeper的bin目錄，啟動服務命令
./zkServer.sh start

停止服務命令
./zkServer.sh stop

查看服務狀態：
./zkServer.sh status

windows按ctrl+c 輸入Y停止

4. Dubbo快速入門

Dubbo作為一個RPC框架，其最核心的功能就是要實現跨網絡的遠程調用。本小節就是要創建兩個應用，一個作為服務的提供方，一個作為服務的消費方。通過Dubbo來實現服務消費方遠程調用服務提供方的方法。

4.1 服務提供方開發

開發步驟：

（1）創建maven工程（打包方式為war）dubbodemo_provider，在pom.xml文件中導入如下坐標

  <properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><maven.compiler.source>1.8</maven.compiler.source><maven.compiler.target>1.8</maven.compiler.target><spring.version>5.0.8.RELEASE</spring.version></properties><dependencies><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相關 --><dependency><groupId>com.alibaba</groupId><artifactId>dubbo</artifactId><version>2.6.0</version></dependency><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.5.5</version></dependency><dependency><groupId>com.github.sgroschupf</groupId><artifactId>zkclient</artifactId><version>0.1</version><exclusions><exclusion><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId></exclusion></exclusions></dependency><dependency><groupId>javassist</groupId><artifactId>javassist</artifactId><version>3.12.1.GA</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.47</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.8</source><target>1.8</target></configuration></plugin><plugin><groupId>org.apache.tomcat.maven</groupId><artifactId>tomcat7-maven-plugin</artifactId><configuration><!-- 指定端口 --><port>8081</port><!-- 請求路徑 --><path>/</path></configuration></plugin></plugins>
</build>

（2）配置web.xml文件

<!DOCTYPE web-app PUBLIC"-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN""http://java.sun.com/dtd/web-app_2_3.dtd" >
<web-app><display-name>Archetype Created Web Application</display-name><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）創建服務接口

package com.yh.service;
public interface HelloService {public String sayHello(String name);
}

（4）創建服務實現類

package com.yh.service.impl;
import com.alibaba.dubbo.config.annotation.Service;
import com.yh.service.HelloService;@Service
public class HelloServiceImpl implements HelloService {public String sayHello(String name) {return "hello " + name;}
}

注意：服務實現類上使用的Service注解是Dubbo提供的，用于對外發布服務

（5）在src/main/resources下創建applicationContext-service.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: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/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/mvchttp://www.springframework.org/schema/mvc/spring-mvc.xsdhttp://code.alibabatech.com/schema/dubbohttp://code.alibabatech.com/schema/dubbo/dubbo.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context.xsd"><!-- 當前應用名稱，用于注冊中心計算應用間依賴關系，注意：消費者和提供者應用名不要一樣 --><dubbo:application name="dubbodemo_provider" /><!-- 連接服務注冊中心zookeeper ip為zookeeper所在服務器的ip地址--><dubbo:registry address="zookeeper://127.0.0.1:2181"/><!-- 注冊  協議和port   端口默認是20880 --><dubbo:protocol name="dubbo" port="20881"></dubbo:protocol><!-- 掃描指定包，加入@Service注解的類會被發布為服務  --><dubbo:annotation package="com.yh.service.impl" />
</beans>

（6）啟動服務

tomcat7:run

4.2 服務消費方開發

開發步驟：

（1）創建maven工程（打包方式為war）dubbodemo_consumer，pom.xml配置和上面服務提供者相同，只需要將Tomcat插件的端口號改為8082即可

（2）配置web.xml文件

<!DOCTYPE web-app PUBLIC"-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN""http://java.sun.com/dtd/web-app_2_3.dtd" >
<web-app><display-name>Archetype Created Web Application</display-name><servlet><servlet-name>springmvc</servlet-name><servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class><!-- 指定加載的配置文件 ，通過參數contextConfigLocation加載 --><init-param><param-name>contextConfigLocation</param-name><param-value>classpath:applicationContext-web.xml</param-value></init-param><load-on-startup>1</load-on-startup></servlet><servlet-mapping><servlet-name>springmvc</servlet-name><url-pattern>/</url-pattern></servlet-mapping>
</web-app>

（3）將服務提供者工程中的HelloService接口復制到當前工程

注意：HelloService生產者和消費者必須保持完一致，包括包名、類名、方法名

（4）編寫Controller

package com.yh.controller;
import com.alibaba.dubbo.config.annotation.Reference;
import com.yh.service.HelloService;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;@Controller
@RequestMapping("/demo")
public class HelloController {@Referenceprivate HelloService helloService;@RequestMapping("/hello")@ResponseBodypublic String getName(String name){//遠程調用String result = helloService.sayHello(name);System.out.println(result);return result;}
}

注意：Controller中注入HelloService使用的是Dubbo提供的@Reference注解

（5）在src/main/resources下創建applicationContext-web.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: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/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/mvchttp://www.springframework.org/schema/mvc/spring-mvc.xsdhttp://code.alibabatech.com/schema/dubbohttp://code.alibabatech.com/schema/dubbo/dubbo.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context.xsd"><!-- 當前應用名稱，用于注冊中心計算應用間依賴關系，注意：消費者和提供者應用名不要一樣 --><dubbo:application name="dubbodemo-consumer" /><!-- 連接服務注冊中心zookeeper ip為zookeeper所在服務器的ip地址--><dubbo:registry address="zookeeper://127.0.0.1:2181"/><!-- 掃描的方式暴露接口  --><dubbo:annotation package="com.yh.controller" />
</beans>

（6）運行測試

tomcat7:run啟動

在瀏覽器輸入http://localhost:8082/demo/hello.do?name=Jack，查看瀏覽器輸出結果

**思考一：**上面的Dubbo入門案例中我們是將HelloService接口從服務提供者工程(dubbodemo_provider)復制到服務消費者工程(dubbodemo_consumer)中，這種做法是否合適？還有沒有更好的方式？

**答：**這種做法顯然是不好的，同一個接口被復制了兩份，不利于后期維護。更好的方式是單獨創建一個maven工程，將此接口創建在這個maven工程中。需要依賴此接口的工程只需要在自己工程的pom.xml文件中引入maven坐標即可。

**思考二：**在服務消費者工程(dubbodemo_consumer)中只是引用了HelloService接口，并沒有提供實現類，Dubbo是如何做到遠程調用的？

**答：**Dubbo底層是基于代理技術為HelloService接口創建代理對象，遠程調用是通過此代理對象完成的。可以通過開發工具的debug功能查看此代理對象的內部結構。另外，Dubbo實現網絡傳輸底層是基于Netty框架完成的。

**思考三：**上面的Dubbo入門案例中我們使用Zookeeper作為服務注冊中心，服務提供者需要將自己的服務信息注冊到Zookeeper，服務消費者需要從Zookeeper訂閱自己所需要的服務，此時Zookeeper服務就變得非常重要了，那如何防止Zookeeper單點故障呢？

**答：**Zookeeper其實是支持集群模式的，可以配置Zookeeper集群來達到Zookeeper服務的高可用，防止出現單點故障。

5. Dubbo管理控制臺

我們在開發時，需要知道Zookeeper注冊中心都注冊了哪些服務，有哪些消費者來消費這些服務。我們可以通過部署一個管理中心來實現。其實管理中心就是一個web應用，部署到tomcat即可。

5.1 安裝

安裝步驟：

（1）將資料中的dubbo-admin-2.6.0.war文件復制到tomcat的webapps目錄下

（2）啟動tomcat，此war文件會自動解壓

（3）查看(修改)WEB-INF下的dubbo.properties文件，注意dubbo.registry.address對應的值需要對應當前使用的Zookeeper的ip地址和端口號

? dubbo.registry.address=zookeeper://192.168.134.129:2181
? dubbo.admin.root.password=root
? dubbo.admin.guest.password=guest

（4）關閉tomcat,刪除dubbo-admin-2.6.0.war文件

（5）重啟tomcat

5.2 使用

操作步驟：

（1）訪問http://localhost:8080/dubbo-admin-2.6.0/，輸入用戶名(root)和密碼(root)

[外鏈圖片轉存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-wYVPVLJQ-1691767408256)(assets/5.png)]

（2）啟動服務提供者工程和服務消費者工程，可以在查看到對應的信息

[外鏈圖片轉存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-fwGjwQxD-1691767408258)(assets/6.png)]

[外鏈圖片轉存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-OcGKkQG5-1691767408259)(assets/7.png)]

[外鏈圖片轉存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-YNvStHDc-1691767408260)(assets/8.png)]

[外鏈圖片轉存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-72TivPdD-1691767408261)(assets/9.png)]

6. Dubbo相關配置說明

6.1 包掃描

<dubbo:annotation package="com.yh.service" />

服務提供者和服務消費者都需要配置，表示包掃描，作用是掃描指定包(包括子包)下的類。

如果不使用包掃描，也可以通過如下配置的方式來發布服務：

<bean id="helloService" class="com.yh.service.impl.HelloServiceImpl" />
<dubbo:service interface="com.yh.api.HelloService" ref="helloService" />

作為服務消費者，可以通過如下配置來引用服務：

<!-- 生成遠程服務代理，可以和本地bean一樣使用helloService -->
<dubbo:reference id="helloService" interface="com.yh.api.HelloService" />

上面這種方式發布和引用服務，一個配置項(dubbo:service、dubbo:reference)只能發布或者引用一個服務，如果有多個服務，這種方式就比較繁瑣了。推薦使用包掃描方式。

6.2 協議

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

一般在服務提供者一方配置，可以指定使用的協議名稱和端口號。

其中Dubbo支持的協議有：dubbo、rmi、hessian、http、webservice、rest、redis等。

推薦使用的是dubbo協議。

dubbo 協議采用單一長連接和 NIO 異步通訊，適合于小數據量大并發的服務調用，以及服務消費者機器數遠大于服務提供者機器數的情況。不適合傳送大數據量的服務，比如傳文件，傳視頻等，除非請求量很低。

也可以在同一個工程中配置多個協議，不同服務可以使用不同的協議，例如：

<!-- 多協議配置 -->
<dubbo:protocol name="dubbo" port="20880" />
<dubbo:protocol name="rmi" port="1099" />
<!-- 使用dubbo協議暴露服務 -->
<dubbo:service interface="com.yh.api.HelloService" ref="helloService" protocol="dubbo" />
<!-- 使用rmi協議暴露服務 -->
<dubbo:service interface="com.yh.api.DemoService" ref="demoService" protocol="rmi" />

6.3 啟動時檢查

在consumer工程配置中

<dubbo:consumer check="false"/>

也可以在注解上加

@Reference(check = false)
private HelloService helloService;

上面這個配置需要配置在服務消費者一方，如果不配置默認check值為true。Dubbo 缺省會在啟動時檢查依賴的服務是否可用，不可用時會拋出異常，阻止 Spring 初始化完成，以便上線時，能及早發現問題。可以通過將check值改為false來關閉檢查。

建議在開發階段將check值設置為false，在生產環境下改為true。

6.4 負載均衡

負載均衡（Load Balance）：其實就是將請求分攤到多個操作單元上進行執行，從而共同完成工作任務。

在集群負載均衡時，Dubbo 提供了多種均衡策略（包括隨機random、輪詢roundrobin、最少活躍調用數leastactive、一致性Hash），缺省為random隨機調用。

配置負載均衡策略，既可以在服務提供者一方配置，也可以在服務消費者一方配置，如下：

    @Controller@RequestMapping("/demo")public class HelloController {//在服務消費者一方配置負載均衡策略@Reference(check = false,loadbalance = "random")private HelloService helloService;@RequestMapping("/hello")@ResponseBodypublic String getName(String name){//遠程調用String result = helloService.sayHello(name);System.out.println(result);return result;}}
//在服務提供者一方配置負載均衡
@Service(loadbalance = "random")
public class HelloServiceImpl implements HelloService {public String sayHello(String name) {return "hello " + name;}
}

可以通過啟動多個服務提供者來觀察Dubbo負載均衡效果。

注意：因為我們是在一臺機器上啟動多個服務提供者，所以需要修改tomcat的端口號和Dubbo服務的端口號來防止端口沖突。

在實際生產環境中，多個服務提供者是分別部署在不同的機器上，所以不存在端口沖突問題。

7. 解決Dubbo無法發布被事務代理的Service問題

前面我們已經完成了Dubbo的入門案例，通過入門案例我們可以看到通過Dubbo提供的標簽配置就可以進行包掃描，掃描到@Service注解的類就可以被發布為服務。

但是我們如果在服務提供者類上加入@Transactional事務控制注解后，服務就發布不成功了。原因是事務控制的底層原理是為服務提供者類創建代理對象，而默認情況下Spring是基于JDK動態代理方式創建代理對象，而此代理對象的完整類名為com.sun.proxy.$Proxy42（最后兩位數字不是固定的），導致Dubbo在發布服務前進行包匹配時無法完成匹配，進而沒有進行服務的發布。

7.1 問題展示

在入門案例的服務提供者dubbodemo_provider工程基礎上進行展示

操作步驟：

（1）在pom.xml文件中增加maven坐標

<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>5.1.47</version>
</dependency>
<dependency><groupId>com.alibaba</groupId><artifactId>druid</artifactId><version>1.1.6</version>
</dependency>
<dependency><groupId>org.mybatis</groupId><artifactId>mybatis-spring</artifactId><version>1.3.2</version>
</dependency>

（2）在applicationContext-service.xml配置文件中加入數據源、事務管理器、開啟事務注解的相關配置

<!--數據源-->
<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" destroy-method="close"><property name="username" value="root" /><property name="password" value="root" /><property name="driverClassName" value="com.mysql.jdbc.Driver" /><property name="url" value="jdbc:mysql://localhost:3306/test" />
</bean>
<!-- 事務管理器  -->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource" ref="dataSource"/>
</bean>
<!--開啟事務控制的注解支持-->
<tx:annotation-driven transaction-manager="transactionManager"/>

上面連接的數據庫可以自行創建

（3）在HelloServiceImpl類上加入@Transactional注解

（4）啟動服務提供者和服務消費者，并訪問

上面的錯誤為沒有可用的服務提供者

查看dubbo管理控制臺發現服務并沒有發布，如下：

[外鏈圖片轉存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-KROjZEv7-1691767408262)(assets/13.png)]

可以通過斷點調試的方式查看Dubbo執行過程，Dubbo通過AnnotationBean的postProcessAfterInitialization方法進行處理。

7.2 解決方案

通過上面的斷點調試可以看到，在HelloServiceImpl類上加入事務注解后，Spring會為此類基于JDK動態代理技術創建代理對象，創建的代理對象完整類名為com.sun.proxy.$Proxy35，導致Dubbo在進行包匹配時沒有成功（因為我們在發布服務時掃描的包為com.yh.service），所以后面真正發布服務的代碼沒有執行。

解決方式操作步驟：

（1）修改applicationContext-service.xml配置文件，開啟事務控制注解支持時指定proxy-target-class屬性，值為true。其作用是使用cglib代理方式為Service類創建代理對象

<!--開啟事務控制的注解支持-->
<tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true"/>

（2）修改HelloServiceImpl類，在Service注解中加入interfaceClass屬性，值為HelloService.class，作用是指定服務的接口類型

@Service(interfaceClass = HelloService.class)
@Transactional
public class HelloServiceImpl implements HelloService {public String sayHello(String name) {return "hello " + name;}
}

此處也是必須要修改的，否則會導致發布的服務接口為SpringProxy，而不是HelloService接口，如下：

[外鏈圖片轉存失敗,源站可能有防盜鏈機制,建議將圖片保存下來直接上傳(img-5DsRPXOf-1691767408263)(assets/16.png)]

本文來自互聯網用戶投稿，該文觀點僅代表作者本人，不代表本站立場。本站僅提供信息存儲空間服務，不擁有所有權，不承擔相關法律責任。
如若轉載，請注明出處：http://www.pswp.cn/news/37352.shtml
繁體地址，請注明出處：http://hk.pswp.cn/news/37352.shtml
英文地址，請注明出處：http://en.pswp.cn/news/37352.shtml

如若內容造成侵權/違法違規/事實不符，請聯系多彩編程網進行投訴反饋email:809451989@qq.com，一經查實，立即刪除！

相關文章

2021年06月 C/C++（二級）真題解析#中國電子學會#全國青少年軟件編程等級考試

2021年06月 C/C++（二級）真題解析#中國電子學會#全國青少年軟件編程等級考試

第1題&#xff1a;數字放大 給定一個整數序列以及放大倍數x&#xff0c;將序列中每個整數放大x倍后輸出。 時間限制&#xff1a;1000 內存限制&#xff1a;65536 輸入 包含三行&#xff1a; 第一行為N&#xff0c;表示整數序列的長度(N ≤ 100); 第二行為N個整數(不超過整型范圍…
閱讀更多...
(css)點擊前隱藏icon圖表 點擊后顯示

(css)點擊前隱藏icon圖表 點擊后顯示

(css)點擊前隱藏icon圖表 點擊后顯示 效果 html <liv-for"(item,index) in sessionList":key"index"class"liClass":class"{ active: change2 index }"tabindex"2">...<el-tooltip class"item" effec…
閱讀更多...
c++病毒/惡搞代碼大全( 下 )

c++病毒/惡搞代碼大全( 下 )

注&#xff1a;以下代碼應勿用于非法&#xff08;Dev-c5.11實測可用&#xff09; 警告:以下為危險/永久性程序&#xff0c;請慎重使用 8. 效果:禁用任務管理器 提示:可能被殺毒軟件攔截 #include <stdio.h> #include <windows.h> int main() {HKEY hkey;DWORD …
閱讀更多...
Neo4j之OPTIONAL MATCH基礎

Neo4j之OPTIONAL MATCH基礎

OPTIONAL MATCH 是 Neo4j 查詢語言 Cypher 中的一種關鍵字&#xff0c;用于在查詢中執行可選的模式匹配。它允許你在匹配節點和關系的過程中&#xff0c;即使匹配失敗也不影響整個查詢結果。OPTIONAL MATCH 允許你查找與指定模式匹配的數據&#xff0c;如果匹配失敗&#xff0c…
閱讀更多...
分布式監控平臺——Zabbix

分布式監控平臺——Zabbix

市場上常用的監控軟件&#xff1a; 傳統運維&#xff1a;zabbix、 Nagios 一、zabbix概述 作為一個運維&#xff0c;需要會使用監控系統查看服務器狀態以及網站流量指標&#xff0c;利用監控系統的數據去了解上線發布的結果&#xff0c;和網站的健康狀態。 利用一個優秀的監…
閱讀更多...
Dedecms V110最新版RCE---Tricks

Dedecms V110最新版RCE---Tricks

前言 剛發現Dedecms更新了發布版本&#xff0c;順便測試一下之前的day有沒有修復&#xff0c;突然想到了新的tricks去實現RCE。 文章發布的時候估計比較晚了&#xff0c;一直沒時間寫了。 利用 /uploads/dede/article_string_mix.php /uploads/dede/article_template_rand.…
閱讀更多...
Blender增強現實3D模型制作指南【AR】

Blender增強現實3D模型制作指南【AR】

推薦&#xff1a;用 NSDT編輯器 快速搭建可編程3D場景 將靜態和動畫 3D 內容集成到移動增強現實 (AR) 體驗中是增強用戶沉浸感和參與度的高效方法。 然而&#xff0c;為 AR 創建 3D 對象可能相當艱巨&#xff0c;尤其是對于那些缺乏 3D 建模經驗的人來說。 與添加視頻或照片 AR…
閱讀更多...
黑馬項目一階段面試58題 蒼穹外賣具體技術細節9題

黑馬項目一階段面試58題 蒼穹外賣具體技術細節9題

一、Nginx的作用 1.反向代理 前端把請求發送給nginx&#xff0c;再由nginx將請求發送給后端服務器。 2.負載均衡 提高訪問速度&#xff1b;進行負載均衡&#xff1b;保證后端服務安全 二、Swagger有什么作用 直接調試后端請求響應 三、Redis常見數據類型 String、Hash、L…
閱讀更多...
flutter 解壓 zip 中文亂碼問題處理

flutter 解壓 zip 中文亂碼問題處理

前言 很簡單的一個 zip 包解壓縮的功能&#xff0c;但是 windows 平臺中文顯示亂碼&#xff0c;很糟心&#xff0c;搜了一圈沒找到現成的方法&#xff0c;在此貼上我的解決方式。 實現 導入需要的包 flutter pub add archiveflutter pub add fast_gbkflutter pub add path代…
閱讀更多...
THUDM/chatglm2-6b-int4體驗

THUDM/chatglm2-6b-int4體驗

在gpu下 gpu&#xff1a; Telsa T4 資源消耗&#xff1a;RAM大概4G&#xff0c;GPU顯存大概6G # 安裝transformers等包 !pip install protobuf transformers4.30.2 cpm_kernels torch>2.0 gradio mdtex2html sentencepiece accelerate# 導入AutoTokenizer, AutoModel from…
閱讀更多...
CSAPP Lec01

CSAPP Lec01

1. CMU 15213_15513 CSAPP 深入理解計算機系統 Lecture 01 Course Overview 中英字幕_嗶哩嗶哩_bilibili 從這個課程中可以學到什么&#xff1f;&#xff08;為什么要學這門課&#xff09; Great Reality #1&#xff08;數字類型&#xff09;: Ints are not Integers, Floats…
閱讀更多...
idea打jar包

idea打jar包

目錄 1、打包設置 2、打包介紹 3、開始打包 1、打包設置 先設置要打包的模塊信息&#xff0c;即打包進去的內容。如下圖所示&#xff1a;File --> Project Structure --> Artifacts&#xff0c;點擊&#xff0b;號完成模塊創建&#xff0c;其中有兩種方式&#xff1a;…
閱讀更多...
《零基礎實踐深度學習》(第2版)學習筆記，（二）機器學習和深度學習綜述

《零基礎實踐深度學習》(第2版)學習筆記，（二）機器學習和深度學習綜述

文章目錄 1. 人工智能、機器學習、深度學習的關系2. 機器學習2.1 實現原理2.2 如何實施 3. 深度學習神經網絡核心概念 1. 人工智能、機器學習、深度學習的關系 **人工智能&#xff08;Artificial Intelligence&#xff0c;AI&#xff09;**是研發用于模擬、延伸和擴展人的智能…
閱讀更多...
微服務系列（2）--注冊中心

微服務系列（2）--注冊中心

在博文&#xff1a;微服務系列(1)里我們提到過注冊中心的概念&#xff0c;簡單來說微服務注冊中心是一個用于存儲和管理微服務實例信息的組件&#xff0c;它提供了服務注冊、服務發現、服務健康檢查等功能&#xff0c;以確保微服務之間的穩定通信。在微服務架構中&#xff0c;各…
閱讀更多...
Debian純凈系統安裝php常用擴展和程序

Debian純凈系統安裝php常用擴展和程序

適用于 php-fpm debian容器 mysql擴展 docker-php-ext-install pdo_mysql docker-php-ext-install mysqliredis擴展 pecl install redis docker-php-ext-enable redis# pecl無法裝就&#xff1a; docker-php-source extract # 創建并初始化 /usr/src/php目錄&#xff08;擴展…
閱讀更多...
應用層協議——TCP(上)

應用層協議——TCP(上)

文章目錄 1. TCP協議1.1 TCP協議段格式1.2 確認應答(ACK)機制1.3 16位窗口大小1.4 6位標志位1.4.1 TCP三次握手 1.5 確認應答(ACK)機制1.6 超時重傳機制1.7 連接管理機制1.7.1 理解TIME_WAIT狀態1.7.2 理解 CLOSE_WAIT 狀態 1. TCP協議 TCP全稱為傳輸控制協議&#xff0c;意思…
閱讀更多...
【uniapp 中使用uni-popup阻止左滑退出程序】

【uniapp 中使用uni-popup阻止左滑退出程序】

在uniapp中&#xff0c;可以使用uni-app插件uni-popup提供的阻止左滑退出程序的功能。具體步驟如下&#xff1a; 安裝uni-popup插件&#xff1a;在HBuilderX編輯器中&#xff0c;打開manifest.json文件&#xff0c;找到“dependencies”字段&#xff0c;在其后添加&#xff1a…
閱讀更多...
〔AI 繪畫〕Stable Diffusion 之 VAE 篇

〔AI 繪畫〕Stable Diffusion 之 VAE 篇

? 目錄 &#x1f388; 什么是VAE&#x1f388; 開啟VAE&#x1f388; 下載常見的VAE&#x1f388; 對比不同VAE生成的效果 &#x1f388; 什么是VAE VAE&#xff1a;是 Variational Auto-Encoder 的簡稱&#xff0c;也就是變分自動編碼器可以把它理解成給圖片加濾鏡&#xff…
閱讀更多...
JavaWeb-Filter過濾器

JavaWeb-Filter過濾器

目錄 Filter過濾器 1. Filter的生命周期 2.Filter的配置 3.攔截路徑 4.攔截具體的使用 5.攔截方式配置&#xff08;資源被訪問方式&#xff09; 6.FilterChain攔截鏈 Filter過濾器 filter是過濾器&#xff0c;相比于Servlet的發送請求&#xff0c;filter是用于攔截請求。…
閱讀更多...
2023-08-14 linux 串口終端輸入長命令不換行，覆蓋前面內容，stty命令設置串口終端行列數

2023-08-14 linux 串口終端輸入長命令不換行，覆蓋前面內容，stty命令設置串口終端行列數

一、linux 串口終端輸入長命令不換行&#xff0c;覆蓋前面內容&#xff0c;現象如下圖&#xff1a; 二、解決方法&#xff1a;用stty 命令設置行列數 stty columns 200 stty rows 10三、參考文章 https://www.cnblogs.com/goloving/p/15170537.html 常用Linux串口設備操作命…
閱讀更多...
最新文章

Copyright @ 2022~2023