碼上歡樂
相關內容    簡體    繁體

企業級SpringBoot與Dubbo的使用方式

本文轉載自   查看原文   2019-05-08 18:10   6376    【解決方案系列】亂殺

企業級SpringBoot與Dubbo的使用方式
SpringBoot越來越熱門以至於達到滿大街可見的程度，而Dubbo這個基於二進制的微服務框架又捐獻給Apache孵化，如果不會如何使用那么是不是很不好意思呢？
這次從公司的項目中抽一個小列子來熟悉下如果從零構建，至於深入了解->傳送門:Dubbo官方中文手冊
版本:

  1. Springboot2.x
  2. Double2.6
  3. Zk3.4.14
  4. JDK8

這里就不介紹Dubbo了，傳送去看看以前的：互聯網級微服務架構神器Duubo

zookeepr安裝

下載去官網查找穩定的版本進行使用:http://www.apache.org/dyn/closer.cgi/zookeeper/
先在服務器上安裝zookeeper。

cd /usr/local/src/
#下載
sudo wget http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.4.14/zookeeper-3.4.14.tar.gz
#解壓
tar -zxvf zookeeper-3.4.14.tar.gz
#修改配置文件名稱
mv conf/zoo_sample.cfg zoo.cfg
#啟動zk
./bin/zkServer.sh start
#出現以下字樣代表啟動成功，默認端口2181
Starting zookeeper ... STARTED

SpringBoot2.x整合Dubbo

父工程搭建(pom工程)
<groupId>com.simple.springboot</groupId>
    <artifactId>yun-double</artifactId>
    <version>0.0.1-SNAPSHOT</version>
<packaging>pom</packaging>
<name>yun-double</name>
<description>double</description>

<!--統一管理依賴版本-->
<properties>
	<java.version>1.8</java.version>
	<double.version>2.0.0</double.version>
	<zkclient.version>0.10</zkclient.version>
</properties>

<!-- 依賴於SpringBoot -->
<parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.4.RELEASE</version>
        <relativePath/>
</parent>

<!--依賴定義-->
<dependencyManagement>
	<dependencies>
		<dependency>
			<groupId>com.alibaba.spring.boot</groupId>
			<artifactId>dubbo-spring-boot-starter</artifactId>
			<version>${double.version}</version>
		</dependency>
		<dependency>
			<groupId>com.101tec</groupId>
			<artifactId>zkclient</artifactId>
			<version>${zkclient.version}</version>
		</dependency>
	</dependencies>
</dependencyManagement>
創建公共接口工程common

該工程用於存儲服務層接口，以減少代碼的冗余。

<modelVersion>4.0.0</modelVersion>

<parent>
	<groupId>com.simple.springboot</groupId>
	<artifactId>yun-double</artifactId>
	<version>0.0.1-SNAPSHOT</version>
</parent>

<groupId>com.simple.springboot</groupId>
<artifactId>common</artifactId>
<version>0.0.1-SNAPSHOT</version>

<name>common</name>
<description>公共接口</description>

創建公共接口

public interface UserService {

    String getUserById(int id);

}
創建服務提供者(provider)

Pom文件

<modelVersion>4.0.0</modelVersion>

<groupId>com.simple.springboot</groupId>
<artifactId>provider</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>

<name>provider</name>
<description>生產者</description>


<parent>
	<groupId>com.simple.springboot</groupId>
	<artifactId>yun-double</artifactId>
	<version>0.0.1-SNAPSHOT</version>
</parent>

<dependencies>
	<!-- SpringBoot快速啟動Duubbo -->
	<dependency>
		<groupId>com.alibaba.spring.boot</groupId>
		<artifactId>dubbo-spring-boot-starter</artifactId>
	</dependency>
	<!-- Zk客戶端依賴 -->
	<dependency>
		<groupId>com.101tec</groupId>
		<artifactId>zkclient</artifactId>
		<!-- 排除依賴里的日志 -->
		<exclusions>
			<exclusion>
				<groupId>log4j</groupId>
				<artifactId>log4j</artifactId>
			</exclusion>

			<exclusion>
				<groupId>org.slf4j</groupId>
				<artifactId>slf4j-api</artifactId>
			</exclusion>

			<exclusion>
				<groupId>org.slf4j</groupId>
				<artifactId>slf4j-log4j12</artifactId>
			</exclusion>
		</exclusions>
	</dependency>
	<!-- 導入公共接口依賴 -->
	<dependency>
		<groupId>com.simple.springboot</groupId>
		<artifactId>common</artifactId>
		<version>0.0.1-SNAPSHOT</version>
	</dependency>
