springboot?整合?dubbo?的實(shí)現(xiàn)組聚合詳情
更新時(shí)間：2022年07月21日 14:20:56 作者：久違の歡喜
這篇文章主要介紹了springboot整合dubbo的實(shí)現(xiàn)組聚合詳情，文章圍繞主題展開(kāi)詳細(xì)的內(nèi)容介紹，具有一定的參考價(jià)值，需要的小伙伴可以參考一下
消費(fèi)者
yml 文件配置：
dubbo:
application:
name: dubbo-gateway
registry:
address: zookeeper://127.0.0.1:2181
server: true
provider:
timeout: 3000
protocol:
name: dubbo
port: 20881controller 類：
@RestController
@RequestMapping(value = "/order")
@Slf4j
public class OrderController {
/**
* dubbo 的分組特性：group（指定將要聚合的分組）
* dubbo 的聚合特性：merger（指定聚合策略）
* 自定義策略申明文件名為：org.apache.dubbo.rpc.cluster.Merger（不可變），文件夾名：META-INF.dubbo（不可變）
*/
@DubboReference(check = false, group = "2017,2018", merger = "page")
private OrderService orderService;
/**
* 查看訂單信息
*
* @param nowPage
* @param pageSize
* @return
*/
@PostMapping("/getOrderInfo")
public ResponseVO getOrderInfo(@RequestParam(name = "nowPage", required = false, defaultValue = "1") Integer nowPage,
@RequestParam(name = "pageSize", required = false, defaultValue = "5") Integer pageSize) {
// 獲取當(dāng)前登陸人的信息
String userId = CurrentUser.getUserId();
// 使用當(dāng)前登陸人獲取已經(jīng)購(gòu)買的訂單
Page<OrderVO> page = new Page<>(nowPage,pageSize);
if(userId != null && userId.trim().length()>0){
Page<OrderVO> result = orderService.getOrderByUserId(Integer.parseInt(userId), page);
return ResponseVO.success(nowPage, (int) result.getPages(),"",result.getRecords());
}else{
return ResponseVO.serviceFail("用戶未登陸");
}
}
自定義聚合策略
在 dubbo-3.0.9.jar!/META-INF/dubbo/internal/ 目錄下有一個(gè) org.apache.dubbo.rpc.cluster.Merger 文件，文件內(nèi)容如下：
map=org.apache.dubbo.rpc.cluster.merger.MapMerger set=org.apache.dubbo.rpc.cluster.merger.SetMerger list=org.apache.dubbo.rpc.cluster.merger.ListMerger byte=org.apache.dubbo.rpc.cluster.merger.ByteArrayMerger char=org.apache.dubbo.rpc.cluster.merger.CharArrayMerger short=org.apache.dubbo.rpc.cluster.merger.ShortArrayMerger int=org.apache.dubbo.rpc.cluster.merger.IntArrayMerger long=org.apache.dubbo.rpc.cluster.merger.LongArrayMerger float=org.apache.dubbo.rpc.cluster.merger.FloatArrayMerger double=org.apache.dubbo.rpc.cluster.merger.DoubleArrayMerger boolean=org.apache.dubbo.rpc.cluster.merger.BooleanArrayMerger
其中申明了 dubbo 定義的聚合策略。在指定dubbo 聚合策略時(shí)，可使用 dubbo 提供的聚合策略，也可以使用自定義的聚合策略。
如何自定義 dubbo 聚合策略？
在 resources 目錄下創(chuàng)建以下目錄及文件（注意：目錄及文件名稱不可變）。
org.apache.dubbo.rpc.cluster.Merger 文件內(nèi)容如下：
# 自定義聚合策略 page=com.stylefeng.guns.gateway.config.PageMerger
自定義聚合策略類：
package com.stylefeng.guns.gateway.config;
import com.baomidou.mybatisplus.plugins.Page;
import org.apache.dubbo.rpc.cluster.Merger;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;
public class PageMerger implements Merger<Page> {
@Override
public Page merge(Page... items) {
Page<Object> page = new Page<>();
List<Object> records = new ArrayList<>();
AtomicInteger total = new AtomicInteger();
Arrays.stream(items).forEach(item -> {
records.addAll(item.getRecords());
total.addAndGet((int) item.getPages());
});
page.setRecords(records);
page.setSize(total.get());
return page;
}
}提供者
yml 文件配置：
dubbo:
application:
name: dubbo-order
registry:
address: zookeeper://127.0.0.1:2181
server: true
provider:
timeout: 3000
protocol:
name: dubbo
port: 20885接口及其實(shí)現(xiàn)
OrderService 接口：
public interface OrderService {
/**
* 使用當(dāng)前登陸人獲取已經(jīng)購(gòu)買的訂單
* @param userId
* @param page
* @return
*/
Page<OrderVO> getOrderByUserId(Integer userId, Page<OrderVO> page);
}OrderServiceImplA 實(shí)現(xiàn)類：
@DubboService(group = "2017")
@Slf4j
public class OrderServiceImplA implements OrderService {
@Autowired
private MoocOrder2017TMapper moocOrder2017TMapper;
/**
* 使用當(dāng)前登陸人獲取已經(jīng)購(gòu)買的訂單
*
* @param userId
* @param page
* @return
*/
@Override
public Page<OrderVO> getOrderByUserId(Integer userId, Page<OrderVO> page) {
Page<OrderVO> result = new Page<>();
if(userId == null){
log.error("訂單查詢業(yè)務(wù)失敗，用戶編號(hào)未傳入");
return null;
}else{
List<OrderVO> ordersByUserId = moocOrder2017TMapper.getOrdersByUserId(userId,page);
if(ordersByUserId==null && ordersByUserId.size()==0){
result.setTotal(0);
result.setRecords(new ArrayList<>());
return result;
}else{
// 獲取訂單總數(shù)
EntityWrapper<MoocOrder2017T> entityWrapper = new EntityWrapper<>();
entityWrapper.eq("order_user",userId);
Integer counts = moocOrder2017TMapper.selectCount(entityWrapper);
// 將結(jié)果放入Page
result.setTotal(counts);
result.setRecords(ordersByUserId);
return result;
}
}
}
}OrderServiceImplB 實(shí)現(xiàn)類：
@DubboService(group = "2018")
@Slf4j
public class OrderServiceImplB implements OrderService {
@Autowired
private MoocOrder2018TMapper moocOrder2018TMapper;
/**
* 使用當(dāng)前登陸人獲取已經(jīng)購(gòu)買的訂單
*
* @param userId
* @param page
* @return
*/
@Override
public Page<OrderVO> getOrderByUserId(Integer userId, Page<OrderVO> page) {
Page<OrderVO> result = new Page<>();
if(userId == null){
log.error("訂單查詢業(yè)務(wù)失敗，用戶編號(hào)未傳入");
return null;
}else{
List<OrderVO> ordersByUserId = moocOrder2018TMapper.getOrdersByUserId(userId,page);
if(ordersByUserId==null && ordersByUserId.size()==0){
result.setTotal(0);
result.setRecords(new ArrayList<>());
return result;
}else{
// 獲取訂單總數(shù)
EntityWrapper<MoocOrder2018T> entityWrapper = new EntityWrapper<>();
entityWrapper.eq("order_user",userId);
Integer counts = moocOrder2018TMapper.selectCount(entityWrapper);
// 將結(jié)果放入Page
result.setTotal(counts);
result.setRecords(ordersByUserId);
return result;
}
}
}
}表結(jié)構(gòu)及數(shù)據(jù)
表結(jié)構(gòu)：
CREATE TABLE `mooc_order_2017_t` ( `UUID` varchar(100) DEFAULT NULL COMMENT '主鍵編號(hào)', `cinema_id` int DEFAULT NULL COMMENT '影院編號(hào)', `field_id` int DEFAULT NULL COMMENT '放映場(chǎng)次編號(hào)', `film_id` int DEFAULT NULL COMMENT '電影編號(hào)', `seats_ids` varchar(50) DEFAULT NULL COMMENT '已售座位編號(hào)', `seats_name` varchar(200) DEFAULT NULL COMMENT '已售座位名稱', `film_price` double DEFAULT NULL COMMENT '影片售價(jià)', `order_price` double DEFAULT NULL COMMENT '訂單總金額', `order_time` timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT '下單時(shí)間', `order_user` int DEFAULT NULL COMMENT '下單人', `order_status` int DEFAULT '0' COMMENT '0-待支付,1-已支付,2-已關(guān)閉' ) ENGINE=InnoDB DEFAULT CHARSET=utf8 ROW_FORMAT=DYNAMIC COMMENT='訂單信息表'; CREATE TABLE `mooc_order_2018_t` ( `UUID` varchar(100) DEFAULT NULL COMMENT '主鍵編號(hào)', `cinema_id` int DEFAULT NULL COMMENT '影院編號(hào)', `field_id` int DEFAULT NULL COMMENT '放映場(chǎng)次編號(hào)', `film_id` int DEFAULT NULL COMMENT '電影編號(hào)', `seats_ids` varchar(50) DEFAULT NULL COMMENT '已售座位編號(hào)', `seats_name` varchar(200) DEFAULT NULL COMMENT '已售座位名稱', `film_price` double DEFAULT NULL COMMENT '影片售價(jià)', `order_price` double DEFAULT NULL COMMENT '訂單總金額', `order_time` timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT '下單時(shí)間', `order_user` int DEFAULT NULL COMMENT '下單人', `order_status` int DEFAULT '0' COMMENT '0-待支付,1-已支付,2-已關(guān)閉' ) ENGINE=InnoDB DEFAULT CHARSET=utf8 ROW_FORMAT=DYNAMIC COMMENT='訂單信息表';
表數(shù)據(jù)：
INSERT INTO `guns_rest`.`mooc_order_2017_t`(`UUID`, `cinema_id`, `field_id`, `film_id`, `seats_ids`, `seats_name`, `film_price`, `order_price`, `order_time`, `order_user`, `order_status`) VALUES ('329123812gnfn31', 1, 1, 2, '1,2,3,4', '第一排1座,第一排2座,第一排3座,第一排4座', 63.2, 126.4, '2017-05-03 12:13:42', 2, 0);
INSERT INTO `guns_rest`.`mooc_order_2017_t`(`UUID`, `cinema_id`, `field_id`, `film_id`, `seats_ids`, `seats_name`, `film_price`, `order_price`, `order_time`, `order_user`, `order_status`) VALUES ('310bb3c3127a4551ad72f2f3e53333c7', 1, 1, 2, '9,10', '第一排9座,第一排10座', 60, 120, '2022-07-20 14:25:42', 2, 0);
INSERT INTO `guns_rest`.`mooc_order_2018_t`(`UUID`, `cinema_id`, `field_id`, `film_id`, `seats_ids`, `seats_name`, `film_price`, `order_price`, `order_time`, `order_user`, `order_status`) VALUES ('124583135asdf81', 1, 1, 2, '1,2,3,4', '第一排1座,第一排2座,第一排3座,第一排4座', 63.2, 126.4, '2018-02-12 11:53:42', 2, 0);演示：
到此這篇關(guān)于springboot 整合 dubbo 的實(shí)現(xiàn)組聚合詳情的文章就介紹到這了,更多相關(guān)springboot 整合 dubbo內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
IDEA2022創(chuàng)建SpringBoot項(xiàng)目的圖文教程
本文主要介紹了IDEA2022創(chuàng)建SpringBoot項(xiàng)目的圖文教程，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2023-01-01
簡(jiǎn)單了解Java編程中對(duì)異常處理的運(yùn)用
這篇文章主要簡(jiǎn)單介紹了Java編程中對(duì)異常處理的運(yùn)用,是Java入門學(xué)習(xí)中的基礎(chǔ)知識(shí),需要的朋友可以參考下2015-09-09
Spring Cloud gateway 網(wǎng)關(guān)如何攔截Post請(qǐng)求日志
這篇文章主要介紹了Spring Cloud gateway 網(wǎng)關(guān)如何攔截Post請(qǐng)求日志的操作，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-07-07
Java源碼解析阻塞隊(duì)列ArrayBlockingQueue常用方法
今天小編就為大家分享一篇關(guān)于Java源碼解析阻塞隊(duì)列ArrayBlockingQueue常用方法，小編覺(jué)得內(nèi)容挺不錯(cuò)的，現(xiàn)在分享給大家，具有很好的參考價(jià)值，需要的朋友一起跟隨小編來(lái)看看吧2019-01-01
Java 實(shí)戰(zhàn)范例之進(jìn)銷存管理系統(tǒng)的實(shí)現(xiàn)
讀萬(wàn)卷書(shū)不如行萬(wàn)里路，只學(xué)書(shū)上的理論是遠(yuǎn)遠(yuǎn)不夠的，只有在實(shí)戰(zhàn)中才能獲得能力的提升，本篇文章手把手帶你用java+vue+Springboot+ssm+mysql+maven+redis實(shí)現(xiàn)一個(gè)前后端分離的進(jìn)銷存管理系統(tǒng),大家可以在過(guò)程中查缺補(bǔ)漏，提升水平2021-11-11
這篇文章主要介紹了如何使用Java計(jì)算修改文件的MD5值,MD5是一種被廣泛使用的密碼散列函數(shù)，可以產(chǎn)生出一個(gè)128位（16字節(jié)）的散列值,用于確保信息傳輸完整一致,需要的朋友可以參考下2023-04-04
SpringMVC編程使用Controller接口實(shí)現(xiàn)控制器實(shí)例代碼
這篇文章主要介紹了SpringMVC編程使用Controller接口實(shí)現(xiàn)控制器實(shí)例代碼，具有一定參考價(jià)值，需要的朋友可以參考下。2017-11-11
Java Flink窗口觸發(fā)器Trigger的用法詳解
Trigger(窗口觸發(fā)器)決定了窗口（由 WindowAssigner 產(chǎn)生）什么時(shí)候調(diào)用窗口處理函數(shù)?？梢愿鶕?jù)指定的時(shí)間或數(shù)據(jù)元素條件來(lái)決定什么時(shí)候觸發(fā)。本文將詳細(xì)講講其用法，需要的可以參考一下2022-07-07
這篇文章主要為大家詳細(xì)介紹了java分割日期時(shí)間段代碼,具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2016-09-09
SpringBoot+Mybatis-plus+shardingsphere實(shí)現(xiàn)分庫(kù)分表的方案
實(shí)現(xiàn)億級(jí)數(shù)據(jù)量分庫(kù)分表的項(xiàng)目是一個(gè)挑戰(zhàn)性很高的任務(wù),下面是一個(gè)基于Spring Boot的簡(jiǎn)單實(shí)現(xiàn)方案,感興趣的朋友一起看看吧2024-03-03