Distributed Query Bus for Axonframework
Provides facilities for QueryBus and QueryUpdateEmitter to work with multiple cluster-instances, i.e. DistributedQueryBus and DistributedQueryEventEmitter.
QueryHandlers are typically feeded by events. The processing instance for the event is determined by the segment allocation.
When using SubcriptionQuery.updates() then QueryUpdateEmitter can provide updates based on events retrieved after the initial query-result.
In Axon Framework V4.1 this works on a single instance or with axon-server.
Given this challenge, inspired by the JpaEventStorageEngine, a shared storage can be used to communicate SubscriptionQueryUpdateMessages.
The JpaQueryUpdateStore manages subscription and their updates.
The QueryUpdatePollingServices is polling on above store and is feeding results into the update-Flux.
JpaQueryUpdateStorage will handle volatile data, which main characteristics is to be short-living.
The data amount will scale alongside the subscriptions and the updates linearly. Given example of DemoApp is subscribing on a per-request basis.
An ideal storage would therefore be some in-memory database. Eviction strategies might be applied when capacity becomes tight.
This package supports SpringBoot AutoConfiguration.
Build the jar and submit it to your local maven repository or equivalent.
Results taken on random hard-ware:
| Benchmark | Mode | Cnt | Score | Units |
|---|---|---|---|---|
| SimpleQueryBusBenchmark.closeSubscription | thrpt | 2 | 133851,913 | ops/s |
| SimpleQueryBusBenchmark.leaveSubscription | thrpt | 2 | 659,467 | ops/s |
| DistributedQueryBusJpaBenchmark.closeSubscription | thrpt | 2 | 81,275 | ops/s |
| DistributedQueryBusJpaBenchmark.leaveSubscription | thrpt | 2 | 32,752 | ops/s |
| DistributedQueryBusRedisBenchmark.closeSubscription | thrpt | 2 | 46,759 | ops/s |
| DistributedQueryBusRedisBenchmark.leaveSubscription | thrpt | 2 | 27,179 | ops/s |
There should be cleansing handling stale subscriptions and their updates.Performance should be benchmark, and scalability assured.reach baseline of 100 ops/secharden benchmark approachmake use of redis ttl