disruptor_thrift_server
所属分类：微服务
开发工具：Java
文件大小：0KB
下载次数：0
上传日期：2017-08-16 04:58:24
上 传 者：
sh-1993
说明： LMAX中断器支持的Thrift服务器实现（半同步半异步）。，
(LMAX Disruptor backed Thrift Server implementation (half-sync half-async).,)
文件列表:
LICENSE.txt (11609, 2017-08-15)
pom.xml (4697, 2017-08-15)
src/ (0, 2017-08-15)
src/assembly/ (0, 2017-08-15)
src/assembly/distribution.xml (708, 2017-08-15)
src/main/ (0, 2017-08-15)
src/main/java/ (0, 2017-08-15)
src/main/java/com/ (0, 2017-08-15)
src/main/java/com/thinkaurelius/ (0, 2017-08-15)
src/main/java/com/thinkaurelius/thrift/ (0, 2017-08-15)
src/main/java/com/thinkaurelius/thrift/Message.java (14169, 2017-08-15)
src/main/java/com/thinkaurelius/thrift/TDisruptorServer.java (25335, 2017-08-15)
src/main/java/com/thinkaurelius/thrift/TDisruptorServerMBean.java (1266, 2017-08-15)
src/main/java/com/thinkaurelius/thrift/util/ (0, 2017-08-15)
src/main/java/com/thinkaurelius/thrift/util/TBinaryProtocol.java (4768, 2017-08-15)
src/main/java/com/thinkaurelius/thrift/util/ThriftFactories.java (1951, 2017-08-15)
src/main/java/com/thinkaurelius/thrift/util/mem/ (0, 2017-08-15)
src/main/java/com/thinkaurelius/thrift/util/mem/Buffer.java (4381, 2017-08-15)
src/main/java/com/thinkaurelius/thrift/util/mem/FastMemoryOutputTransport.java (5366, 2017-08-15)
src/main/java/com/thinkaurelius/thrift/util/mem/Memory.java (7551, 2017-08-15)
src/main/java/com/thinkaurelius/thrift/util/mem/TMemoryInputTransport.java (4925, 2017-08-15)
src/test/ (0, 2017-08-15)
src/test/java/ (0, 2017-08-15)
src/test/java/com/ (0, 2017-08-15)
src/test/java/com/thinkaurelius/ (0, 2017-08-15)
src/test/java/com/thinkaurelius/thrift/ (0, 2017-08-15)
src/test/java/com/thinkaurelius/thrift/AbstractDisruptorTest.java (9428, 2017-08-15)
src/test/java/com/thinkaurelius/thrift/AbstractMultiConnectionTest.java (3377, 2017-08-15)
src/test/java/com/thinkaurelius/thrift/AbstractMultiRequestTest.java (3225, 2017-08-15)
src/test/java/com/thinkaurelius/thrift/OffHeapMultiConnectionTest.java (1186, 2017-08-15)
src/test/java/com/thinkaurelius/thrift/OffHeapMultiRequestTest.java (1180, 2017-08-15)
src/test/java/com/thinkaurelius/thrift/OffHeapMultiRequestWithReallocateTest.java (1201, 2017-08-15)
src/test/java/com/thinkaurelius/thrift/OffheapMultiConnectionWithRellocateTest.java (1205, 2017-08-15)
src/test/java/com/thinkaurelius/thrift/OnHeapMultiConnectionTest.java (1184, 2017-08-15)
src/test/java/com/thinkaurelius/thrift/OnHeapMultiConnectionWithReallocateTest.java (1204, 2017-08-15)
src/test/java/com/thinkaurelius/thrift/OnHeapMultiRequestTest.java (1178, 2017-08-15)
src/test/java/com/thinkaurelius/thrift/OnHeapMultiRequestWithReallocateTest.java (1198, 2017-08-15)
src/test/java/com/thinkaurelius/thrift/test/ (0, 2017-08-15)
... ...
## LMAX Disruptor backed Thrift Server implementation.
This server is half-sync/half-async and uses separate invocation executor.
On 4 node cluster with SSDs and RF=3 Cassandra (trunk branch, stress -n 3000000, QUORUM read/write)
shows around __3x__ (!) improvement in read and __2x__ (!) improvement in write speed as well as
significant latency improvements over THsHaServer and about __1.5x__ read/write throughput and
__2x__ latency improvement over TThreadedSelectorServer.
## Binaries
Binaries and dependency information for Maven, Ivy, Gradle and others can be found at [http://search.maven.org](http://search.maven.org/#search%7Cga%7C1%7Cthrift-server).
Example for Maven:
```xml
com.thinkaurelius.thrift
thrift-server
0.3.0
```
and for Ivy:
```xml
```
## Performance numbers
### TDisruptorServer (1 write, 3 read runs):
#### WRITE (3,000,000 keys)
Averages from the middle 80% of values:
interval_op_rate : 19539
interval_key_rate : 19539
latency median : 1.9
latency 95th percentile : 5.4
latency 99.9th percentile : 83.3
Total operation time : 00:02:45
#### READ
Averages from the middle 80% of values:
interval_op_rate : 23836
interval_key_rate : 23836
latency median : 2.2
latency 95th percentile : 4.7
latency 99.9th percentile : 21.7
Total operation time : 00:02:36
Averages from the middle 80% of values:
interval_op_rate : 23530
interval_key_rate : 23530
latency median : 2.1
latency 95th percentile : 4.1
latency 99.9th percentile : 23.1
Total operation time : 00:02:25
Averages from the middle 80% of values:
interval_op_rate : 24217
interval_key_rate : 24217
latency median : 2.1
latency 95th percentile : 4.1
latency 99.9th percentile : 24.2
Total operation time : 00:02:28
### THsHaServer (1 write, 3 read runs):
#### WRITE (3,000,000 keys)
Averages from the middle 80% of values:
interval_op_rate : 11167
interval_key_rate : 11167
latency median : 4.1
latency 95th percentile : 6.3
latency 99.9th percentile : 135.6
Total operation time : 00:04:34
#### READ
Averages from the middle 80% of values:
interval_op_rate : 8176
interval_key_rate : 8176
latency median : 6.1
latency 95th percentile : 8.4
latency 99.9th percentile : 27.2
Total operation time : 00:06:20
Averages from the middle 80% of values:
interval_op_rate : 8106
interval_key_rate : 8106
latency median : 5.9
latency 95th percentile : 8.8
latency 99.9th percentile : 29.3
Total operation time : 00:06:15
Averages from the middle 80% of values:
interval_op_rate : 8133
interval_key_rate : 8133
latency median : 5.8
latency 95th percentile : 8.2
latency 99.9th percentile : 26.5
Total operation time : 00:06:15
近期下载者：
相关文件：
收藏者：