コンシューマ
ymlファイル構成:
dubbo:
application:
name: dubbo-gateway
registry:
address: zookeeper://127.0.0.1:2181
server: true
provider:
timeout: 3000
protocol:
name: dubbo
port: 20881コントローラクラス:
@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) {
// 获取当前登陆人的信息
String userId = CurrentUser.getUserId();
// 使用当前登陆人获取已经购买的订单
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 ファイルがあります。ファイルの内容は次のとおりです。
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 が提供する集約戦略を使用することも、カスタム集約戦略を使用することもできます。 ダボ集約戦略をカスタマイズするにはどうすればよいですか? リソース ディレクトリに次のディレクトリとファイルを作成します (注: ディレクトリとファイル名は変更できません)。
org.apache.dubbo.rpc.cluster.Merger ファイルの内容は次のとおりです:
# 自定义聚合策略 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インターフェイスとその実装 OrderService インターフェイス:
public interface OrderService {
/**
* 使用当前登陆人获取已经购买的订单
* @param userId
* @param page
* @return
*/
Page<OrderVO> getOrderByUserId(Integer userId, Page<OrderVO> page);
}
OrderServiceImplA 実装クラス:
@DubboService(group = "2017")
@Slf4j
public class OrderServiceImplA implements OrderService {
@Autowired
private MoocOrder2017TMapper moocOrder2017TMapper;
/**
* 使用当前登陆人获取已经购买的订单
*
* @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("订单查询业务失败，用户编号未传入");
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{
// 获取订单总数
EntityWrapper<MoocOrder2017T> entityWrapper = new EntityWrapper<>();
entityWrapper.eq("order_user",userId);
Integer counts = moocOrder2017TMapper.selectCount(entityWrapper);
// 将结果放入Page
result.setTotal(counts);
result.setRecords(ordersByUserId);
return result;
}
}
}
}
OrderServiceImplB 実装クラス:
@DubboService(group = "2018")
@Slf4j
public class OrderServiceImplB implements OrderService {
@Autowired
private MoocOrder2018TMapper moocOrder2018TMapper;
/**
* 使用当前登陆人获取已经购买的订单
*
* @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("订单查询业务失败，用户编号未传入");
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{
// 获取订单总数
EntityWrapper<MoocOrder2018T> entityWrapper = new EntityWrapper<>();
entityWrapper.eq("order_user",userId);
Integer counts = moocOrder2018TMapper.selectCount(entityWrapper);
// 将结果放入Page
result.setTotal(counts);
result.setRecords(ordersByUserId);
return result;
}
}
}
}テーブル構造とデータ
テーブル構造:
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-已关闭' ) 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-已关闭' ) ENGINE=InnoDB DEFAULT CHARSET=utf8 ROW_FORMAT=DYNAMIC COMMENT='订单信息表';
テーブル データ:
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);
デモ:
以上がspringboot が dubbo を統合してグループ集約を実現する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。
声明
この記事は亿速云で複製されています。侵害がある場合は、admin@php.cn までご連絡ください。
高度なJavaプロジェクト管理、自動化の構築、依存関係の解像度にMavenまたはGradleを使用するにはどうすればよいですか？Mar 17, 2025 pm 05:46 PMこの記事では、Javaプロジェクト管理、自動化の構築、依存関係の解像度にMavenとGradleを使用して、アプローチと最適化戦略を比較して説明します。
適切なバージョン化と依存関係管理を備えたカスタムJavaライブラリ（JARファイル）を作成および使用するにはどうすればよいですか？Mar 17, 2025 pm 05:45 PMこの記事では、MavenやGradleなどのツールを使用して、適切なバージョン化と依存関係管理を使用して、カスタムJavaライブラリ（JARファイル）の作成と使用について説明します。
カフェインやグアバキャッシュなどのライブラリを使用して、Javaアプリケーションにマルチレベルキャッシュを実装するにはどうすればよいですか？Mar 17, 2025 pm 05:44 PMこの記事では、カフェインとグアバキャッシュを使用してJavaでマルチレベルキャッシュを実装してアプリケーションのパフォーマンスを向上させています。セットアップ、統合、パフォーマンスの利点をカバーし、構成と立ち退きポリシー管理Best Pra
キャッシュや怠zyなロードなどの高度な機能を備えたオブジェクトリレーショナルマッピングにJPA（Java Persistence API）を使用するにはどうすればよいですか？Mar 17, 2025 pm 05:43 PMこの記事では、キャッシュや怠zyなロードなどの高度な機能を備えたオブジェクトリレーショナルマッピングにJPAを使用することについて説明します。潜在的な落とし穴を強調しながら、パフォーマンスを最適化するためのセットアップ、エンティティマッピング、およびベストプラクティスをカバーしています。[159文字]
Javaのクラスロードメカニズムは、さまざまなクラスローダーやその委任モデルを含むどのように機能しますか？Mar 17, 2025 pm 05:35 PMJavaのクラスロードには、ブートストラップ、拡張機能、およびアプリケーションクラスローダーを備えた階層システムを使用して、クラスの読み込み、リンク、および初期化が含まれます。親の委任モデルは、コアクラスが最初にロードされ、カスタムクラスのLOAに影響を与えることを保証します
ホットAIツール
Undresser.AI Undress
リアルなヌード写真を作成する AI 搭載アプリ
AI Clothes Remover
写真から衣服を削除するオンライン AI ツール。
Undress AI Tool
脱衣画像を無料で
Clothoff.io
AI衣類リムーバー
AI Hentai Generator
AIヘンタイを無料で生成します。
人気の記事
R.E.P.O.説明されたエネルギー結晶と彼らが何をするか（黄色のクリスタル）
3週間前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最高のグラフィック設定
3週間前By尊渡假赌尊渡假赌尊渡假赌
アサシンのクリードシャドウズ：シーシェルリドルソリューション
2週間前ByDDD
R.E.P.O.誰も聞こえない場合はオーディオを修正する方法
3週間前By尊渡假赌尊渡假赌尊渡假赌
WWE 2K25：Myriseのすべてのロックを解除する方法
4週間前By尊渡假赌尊渡假赌尊渡假赌
ホットツール
MinGW - Minimalist GNU for Windows
このプロジェクトは osdn.net/projects/mingw に移行中です。引き続きそこでフォローしていただけます。 MinGW: GNU Compiler Collection (GCC) のネイティブ Windows ポートであり、ネイティブ Windows アプリケーションを構築するための自由に配布可能なインポート ライブラリとヘッダー ファイルであり、C99 機能をサポートする MSVC ランタイムの拡張機能が含まれています。すべての MinGW ソフトウェアは 64 ビット Windows プラットフォームで実行できます。
WebStorm Mac版
便利なJavaScript開発ツール
SecLists
SecLists は、セキュリティ テスターの究極の相棒です。これは、セキュリティ評価中に頻繁に使用されるさまざまな種類のリストを 1 か所にまとめたものです。 SecLists は、セキュリティ テスターが必要とする可能性のあるすべてのリストを便利に提供することで、セキュリティ テストをより効率的かつ生産的にするのに役立ちます。リストの種類には、ユーザー名、パスワード、URL、ファジング ペイロード、機密データ パターン、Web シェルなどが含まれます。テスターはこのリポジトリを新しいテスト マシンにプルするだけで、必要なあらゆる種類のリストにアクセスできるようになります。
Dreamweaver Mac版
ビジュアル Web 開発ツール
Safe Exam Browser
Safe Exam Browser は、オンライン試験を安全に受験するための安全なブラウザ環境です。このソフトウェアは、あらゆるコンピュータを安全なワークステーションに変えます。あらゆるユーティリティへのアクセスを制御し、学生が無許可のリソースを使用するのを防ぎます。