</dependencies>

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

在pom文件中我們需要引入Dubbo,Zk客戶端並且引入公共接口工程
application.properties配置文件

#dubbo.application.name 應用名稱
#dubbo.registry.address 注冊中心地址
#dubbo.protocol.name 協議名稱
#dubbo.protocol.port 協議端口
#dubbo.scan dubbo 服務類包目錄
#server.port=8080
spring.application.name=user-pro
dubbo.application.name=user-provider1
dubbo.registry.address=zookeeper://192.168.197.133:2181
dubbo.protocol.name=dubbo
dubbo.protocol.port=20880

在這里dubbo.application.name應用名稱一定不能重復
實現UserService

@Component
@Service(timeout = 10000,interfaceClass = UserService.class)
public class UserServiceImpl implements UserService {

    @Override
    public String getUserById(int id) {
        if(id == 1) {
            return "SimpleWu";
        }else {
            return "Apache Dubbo";
        }
    }
}

@Service 這個注解使用的不是Spring里面的而是com.alibaba.dubbo.config.annotation.Service
timeout 配置超時時間
interfaceClass 接口類
version 服務版本，如果配置了服務版本在消費端引用也必須一樣，具體等會說
創建啟動類
在該工程中我們不需要引入Web模塊浪費端口號，只需要這樣寫啟動類

@EnableDubbo
@EnableDubboConfiguration
@DubboComponentScan("com.simple.springboot.provider.common.impl")
public class ProviderApplication {

    public static void main(String[] args) {
        SpringApplication app = new SpringApplication(ProviderApplication.class);
        app.run(args);
        //dubbo Main獨立運行，脫離web容器
        Main.main(args);
    }

}

@EnableDubbo 啟動Dubbo功能
@EnableDubboConfiguration 啟動Duubbo配置
@DubboComponentScan 掃描提供者實現類

創建服務消費者(consumer)

POM文件

<modelVersion>4.0.0</modelVersion>


<groupId>com.simple.springboot</groupId>
<artifactId>consumer</artifactId>
<version>0.0.1-SNAPSHOT</version>


<name>consumer</name>
<description>消費者</description>

<parent>
	<groupId>com.simple.springboot</groupId>
	<artifactId>yun-double</artifactId>
	<version>0.0.1-SNAPSHOT</version>
</parent>

<dependencies>
	<dependency>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-web</artifactId>
	</dependency>

	<dependency>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-test</artifactId>
	</dependency>
	<!-- SpringBoot快速啟動Duubbo -->
	<dependency>
		<groupId>com.alibaba.spring.boot</groupId>
		<artifactId>dubbo-spring-boot-starter</artifactId>
	</dependency>
	<!-- Zk客戶端依賴 -->
	<dependency>
		<groupId>com.101tec</groupId>
		<artifactId>zkclient</artifactId>
		<!-- 排除依賴里的日志 -->
		<exclusions>
			<exclusion>
				<groupId>log4j</groupId>
				<artifactId>log4j</artifactId>
			</exclusion>

			<exclusion>
				<groupId>org.slf4j</groupId>
				<artifactId>slf4j-api</artifactId>
			</exclusion>

			<exclusion>
				<groupId>org.slf4j</groupId>
				<artifactId>slf4j-log4j12</artifactId>
			</exclusion>
		</exclusions>
	</dependency>
	<!-- 導入公共接口依賴 -->
	<dependency>
		<groupId>com.simple.springboot</groupId>
		<artifactId>common</artifactId>
		<version>0.0.1-SNAPSHOT</version>
	</dependency>
</dependencies>

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

在這個工程中我們是需要依賴Web的，不然咋訪問呢
編寫Application.properties配置文件

