superleo-cn/reactor-example

ReactorExample

How to start the ReactorExample application

1. Run mvn clean install to build your application
2. Start application with java -jar target/reactor-example-1.0-SNAPSHOT.jar server config.yml
3. To check that your application is running enter url http://localhost:8080

Health Check

To see your applications health enter url http://localhost:8081/healthcheck

Non-blocking benchmarking

Reduced the server maxThreads to 8 threads (Default: 1024) in config.yml. Requires Apache HTTP server benchmarking tool

Blocking benchmark

ab -n 10000 -c 70 localhost:8080/sample/blocking

Non-blocking benchmark

ab -n 10000 -c 70 localhost:8080/sample/nonblocking

Reactive Example

Once the server is up and running, you can make the following request to fetch the recommended users. The console logs should show what scheduler the code runs on.

curl "localhost:8080/recommended_users/3?limit=10"

Distributed Tracing

Currently not using the Context API. Leveraging the onScheduleHook to pass trace information. And manually tracing sections. Each span has the tags which includes threads which started and finished the operation

1. Bring up Zipkin locally

curl -sSL https://zipkin.io/quickstart.sh | bash -s
java -jar zipkin.jar

2. Bring up dropwizard application

java -jar target/reactor-example-1.0-SNAPSHOT.jar server config.yml

3. Send sample request and search for trace at http://127.0.0.1:9411/

curl "localhost:8080/recommended_users/3?limit=10"