Queue server

This is an simple java queue server.

Goals:

• REST for simple integration
• JSON for flexible message structures
• Netty for fastest TCP/IP and HTTP server realization
• Raft for safe cluster consensus

As result one instance allows:

• send up to 160000 REST message-at-request per second in concurrent mode
• send up to 600000 binary protocol message-at-request per second in concurrent mode

See integration test benchmarks for more details.

See tests for communication example

Recommended server options

localhost$ sysctl net.inet.tcp.msl
net.inet.tcp.msl: 15000
localhost$ sudo sysctl -w net.inet.tcp.msl=1000
net.inet.tcp.msl: 15000 -> 1000
localhost$ ulimit -n
2048
localhost$ sudo ulimit -n 65536
localhost$ ulimit -n
65536

Recommended java options

-server
-Xms4g
-Xmx4g
-Xss6m
-XX:+AggressiveOpts
-XX:+UseCompressedOops
-XX:-MaxFDLimit
-XX:+AlwaysPreTouch
-XX:+DisableExplicitGC
-XX:+TieredCompilation
-XX:+UnlockDiagnosticVMOptions
-XX:+UnlockExperimentalVMOptions
-XX:InitialRAMFraction=1
-XX:MaxRAMFraction=1
-XX:MinRAMFraction=1
-XX:+UseAES
-XX:+UseAESIntrinsics
-XX:+UseG1GC
-XX:+UseStringDeduplication
-XX:-UseBiasedLocking
-XX:ConcGCThreads=5
-XX:G1HeapRegionSize=16m
-XX:G1MaxNewSizePercent=80
-XX:G1MixedGCLiveThresholdPercent=50
-XX:G1NewSizePercent=50
-XX:InitiatingHeapOccupancyPercent=10
-XX:MaxGCPauseMillis=100
-XX:NewSize=512m
-XX:ParallelGCThreads=20
-XX:ReservedCodeCacheSize=256m
-XX:TargetSurvivorRatio=90
-Dio.netty.leakDetectionLevel=disabled
-Djava.net.preferIPv4Stack=true