spring.application.name=user-con
server.port=8080
dubbo.application.name=user-consumer
dubbo.registry.address=zookeeper://192.168.197.133:2181
dubbo.protocol.name=dubbo
dubbo.protocol.port=20880
#dubbo.scan=com.simple.springboot.provider.common.impl

在這里dubbo.application.name應用名稱一定不能重復
dubbo.scan 該配置指向應該是要和服務提供方一致
編寫Controller

@RestController
public class UserController {

    //timeout 可以不指定，如果提供則有填寫但是version一定要指定 不然會找不到服務 直連需要加url="dubbo://localhost:20880"
    @Reference
    private UserService userService;

    @GetMapping("/dubbo/user/{id}")
    public String getUserById(@PathVariable int id){
        return userService.getUserById(id);
    }
}

在這里是使用@Reference去發現服務而不是@Autowired去注入Bean
@Reference 里面可以配置version,timeout超時時間
如果需要Dubbo直連url="dubbo://localhost:20880"

dubbo提供了四種負載均衡策略,分別是：
1、Random LoadBalance 按權重的隨機負載均衡,也是dubbo默認的負載均衡策略
2、RoundRobin LoadBalance 按權重的輪詢負載均衡,即在輪詢的基礎上添加了權重的策略
3、LeastActive LoadBalance 最少活躍調用數,相同活躍數的隨機訪問,活躍數指調用前后的計數差即響應時間的長短;這種策略可以使響應慢的提供者收到的請求較少,大大提供系統性能
4、ConsistentHash LoadBalance 一致性哈希；相同參數的請求總是發到同一提供者

負載均衡的配置：@Reference(loadbalance = "roundrobin")，loadbalance 的值即為四種負載均衡的名稱,全部小寫

在集群調用失敗時，Dubbo 提供了多種容錯方案，缺省為 failover 重試。下面列舉dubbo支持的容錯策略：

1、Failover Cluster：失敗自動切換，當出現失敗，重試其它服務器。通常用於讀操作，但重試會帶來更長延遲。可通過 retries="XXX" 來設置重試次數(不含第一次)。
2、Failfast Cluster：快速失敗，只發起一次調用，失敗立即報錯。通常用於非冪等性的寫操作，比如新增記錄。
3、Failsafe Cluster：失敗安全，出現異常時，直接忽略。通常用於寫入審計日志等操作。
4、Failback Cluster：失敗自動恢復，后台記錄失敗請求，定時重發。通常用於消息通知操作。
5、Forking Cluster：並行調用多個服務器，只要一個成功即返回。通常用於實時性要求較高的讀操作，但需要浪費更多服務資源。可通過 forks="2" 來設置最大並行數。
6、Broadcast Cluster：廣播調用所有提供者，逐個調用，任意一台報錯則報錯 [2]。通常用於通知所有提供者更新緩存或日志等本地資源信息。

配置如下：@Reference(cluster = "failsafe")這里表示使用失敗安全的容錯策略

編寫啟動類

/**
 * @author:SimpleWu
 * @date: 2019-05-08
 */
@EnableDubbo
@SpringBootApplication
@EnableDubboConfiguration
@DubboComponentScan("com.simple.springboot.provider.common.impl")
public class ConsumerApplication {
	public static void main(String[] args) {
		SpringApplication.run(ConsumerApplication.class,args);
	}
}

然后直接就可以訪問成功了。
如果不想使用注解掃描可以使用properties進行配置

#dubbo.scan=com.simple.springboot.provider.common.impl

參考代碼：傳送門
注意事項:
Dubbo是一個二進制的Rpc框架在傳輸數據過程中，實體類必須經過序列化。
在使用poi導出功能時一定不能把response傳到Service層，否則傳輸到Service是導出不了文件而報錯，至於文件下載也一樣但是相信一般都會有單獨的文件服務器。


免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。



猜您在找 SpringBoot企業級框架 Kubernetes 企業級集群部署方式 使用EF構建企業級應用(四) Gitlab之一---企業級gitlab部署及使用 使用EF構建企業級應用(一) 使用EF構建企業級應用(二) 使用EF構建企業級應用(三) 企業級 SpringBoot 教程 （十三）springboot集成spring cache 企業級 SpringBoot 教程 （二十四）springboot整合docker springboot企業級項目常用的pom依賴
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM