搭建SpringCloud-Alibaba框架-有解無憂

簡介

搭建基于SpringcloudAlibaba的分布式框架，注冊中心以及服務消費訂閱采用的是中間件 Nacos作為實作，服務與服務之間的呼叫采用的是dubbo的rpc協議，各模塊通過 Nacos進行統一的配置管理(通過Nacos做配置中心)，當并發進行http介面呼叫時，則是采用中間件Sentinel進行服務限流以及服務降級，http請求回應資料則是從資料庫 mysql 中獲取，最后通過springcloud的插件gateway進行路由轉發，本篇將略微有點長，請耐心看完，

專案地址：https://gitee.com/wangwenlongGitHub/SpringCloudAlibaba-practice.git

Nacos、Sentinel安裝與簡介：https://blog.csdn.net/qq_42227281/article/details/109074957

工程搭建：

1：父工程及子工程

1、創建一個Maven專案作為父工程

src等沒用的檔案直接洗掉，只留關鍵的pom即可

2、創建子工程(maven工程)alibaba-module、alibaba-server、alibaba-common

src等沒用的檔案直接洗掉，只留關鍵的pom即可

3、alibaba-module--Pom檔案

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <artifactId>SpringCloudAlibaba-practice</artifactId>
        <groupId>com.jingshang</groupId>
        <version>1.0</version>
    </parent>

    <artifactId>alibaba-module</artifactId>
    <packaging>pom</packaging>
    <description>module模塊</description>

    <modules>
        <module>admin-user-biz</module>
        <module>admin-user-api</module>
        <module>admin-role-api</module>
        <module>admin-role-biz</module>
    </modules>
</project>

alibaba-module子工程：我用它來管理api介面、http介面

4、alibaba-server--Pom檔案

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.jingshang</groupId>
    <artifactId>alibaba-server</artifactId>
    <packaging>pom</packaging>
    <version>1.0</version>

    <modules>
        <module>alibaba-gateway-server</module>
    </modules>
</project>

alibaba-server子工程：我用它來管理路由轉發、服務降級、限流等功能模塊

5、alibaba-common--Pom檔案

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <artifactId>SpringCloudAlibaba-practice</artifactId>
        <groupId>com.jingshang</groupId>
        <version>1.0</version>
    </parent>

    <artifactId>alibaba-common</artifactId>
    <packaging>pom</packaging>
    <description>common模塊</description>

    <modules>
        <module>common-core</module>
        <module>common-code-generation</module>
    </modules>


</project>

alibaba-common子工程：我通常用來整合安全框架、代碼生成等公共功能模塊

2：整合Nacos注冊中心、服務提供者、配置中心，整合sentinel

服務提供者

在alibaba-module工程中中創建 admin-user-api、admin-user-biz等子工程

說明：api為對外開放的介面、biz為http介面，通俗的講就是postman可呼叫的介面，遠程呼叫我是用的dubbo的rpc協議來替代feign和ribbon

1、創建 admin-user-api 模塊：右鍵alibaba-module->new->module->創建maven專案

構建Pom：pom

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <artifactId>alibaba-module</artifactId>
        <groupId>com.jingshang</groupId>
        <version>1.0</version>
    </parent>


    <artifactId>admin-user-api</artifactId>
    <packaging>jar</packaging>
    <description>user模塊</description>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>


</project>

2、創建 admin-user-biz 模塊：右鍵alibaba-module->new->module->創建springboot專案

構建Pom：pom

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.jingshang</groupId>
    <artifactId>admin-user-biz</artifactId>
    <version>1.0</version>
    <packaging>jar</packaging>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.5.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <!-- 引入Api -->
        <dependency>
            <groupId>com.jingshang</groupId>
            <artifactId>admin-user-api</artifactId>
            <version>1.0</version>
        </dependency>
        <!-- 公共Api-->
        <dependency>
            <groupId>com.jingshang</groupId>
            <artifactId>common-core</artifactId>
            <version>1.0</version>
        </dependency>
        <!-- mysql -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>
        <!-- mybatis -->
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.1.3</version>
        </dependency>
        <!-- 必須包含spring-boot-starter-actuator包，不然啟動會報錯， -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <!-- web 應用 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- 配置中心所需jar包 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
        </dependency>
        <!-- 整合的dubbo -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-dubbo</artifactId>
        </dependency>
        <!-- 整合的nacos -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <!-- sentinel -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
        </dependency>
        <!-- lombok -->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.2</version>
            <optional>true</optional>
        </dependency>
        <!--  junit 測驗所需的jar包 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Finchley.SR1</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                <version>0.2.2.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

application.properties配置

