SpringCloud微服務集成Dubbo的詳細過程
1、Dubbo介紹
Apache Dubbo 是一款易用、高性能的 WEB 和 RPC 框架，同時為構建企業(yè)級微服務提供服務發(fā)現、流量治理、可觀測、認證鑒權等能力、工具與最佳實踐。用于解決微服務架構下的服務治理與通信問題，官方提供了 Java、Golang 等多語言 SDK 實現。使用 Dubbo 開發(fā)的微服務原生具備相互之間的遠程地址發(fā)現與通信能力， 利用 Dubbo 提供的豐富服務治理特性，可以實現諸如服務發(fā)現、負載均衡、流量調度等服務治理訴求。Dubbo 被設計為高度可擴展，用戶可以方便的實現流量攔截、選址的各種定制邏輯。
Dubbo官網：https://cn.dubbo.apache.org/zh-cn/
Dubbo文檔：https://cn.dubbo.apache.org/zh-cn/overview/quickstart/
Dubbo GitHub地址：https://github.com/apache/dubbo
Dubbo 使用版本對應關系：https://github.com/alibaba/spring-cloud-alibaba/wiki/版本說明#2021x-分支 選擇和項目相互對應的版本進行使用。這里我使用的是Dubbo 2.7.8
2、Dubbo連接注冊中心
Dubbo推薦使用Zookeeper作為注冊中心，Zookeeper是Apacahe Hadoop的子項目，是一個樹型的目錄服務，支持變更推送，適合作為 Dubbo 服務的注冊中心，工業(yè)強度較高，可用于生產環(huán)境。除此之外Dubbo還可以使用阿里巴巴的nacos做注冊中心。Nacos作為注冊中心Dubbo使用與ZooKeeper基本相同，在使用上，不同的地方只有以下兩點：
- 1、導入的依賴，配置不同；
- 2、注解不同，ZooKeeper使用@Service、@Reference注解，Nacos使用@DubboService、@DubboReference注解；
3、Dubbo負載均衡
- RandomLoadBalance：加權隨機，默認算法，默認權重相同；
- RoundRobinLoadBalance：加權輪詢，默認權重相同；
- LeastActiveLoadBalance：最少活躍優(yōu)先+加權隨機，能者多勞；
- ConsistentHashLoadBalance：一致性Hash，確定入參，確定提供者，適用于有狀態(tài)的請求；
4、Dubbo Admin下載與使用
官網地址：https://github.com/apache/dubbo-adminDubbo和Dubbo Admin版本說明：https://cn.dubbo.apache.org/zh-cn/blog/2019/01/07/新版-dubbo-admin-介紹/
4.1、修改配置文件
進入dubbo-admin-server的resources目錄，修改application.properties文件修改配置中心。默認為zookeeper：
admin.registry.address注冊中心 admin.config-center 配置中心 admin.metadata-report.address元數據中心
由于我使用nacos，修改注冊中心為nacos。 nacos注冊中心有 GROUP 和 namespace:
admin.registry.address=nacos://127.0.0.1:8848?group=DEFAULT_GROUP&namespace=public&username=nacos&password=nacos admin.config-center=nacos://127.0.0.1:8848?group=dubbo&username=nacos&password=nacos admin.metadata-report.address=nacos://127.0.0.1:8848?group=dubbo&username=nacos&password=nacos //改為自己的注冊中心： admin.registry.address=nacos://localhost:8848?group=DEFAULT_GROUP&namespace=23857f22-27ac-4947-988a-1b88d4eeb807&username=nacos&password=nacos admin.config-center=nacos://localhost:8848?group=DEFAULT_GROUP&namespace=23857f22-27ac-4947-988a-1b88d4eeb807&username=nacos&password=nacos admin.metadata-report.address=nacos://localhost:8848?group=DEFAULT_GROUP&namespace=23857f22-27ac-4947-988a-1b88d4eeb807&username=nacos&password=nacos
4.2、Dubbo Admin項目打包
在項目根目錄進行打包，跳過測試:
mvn clean package -Dmaven.test.skip=true
進入dubbo-admin-0.6.0/dubbo-admin-distribution/target 進行啟動后端：
java -jar dubbo-admin-0.6.0.jar
dubbo-admin-ui 目錄下執(zhí)行命令啟動前端：
npm run dev
這是官方項目開發(fā)環(huán)境說明，打開項目就能看到：
4.3 訪問dubbo admin
瀏覽器輸入地址進行訪問,之前的dubbo-admin老版本用的是Tomcat啟動的，后端端口是8080（可能會沖突），前端端口是8081
http://localhost:8081
新版的dubbo-admin用的是Netty，默認配置端口是38080，前端端口38082
http://localhost:38082 或 http://localhost:38080
用戶名密碼都是root
登錄成功：
5、SpringCloud集成Dubbo
在SpringBoot模塊中引入maven依賴：
<!-- Dubbo Spring Cloud Starter -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>這里使用用戶模塊和訂單模塊模擬微服務使用Dubbo RPC的調用。在提供者模塊中加入Dubbo依賴，在配置文件中設置dubbo連接注冊中心和配置中心：
dubbo:
application:
name: user-service-model-provider
protocol:
name: dubbo
port: -1
provider:
group: DEFAULT_GROUP
version: 2.0
#port: 20881
registry:
address: nacos://${nacos.address:127.0.0.1}:8848?username=nacos&password=nacos
#配置nacos自定義命名空間
parameters:
namespace: 23857f22-27ac-4947-988a-1b88d4eeb807
group: DEFAULT_GROUP
# registry:
# address: zookeeper://${zookeeper.address:127.0.0.1}:2181
metadata-report:
address: nacos://${nacos.address:127.0.0.1}:8848?username=nacos&password=nacos
#配置nacos自定義命名空間
parameters:
namespace: 23857f22-27ac-4947-988a-1b88d4eeb807配置添加成功后，在業(yè)務模塊service層，新建一個對外提供的dubbo實現類UserExternalServiceImpl，需要使用@DubboService注解，@Service注解盡量不要使用，可以使用@Componet代替。代碼如下：
//@Service
@Component
@DubboService(timeout = 1000 * 10,group = "userGroup",version = "2.0")
public class UserExternalServiceImpl implements IUserExternalService {
@Autowired
private IUserService userService;
@Override
public Response selectUserAll() {
// try {
// TimeUnit.MILLISECONDS.sleep(1000*5);
// } catch (InterruptedException e) {
// e.printStackTrace();
// }
return Response.success(userService.selectUserAll());
}
@Override
public Response insert(UserExternal userExternal) {
// boolean flag = true;
// if (flag == true){
// throw new ParamException(500,"用戶模塊出現錯誤，需要回滾");
// }
// try {
// TimeUnit.MILLISECONDS.sleep(20000);
// } catch (InterruptedException e) {
// e.printStackTrace();
// }
User user=new User();
BeanUtils.copyProperties(userExternal,user);
boolean save = userService.save(user);
if (save){
return Response.success();
}else {
return Response.fail();
}
}
}然后還需要在新建一個專門存dubbo的對外接口服務模塊用interface-module名稱，在該模塊中新建一個IUserExternalService接口，該接口實現在用戶模塊中的UserExternalServiceImpl實現類：
public interface IUserExternalService {
Response<List<UserExternal>> selectUserAll();
Response insert(UserExternal user);
}現在我們的接口提供方已經編寫完成了，接下來開始編寫接口使用方也就是消費者。在訂單模塊中引入dubbo依賴，在配置文件中將dubbo連接注冊中心和配置中心：
dubbo:
application:
name: order-service-model-consumer
consumer:
group: DEFAULT_GROUP
version: 2.0
protocol:
name: dubbo
port: -1
registry:
address: nacos://${nacos.address:127.0.0.1}:8848?username=nacos&password=nacos
#配置nacos自定義命名空間
parameters:
namespace: 23857f22-27ac-4947-988a-1b88d4eeb807
# registry:
# address: zookeeper://${zookeeper.address:127.0.0.1}:2181
cloud:
subscribed-services: user-service-model-provider
metadata-report:
address: nacos://${nacos.address:127.0.0.1}:8848?username=nacos&password=nacos
#配置nacos自定義命名空間
parameters:
namespace: 23857f22-27ac-4947-988a-1b88d4eeb807下面我們需要引入剛剛新建存dubbo接口模塊的依賴包，然后就可以使用該接口了。首先建一個IDubboUserService的接口實現DubboUserServiceImpl類，意思是這個類是專門存放通過dubbo接口調用用戶模塊的業(yè)務類，后續(xù)在訂單模塊中處理用戶模塊信息都可以在該業(yè)務類中進行處理。
IDubboUserService類代碼：
public interface IDubboUserService {
List<UserExternal> selectUserAll();
}DubboUserServiceImpl業(yè)務類代碼,需要在該類中使用@DubboReference(group = "userGroup",version = "2.0")注解注入IUserExternalService接口信息，通過Dubbo RPC實現遠程調用，注意group 和version 需要和提供方相互對應，不然會注入失?。?/p>
@Service
@Slf4j
public class DubboUserServiceImpl implements IDubboUserService {
@DubboReference(group = "userGroup",version = "2.0")
private IUserExternalService userExternalService;
@Override
public List<UserExternal> selectUserAll() {
//添加blog
Blog blog = new Blog();
blog.setUid(UUID.randomUUID().toString());
blog.setTitle("dubbo測試Test");
blog.setContent("啊");
blog.setSummary("12");
blog.setTagUid("3c16b9093e9b1bfddbdfcb599b23d835");
blogService.insert(blog);
//處理相關邏輯
Response<List<UserExternal>> response = userExternalService.selectUserAll();
UserExternal user = new UserExternal();
user.setUserName("dubbo測試Test");
user.setAccount("system");
user.setEmail("dubbo@gemail.com");
Response insert = userExternalService.insert(user);
System.out.println(insert);
return response.getModel();
}
}通過上面的代碼，就可以實現服務模塊與模塊之間的遠程調用了。使用Dubbo在訂單模塊調用用戶模塊就和調用其他業(yè)務類代碼一樣通過依賴注入就可以了，是不是非常方便。
5、dubbo使用Sentinel進行限流和異常兜底
需要引入Maven依賴：
<!-- 在dubbo中使用 Sentinel 需要添加下面依賴 -->
<dependency>
<groupId>com.alibaba.csp</groupId>
<artifactId>sentinel-apache-dubbo-adapter</artifactId>
</dependency>由于限流和兜底是消費方要處理的事情，所以我們只需要在訂單模塊中引入上面依賴即可。在DubboUserServiceImpl中，通過@SentinelResource注解處理，代碼如下：
@Service
@Slf4j
public class DubboUserServiceImpl implements IDubboUserService {
@DubboReference(group = "userGroup",version = "2.0")
private IUserExternalService userExternalService;
@Autowired
private IBlogService blogService;
// @PostConstruct
// private void initFlowRules(){
// System.out.println("Sentinel initFlowRules start===");
// List<FlowRule> rules = new ArrayList<>();
// FlowRule rule = new FlowRule();
// rule.setResource(IDubboUserService.class.getName());
// rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
// // Set limit QPS to 20.
// rule.setCount(20);
// rules.add(rule);
// FlowRuleManager.loadRules(rules);
// System.out.println("Sentinel initFlowRules end====");
// }
@Override
@SentinelResource(value = "com.itmy.user.service.IUserExternalService:selectUserAll()", //當前方法的路徑
blockHandler = "selectUserAll",
blockHandlerClass = CustomerBlockHandler.class, //觸發(fā)限流 走該類的blockHandler = "selectUserAll"方法
fallback = "selectUserAllFallback",
fallbackClass = UserFallback.class, //dubbo調用接口異常，走該類的 fallback = "selectUserAllFallback"方法
exceptionsToIgnore = {IllegalArgumentException.class})
//fallback 負責業(yè)務異常 blockHandler限流方法 exceptionsToIgnore 報該異常fallback不處理
@GlobalTransactional(rollbackFor = Exception.class,timeoutMills = 30000,name = "order_tx_group") //seata事務注解，目前沒有使用后面會在seata博客中介紹。
public List<UserExternal> selectUserAll() {
//添加blog
Blog blog = new Blog();
blog.setUid(UUID.randomUUID().toString());
blog.setTitle("dubbo事務測試Test");
blog.setContent("dubbo事務測試Test啊的服務器打");
blog.setSummary("12");
blog.setTagUid("3c16b9093e9b1bfddbdfcb599b23d835");
blogService.insert(blog);
//處理相關邏輯
Response<List<UserExternal>> response = userExternalService.selectUserAll();
// boolean flag = true;
// if (flag == true){
// throw new ParamException(500,"用戶模塊出現錯誤，需要回滾");
// }
UserExternal user = new UserExternal();
user.setUserName("dubbo事務");
user.setAccount("system");
user.setEmail("dubbo@gemail.com");
Response insert = userExternalService.insert(user);
System.out.println(insert);
return response.getModel();
}
}CustomerBlockHandler處理限流的相關代碼：
@Slf4j
public class CustomerBlockHandler {
/**
* 查詢用戶熱點限流測試
* @param name
* @param email
* @param exception
* @return
*/
public static Response selectUserBlockException(@RequestParam(value = "name",required = false) String name,
@RequestParam(value = "email",required = false) String email,
BlockException exception){
log.error("CustomerBlockHandler|selectUserBlockException is fail");
return Response.fail(FallbackErrorEnum.USER_MODULE_FALL);
}
/**
* 查詢限流
* @return
*/
public static Response redisFindBlockException(BlockException exception){
log.error("添加訂單 redis|添加用戶 redis信息，調用接口被限流。。。。。");
return Response.fail(FallbackErrorEnum.REDIS_FIND_FALL);
}
public static List<UserExternal> selectUserAll(BlockException exception){
log.error("添加訂單|添加用戶信息，觸發(fā)限流控制。。。。。");
throw new ParamException(600,"添加用戶信息異常："+exception.getMessage());
}
}UserFallback異常處理：
@Slf4j
public class UserFallback {
public static List<UserExternal> selectUserAllFallback(Throwable throwable) {
log.error("添加訂單|添加用戶信息異常，觸發(fā)熔斷兜底操作。");
throw new ParamException(600,"添加用戶信息異常，觸發(fā)兜底操作");
}
}6、總結
SpringCloud集成Dubbo到目前為止就介紹完畢了，希望本博客對你有所幫助。目前只介紹了如何使用dubbo，dubbo還有需多需要去學習的地方，讓我們持續(xù)學習新的知識，來應對工作中的各種問題。
到此這篇關于SpringCloud微服務集成Dubbo的文章就介紹到這了,更多相關SpringCloud集成Dubbo內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
這篇文章主要介紹了Springboot傳輸數據時日期格式化問題,本文通過示例代碼給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2023-09-09
SpringBoot使用Apache Tika實現多種文檔的內容解析
在日常開發(fā)中,我們經常需要解析不同類型的文檔,如PDF、Word、Excel、HTML、TXT等,Apache Tika是一個強大的內容解析工具,可以輕松地提取文檔中的內容和元數據信息,本文將通過SpringBoot和Apache Tika的結合,介紹如何實現對多種文檔格式的內容解析2024-12-12
這篇文章主要介紹了Java簡單數組排序,實例分析了基于冒泡法實現數組排序的相關技巧,簡單實用,具有一定參考借鑒價值,需要的朋友可以參考下2015-10-10
這篇文章主要介紹了Spring Validation實現原理分析，小編覺得挺不錯的，現在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2018-07-07
接口在JAVA編程語言中是一個抽象類型，是抽象方法的集合，接口通常以interface來聲明。一個類通過繼承接口的方式，從而來繼承接口的抽象方法2021-10-10
SpringBoot整合SpringSecurityOauth2實現鑒權動態(tài)權限問題
這篇文章主要介紹了SpringBoot整合SpringSecurityOauth2實現鑒權-動態(tài)權限,本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-06-06
這篇文章主要介紹了git server“丟失”commit問題，本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2020-05-05
這篇文章主要介紹了Java中生成微信小程序太陽碼的實現方案,本文講解了如何生成微信小程序太陽碼，通過微信提供的兩種方案都可以實現，在實際的項目中建議采用第二種方案，需要的朋友可以參考下2022-05-05
這篇文章主要為大家介紹了java?獲取子串速率比較分析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-12-12
這篇文章主要介紹了Java中構造、生成XML簡明教程,本文通過dom4j包來完成,需要的朋友可以參考下2014-08-08