欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

springboot?整合?dubbo?的實現(xiàn)組聚合詳情

 更新時間:2022年07月21日 14:20:56   作者:久違の歡喜  
這篇文章主要介紹了springboot整合dubbo的實現(xiàn)組聚合詳情,文章圍繞主題展開詳細(xì)的內(nèi)容介紹,具有一定的參考價值,需要的小伙伴可以參考一下

消費者

yml 文件配置:

dubbo:
  application:
    name: dubbo-gateway
  registry:
    address: zookeeper://127.0.0.1:2181
  server: true
  provider:
    timeout: 3000
  protocol:
    name: dubbo
    port: 20881

controller 類:

@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)購買的訂單
        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/ 目錄下有一個 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 聚合策略時,可使用 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

接口及其實現(xiàn)

OrderService 接口:

public interface OrderService {

    /**
     * 使用當(dāng)前登陸人獲取已經(jīng)購買的訂單
     * @param userId
     * @param page
     * @return
     */
    Page<OrderVO> getOrderByUserId(Integer userId, Page<OrderVO> page);

}

OrderServiceImplA 實現(xiàn)類:

@DubboService(group = "2017")
@Slf4j
public class OrderServiceImplA implements OrderService {

    @Autowired
    private MoocOrder2017TMapper moocOrder2017TMapper;

    /**
     * 使用當(dāng)前登陸人獲取已經(jīng)購買的訂單
     *
     * @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ù)失敗,用戶編號未傳入");
            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 實現(xiàn)類:

@DubboService(group = "2018")
@Slf4j
public class OrderServiceImplB implements OrderService {

    @Autowired
    private MoocOrder2018TMapper moocOrder2018TMapper;

    /**
     * 使用當(dāng)前登陸人獲取已經(jīng)購買的訂單
     *
     * @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ù)失敗,用戶編號未傳入");
            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 '主鍵編號',
  `cinema_id` int DEFAULT NULL COMMENT '影院編號',
  `field_id` int DEFAULT NULL COMMENT '放映場次編號',
  `film_id` int DEFAULT NULL COMMENT '電影編號',
  `seats_ids` varchar(50) DEFAULT NULL COMMENT '已售座位編號',
  `seats_name` varchar(200) DEFAULT NULL COMMENT '已售座位名稱',
  `film_price` double DEFAULT NULL COMMENT '影片售價',
  `order_price` double DEFAULT NULL COMMENT '訂單總金額',
  `order_time` timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT '下單時間',
  `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 '主鍵編號',
  `cinema_id` int DEFAULT NULL COMMENT '影院編號',
  `field_id` int DEFAULT NULL COMMENT '放映場次編號',
  `film_id` int DEFAULT NULL COMMENT '電影編號',
  `seats_ids` varchar(50) DEFAULT NULL COMMENT '已售座位編號',
  `seats_name` varchar(200) DEFAULT NULL COMMENT '已售座位名稱',
  `film_price` double DEFAULT NULL COMMENT '影片售價',
  `order_price` double DEFAULT NULL COMMENT '訂單總金額',
  `order_time` timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT '下單時間',
  `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 的實現(xiàn)組聚合詳情的文章就介紹到這了,更多相關(guān)springboot 整合 dubbo內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • IDEA2022創(chuàng)建SpringBoot項目的圖文教程

    IDEA2022創(chuàng)建SpringBoot項目的圖文教程

    本文主要介紹了IDEA2022創(chuàng)建SpringBoot項目的圖文教程,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2023-01-01
  • 簡單了解Java編程中對異常處理的運用

    簡單了解Java編程中對異常處理的運用

    這篇文章主要簡單介紹了Java編程中對異常處理的運用,是Java入門學(xué)習(xí)中的基礎(chǔ)知識,需要的朋友可以參考下
    2015-09-09
  • Spring Cloud gateway 網(wǎng)關(guān)如何攔截Post請求日志

    Spring Cloud gateway 網(wǎng)關(guān)如何攔截Post請求日志

    這篇文章主要介紹了Spring Cloud gateway 網(wǎng)關(guān)如何攔截Post請求日志的操作,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2021-07-07
  • Java源碼解析阻塞隊列ArrayBlockingQueue常用方法

    Java源碼解析阻塞隊列ArrayBlockingQueue常用方法

    今天小編就為大家分享一篇關(guān)于Java源碼解析阻塞隊列ArrayBlockingQueue常用方法,小編覺得內(nèi)容挺不錯的,現(xiàn)在分享給大家,具有很好的參考價值,需要的朋友一起跟隨小編來看看吧
    2019-01-01
  • Java 實戰(zhàn)范例之進銷存管理系統(tǒng)的實現(xiàn)

    Java 實戰(zhàn)范例之進銷存管理系統(tǒng)的實現(xiàn)

    讀萬卷書不如行萬里路,只學(xué)書上的理論是遠(yuǎn)遠(yuǎn)不夠的,只有在實戰(zhàn)中才能獲得能力的提升,本篇文章手把手帶你用java+vue+Springboot+ssm+mysql+maven+redis實現(xiàn)一個前后端分離的進銷存管理系統(tǒng),大家可以在過程中查缺補漏,提升水平
    2021-11-11
  • 如何使用Java計算修改文件的MD5值

    如何使用Java計算修改文件的MD5值

    這篇文章主要介紹了如何使用Java計算修改文件的MD5值,MD5是一種被廣泛使用的密碼散列函數(shù),可以產(chǎn)生出一個128位(16字節(jié))的散列值,用于確保信息傳輸完整一致,需要的朋友可以參考下
    2023-04-04
  • SpringMVC編程使用Controller接口實現(xiàn)控制器實例代碼

    SpringMVC編程使用Controller接口實現(xiàn)控制器實例代碼

    這篇文章主要介紹了SpringMVC編程使用Controller接口實現(xiàn)控制器實例代碼,具有一定參考價值,需要的朋友可以參考下。
    2017-11-11
  • Java Flink窗口觸發(fā)器Trigger的用法詳解

    Java Flink窗口觸發(fā)器Trigger的用法詳解

    Trigger(窗口觸發(fā)器)決定了窗口(由 WindowAssigner 產(chǎn)生)什么時候調(diào)用窗口處理函數(shù)。可以根據(jù)指定的時間或數(shù)據(jù)元素條件來決定什么時候觸發(fā)。本文將詳細(xì)講講其用法,需要的可以參考一下
    2022-07-07
  • java分割日期時間段代碼

    java分割日期時間段代碼

    這篇文章主要為大家詳細(xì)介紹了java分割日期時間段代碼,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2016-09-09
  • SpringBoot+Mybatis-plus+shardingsphere實現(xiàn)分庫分表的方案

    SpringBoot+Mybatis-plus+shardingsphere實現(xiàn)分庫分表的方案

    實現(xiàn)億級數(shù)據(jù)量分庫分表的項目是一個挑戰(zhàn)性很高的任務(wù),下面是一個基于Spring Boot的簡單實現(xiàn)方案,感興趣的朋友一起看看吧
    2024-03-03

最新評論