spring.application.name=admin-user-biz
server.port=8001
# sentinel dashboard
spring.cloud.sentinel.transport.dashboard=10.10.10.244:8888
#nacos 注冊中心
spring.cloud.nacos.discovery.server-addr=localhost:8848
spring.cloud.nacos.discovery.namespace=dddf9ef6-638a-42fa-9b82-9c61a944f6cc
#spring.cloud.nacos.discovery.cluster‐name=DEFAULT_GROUP
# dubbo 服務
dubbo.scan.base-packages=com.jingshang.adminuserbiz.service
dubbo.protocol.name=dubbo
dubbo.protocol.port=20881
dubbo.registry.address=spring-cloud://localhost
#訂閱 (意思是呼叫哪個web服務的介面)
#dubbo.cloud.subscribed-services=admin-user-biz
#mysql日志
logging.level.com.jingshang.adminuserbiz.dao=debug

注：mysql配置到了nacos中，application.properties中就不再重復寫mysql的連接了，如何將mysql配置到nacos中請繼續往下看

說明：application.properties中配置了nacos注冊中心、sentinel流量防衛兵等基本配置、rpc遠程呼叫協議【dubbo】

重點：當你配置了dubbo之后，Service層的注解要使用 dubbo的@Service注解，當你非要使用 @org.springframework.stereotype.Service的 @Service注解時，請一定保證當前服務沒有被其他服務遠程呼叫，否則呼叫此服務的服務消費者啟動時將會拋出【No provider available for the service 】翻譯過來就是：沒有提供該服務的提供商

2.1、構建nacos配置中心

①登錄：默認賬號密碼都是 nacos，地址：http://localhost:8848/nacos

②進去后選擇：【服務管理】-->【命名空間】-->【點擊右上角：新建命名空間】

效果圖：

④新增配置資訊：選擇串列頁的【配置管理】-->【選擇上方剛創建的dev命名空間】-->【點擊右上方的 + 號】Id、group、配置內容為必填資訊，配合格式我springboot專案中用的是properties，所以這里選properties就可以了，主要是和代碼的組態檔后綴保持一致即可

我這里只配了資料庫，各位小伙伴根據自己實際情況做配置???????

⑤bootstrap.properties拉取配置中心資訊的配置

#配置中心
spring.cloud.nacos.config.server-addr=localhost:8848
spring.cloud.nacos.config.prefix=alibaba-admin-database
spring.cloud.nacos.config.group=DEFAULT_DATABASE
spring.cloud.nacos.config.file-extension=properties
spring.cloud.nacos.config.namespace=dddf9ef6-638a-42fa-9b82-9c61a944f6cc
# 修改nacos日志列印級別，不修改的話，配置資訊一直重繪
logging.level.com.alibaba.nacos:warn

yaml格式

logging:
  level:
    com:
      alibaba:
        nacos: warn
spring:
  cloud:
    nacos:
      config:
        file-extension: properties
        group: DEFAULT_DATABASE
        namespace: dddf9ef6-638a-42fa-9b82-9c61a944f6cc
        prefix: alibaba-admin-database
        server-addr: localhost:8848

bootstrap.properties的屬性與nacos的對應關系

說明：為什么這里要創建兩個組態檔，為什么不直接在application.properties中配置所有所需資訊呢，這是因為nacos做配置中心的時候，默認支持的是bootstrap，而不是application，不這么做的話，你的配置就算寫的再好，也不會將其放到nacos中做配置中心的，而且會導致啟動找不到配置而報錯

重點：bootstrap.properties通過namespace【namespace的指向是命名空間，如果不寫的話，默認去找public命名空間，但是這樣的話，配置就找不到了(我們在配置中心配置的資料庫資訊)】和prefix【prefix它指定的配置的Id】，通過這兩個屬性，使得組態檔能精準的找到屬于我們自己的配置資訊

⑥nacos多配制

前提：需要有一個默認配置，該默認配置需要指定【命名空間：namespace、nacos地址：server-addr】

多配制：當你需要從nacos配置中心拉取多個配置時，應該在bootstrap.properties組態檔中配置【data-id、group】如下圖圈紅的位置

⑦ 如需多配制請在bootstrap.properties中這么寫：

spring.cloud.nacos.config.ext-config[0].data-id=alibaba-admin-database.properties

spring.cloud.nacos.config.ext-config[0].group=DEFAULT_DATABASE

yaml格式

spring:
  cloud:
    nacos:
      config:
        ext-config:
        - data-id: alibaba-admin-database.properties
          group: DEFAULT_DATABASE

重點：值得注意的是data-id 一定要加擴展名，當你不加它的時候，系統還是會提醒你，讓你選擇一個合適的擴展名，至于為什么系統會這么貼心的告訴你呢？那是因為它報錯給我們了【報錯資訊：must contains file extension with properties|yaml|yml 】

誤區：ext-config[0]我當時在想為什么是【0】,如果沒有【0】的情況下，我可不可以直接寫【1】百思不得其解，但是當我看到原始碼的時候我才突然恍然大悟

/**
 * 一組擴展配置
 */
private List<Config> extConfig;

這個配置的容器是List，而List索引必須從0開始，所以當你需要多配制的時候，要從0開始，然后才是1、2、3

配置好后啟動查看控制臺日志輸出，如下圖：加載了兩個配置

⑧啟動類添加注解

@MapperScan(basePackages = {"com.jingshang.adminuserbiz.dao"})
@EnableDiscoveryClient//將服務注冊到注冊中心
@SpringBootApplication
public class AdminUserBizApplication {

    public static void main(String[] args) {
        SpringApplication.run(AdminUserBizApplication.class, args);
    }

}

2.1：撰寫http介面、并進行流控及降級

①Mapper層省略、寫sql陳述句的時候，啟動類記得掃描喲或者在Mapper層加注解

②Service層：介面寫在 admin-user-api 里面，如下圖

介面方法：String findByName(Integer id); id查詢回傳名稱，這方法名起的不咋地，能懂意思就行哈，不要太在意我起的名字???????

③Service實作類：該實作類放在 admin-user-biz 里面，如下圖，如果不明白api、zip的區別，請往上看，上面有說明，???????

④介面方法：

@Slf4j
@Service
public class UserServiceImpl implements UserDubboService {


    @Resource
    private UserDao sysUserDao;

    @SentinelResource(value = "user/findByName", blockHandler = "exceptionHandler")
    @Override
    public String findByName(Integer id) {
        return sysUserDao.findByName(id);
    }
}

重點：

1、@Service注解使用 dubbo的注解，且一定要實作介面

2、@SentinelResource它是sentinel的注解(用于服務限流、降級、服務熔斷)

用于定義資源，并提供可選的例外處理和 fallback 配置項，

@SentinelResource 注解包含以下屬性：

value：資源名稱，必需項（不能為空）

entryType：entry 型別，可選項（默認為EntryType.OUT）

blockHandler(命名塊的例外功能) 、 blockHandlerClass (指定自定義限流及降級的類)

3、Sentinel限流、降級的使用

一：流控

①先請求介面，因為只有請求完介面后，sentinel的簇點鏈路才有該路徑，才可以進行限流???????

②打開sentinel 簇點鏈路->串列視圖->找到剛呼叫的介面地址->點擊流控???????

QPS:點擊數

單機閾值：單位時間內QPS和執行緒數的數量

執行緒數：跟QPS很像，理解直觀意思即可

關聯：比如A介面地址為資源名、B介面地址為關聯的資源名，當A介面限流后，B介面也會被限流

Warm Up：預熱模式，該加載因子默認是3，意思是當QPS(點擊數)設定每秒10次，warm up設定5秒，那就是在5秒內處于預熱模式，每秒的并發是 QPS/加載因子、10/3 ，也就是說在預熱模式內(warm up = 5秒)并發最多是3，當大于3的時候就會進行流量控制

排隊等候：這種方式主要用于處理間隔性突發的流量，例如訊息佇列，想象一下這樣的場景，在某一秒有大量的請求到來，而接下來的幾秒則處于空閑狀態，我們希望系統能夠在接下來的空閑期間逐漸處理這些請求，而不是在第一秒直接拒絕多余的請求，

注意：勻速排隊模式暫時不支持 QPS > 1000 的場景，

注意：自定義的流量控制例外請參考上面介面實作類里的方法

二：降級

①先請求介面，因為只有請求完介面后，sentinel的簇點鏈路才有該路徑，才可以進行降級

②打開sentinel 簇點鏈路->串列視圖->找到剛呼叫的介面地址->點擊降級

注意：降級規則1.8之后更新了策略

RT：平均回應時間，當rt設定為200毫秒時則表示，單位時間內的的請求平均回應時間必須在200毫秒以內完成，若超出則會觸發降級

時間視窗：被降級后的資源將在時間視窗后恢復正常

例外比例：單位時間內的請求，當報錯達到一定比例后服務將會自動降級(例：每秒請求10次，例外比例設定為20%，那么10次請求中報錯超過3次，報錯就會超過20%，一旦超過，sentinel就會進行服務熔斷)

例外數：這個相對于前兩個就比較好理解一些了，直接設定好報錯的次數，當報錯次數超過設定的例外數時，就會自動降級

注意：自定義的服務降級例外請參考上面介面實作類里的方法，與流控的自定義例外寫法可以保持一致，關鍵點在sentinel Dashbord對于該資源是設定了限流還是降級

2.2 服務消費者

服務消費者

1、創建 admin-role-api 模塊：右鍵alibaba-module->new->module->創建maven專案

構建Pom:

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <artifactId>alibaba-module</artifactId>
        <groupId>com.jingshang</groupId>
        <version>1.0</version>
    </parent>


    <artifactId>admin-role-api</artifactId>
    <packaging>jar</packaging>
    <description>role模塊</description>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

</project>

2、創建 admin-role-biz 模塊：右鍵alibaba-module->new->module->創建springboot專案

構建Pom：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.jingshang</groupId>
    <artifactId>admin-role-biz</artifactId>
    <version>1.0</version>
    <packaging>jar</packaging>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.5.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <!-- 引入Api -->
        <dependency>
            <groupId>com.jingshang</groupId>
            <artifactId>admin-role-api</artifactId>
            <version>1.0</version>
        </dependency>
        <dependency>
            <groupId>com.jingshang</groupId>
            <artifactId>admin-user-api</artifactId>
            <version>1.0</version>
        </dependency>
        <!-- mysql -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>
        <!-- mybatis -->
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.1.3</version>
        </dependency>
        <!-- 必須包含spring-boot-starter-actuator包，不然啟動會報錯， -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <!-- web 應用 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- 整合的dubbo -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-dubbo</artifactId>
        </dependency>
        <!-- 整合的nacos -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <!-- 配置中心所需jar包 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
        </dependency>
        <!-- sentinel -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.2</version>
            <optional>true</optional>
        </dependency>
        <!--  junit 測驗所需的jar包 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Finchley.SR1</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                <version>0.2.2.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

application.properties基本配置

spring.application.name=admin-role-biz
server.port=8002
# sentinel dashboard (限流、熔斷降級)
spring.cloud.sentinel.transport.dashboard=10.10.10.244:8888
#nacos 注冊中心
spring.cloud.nacos.discovery.server-addr=localhost:8848
spring.cloud.nacos.discovery.namespace=dddf9ef6-638a-42fa-9b82-9c61a944f6cc
# dubbo 服務
#dubbo.scan.base-packages=com.jingshang.adminrolebiz.service
dubbo.protocol.name=dubbo
dubbo.protocol.port=20882
dubbo.registry.address=spring-cloud://localhost
#訂閱 (意思是呼叫哪個web服務的介面)
dubbo.cloud.subscribed-services=admin-user-biz
#mysql日志
logging.level.com.jingshang.adminrolebiz.dao=debug

bootstrap.properties拉取配置中心的配置，這里跟服務提供者保持一致，都是拉取的同一個資料庫的配置，這里就不重新粘貼代碼了，小伙伴可直接復制服務提供者的bootstrap.properties中的配置，我這里只在nacos中配置了資料庫，其他配置根據小伙伴們的個人需求進行撰寫

啟動類添加@EnableDiscoveryClient注解

注：搭建消費者的方法與提供者步驟相同，這里不再贅述???????

3、消費提供者提供的方法???????

serviceImpl

package com.jingshang.adminrolebiz.service;

import com.jingshang.adminuserapi.dubbo.UserDubboService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Component;


/**
 * @Author: 王文龍
 * @Date: 2020/9/914:21
 * @Version: 1.0
 * @Describe: 描述:
 */
@Component
public class RoleServiceImpl {


    @Reference
    UserDubboService dubboService;//dubbo服務


    public String findByName(Integer id) {
        return dubboService.findByName(id);
    }
}

注入服務提供者時，要使用dubbo的@Reference注解，我個人遠程呼叫是用的dubbo的rpc協議，如果遠程呼叫使用的的feign的話就另當別論了

注：因為我這里沒有實作介面，所以不需要@Service注解，但需要 @Component注解，而且application.properties也不可以讓dubbo去掃描service包，在你妹使用dubbo的@Service注解的時候，配置里去掃描service包是會報錯的，所以這里注意一下

controller

package com.jingshang.adminrolebiz.controller;

import com.jingshang.adminrolebiz.service.RoleServiceImpl;
import com.jingshang.adminuserapi.dubbo.UserDubboService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

/**
 * @Author: 王文龍
 * @Date: 2020/9/914:25
 * @Version: 1.0
 * @Describe: 描述:
 */
@RestController
@RequestMapping("/role")
public class RoleController {


    @Resource
    private RoleServiceImpl roleService;

    @RequestMapping("/findByName")
    public String findByName(Integer id) {
        return roleService.findByName(id);
    }
}

5、PostMan呼叫介面

!!!! 關于服務注冊、訂閱、配置、限流、降級就到此結束了???????

轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/173027.html

標籤：其他

上一篇：SSM整合：商城小專案001（配置SSM環境+查詢所有操作+添加操作）

下一篇：在建站程序如何防止忽悠