You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
2.3 KiB
2.3 KiB
JAX-RS MongoDB ReactiveStreams to RxJava Examples 
A one stop project for examples of using the ReactiveStreams MongoDB driver with RxJava.
Includes initializing with multiple embedded web servers for further reference and benchmarking
Note: runs embedded MongoDB on separate port 27018 by default, no need to install it.
Current Implementations Done
- Jersey on Grizzly (grizzly-jersey)
- Jersey on Netty (netty-jersey)
- Jersey on Tomcat (tomcat-jersey)
- RestEasy on Undertow (undertow-resteasy)
- RestEasy on Netty (netty-resteasy)
- RestEasy on Tomcat (tomcat-resteasy)
Resource references
- Jersey Reactive Resource - Jersey does not have support for RxJava and is implemented with Completable
- RESTEasy Reactive Resource - RESTEasy does have pluggable support for RxJava (using resteasy-rxjava2) and is implemented with Single
- Synced Resource
Guide
1. Running implementations
Packaging
$ maven package
Running
$ java -jar (implementation)/target/(implementation).jar
$ java -jar grizzly-jersey/target/undertow-resteasy.jar
2. Endpoints
| METHOD | ENDPOINT | DESCRIPTION |
|---|---|---|
| GET | /async/{userID} | Get user from database |
| GET | /async/{userID}/{name}/{phoneNumber} | Create user |
| GET | /sync/{userID} | Get user from database (synced) |
| GET | /sync/{userID}/{name}/{phoneNumber} | Create user (synced) |
3. Benchmark
Use your tool of choice like wrk or JMeter
$ wrk -t12 -c400 -d30s http://127.0.0.1:8080/user/jaryl/Jaryl%20Chng/01189998819991197253