Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/annabergite/abg-rpc
/ types & classes
Types & classes
287 in github.com/annabergite/abg-rpc
⨍
Functions
1,654
◇
Types & classes
287
Class
AbgClient
@author Annabergite
abg-cloud/src/main/java/rpc/abg/client/AbgClient.java:31
Interface
AbgServiceBeanClientProcessor
拦截并处理AbgService远程调用实例, 实现类必须是被spring管理的 @author Annabergite
abg-spring-boot-starter/src/main/java/rpc/abg/boot/TurboServiceBeanClientProcessor.java:11
Class
AbstractClient
abg-jmh/src/main/java/rpc/abg/benchmark/client/AbstractClient.java:9
Class
AddressWithWeight
abg-cloud/src/main/java/rpc/abg/config/AddressWithWeight.java:8
Class
AllIntBean
abg-jmh/src/main/java/rpc/abg/benchmark/bean/AllIntBean.java:3
Class
App
abg-cloud/src/main/java/rpc/abg/transport/client/App.java:41
Class
AppConfig
abg-cloud/src/main/java/rpc/abg/config/client/AppConfig.java:21
Class
ArrayBenchmark
@author Annabergite
abg-jmh/src/main/java/rpc/abg/benchmark/array/ArrayBenchmark.java:24
Class
ArrayListObj
abg-jmh/src/main/java/rpc/abg/benchmark/kryo/KryoByteBufTest.java:104
Class
AtomicIntergerArrayBenchmark
abg-jmh/src/main/java/rpc/abg/benchmark/concurrent/AtomicIntergerArrayBenchmark.java:20
Class
AtomicMuiltInteger
原子性操作多个int @author Annabergite
abg-utils/src/main/java/rpc/abg/util/concurrent/AtomicMuiltInteger.java:14
Class
AtomicMuiltInteger1
原子性操作多个int @author Annabergite
abg-jmh/src/main/java/rpc/abg/benchmark/concurrent/AtomicMuiltInteger1.java:13
Class
AtomicMuiltInteger2
原子性操作多个int @author Annabergite
abg-jmh/src/main/java/rpc/abg/benchmark/concurrent/AtomicMuiltInteger2.java:14
Class
AttachmentThread
just for long time running thread @author Annabergite
abg-utils/src/main/java/rpc/abg/util/concurrent/AttachmentThread.java:14
Class
AttachmentThreadFactory
abg-utils/src/main/java/rpc/abg/util/concurrent/AttachmentThreadFactory.java:10
Class
AttachmentThreadUtils
当线程为AttachmentThread、FastThreadLocalThread时能达到ThreadLocal 1.5x的性能;<br> 当线程不是上述两种,并且线程id小于16k时,可获得跟ThreadLocal相同的性能;<br> 当线程不满足上述两种情况,将只能达到ThreadLocal
abg-utils/src/main/java/rpc/abg/util/concurrent/AttachmentThreadUtils.java:18
Class
BatchSender
abg-cloud/src/main/java/rpc/abg/transport/client/sender/BatchSender.java:12
Class
BooleanSerializer
abg-jmh/src/main/java/rpc/abg/benchmark/serialization/manual/BooleanSerializer.java:5
Class
Booster
加速器 @author Annabergite @param <T>
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool3.java:181
Class
ByteBufInput
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:13
Class
ByteBufInput
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:31
Class
ByteBufOutput
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:15
Class
ByteBufOutput
abg-protostuff/src/main/java/io/protostuff/ByteBufOutput.java:22
Class
ByteBufUtils
abg-utils/src/main/java/rpc/abg/util/ByteBufUtils.java:5
Class
ByteBufUtilsBenchmark
abg-jmh/src/main/java/rpc/abg/benchmark/bytebuf/ByteBufUtilsBenchmark.java:22
Class
ByteBufferBenchmark
abg-jmh/src/main/java/rpc/abg/benchmark/bytebuf/ByteBufferBenchmark.java:21
Class
CellCounter
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentIntegerSequencer.java:39
Class
CellCounter
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentLongSequencer.java:39
Class
ClientConfig
abg-cloud/src/main/java/rpc/abg/config/client/ClientConfig.java:8
Class
CodecConstants
abg-cloud/src/main/java/rpc/abg/transport/client/codec/CodecConstants.java:5
Class
ComplexObj
abg-jmh/src/main/java/rpc/abg/benchmark/kryo/KryoByteBufTest.java:114
Class
CompressBenchmark
abg-jmh/src/main/java/rpc/abg/benchmark/compress/CompressBenchmark.java:33
Interface
CompressType
压缩类型 @author Annabergite
abg-cloud/src/main/java/rpc/abg/protocol/CompressType.java:9
Class
ConcurrentArrayList
only support add get set, not support remove @author Annabergite @param <T>
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentArrayList.java:20
Class
ConcurrentArrayListBenchmark
abg-jmh/src/main/java/rpc/abg/benchmark/array/ConcurrentArrayListBenchmark.java:21
Class
ConcurrentHashMapBenchmark
abg-jmh/src/main/java/rpc/abg/benchmark/map/ConcurrentHashMapBenchmark.java:22
Class
ConcurrentIntArrayMapBenchmark
abg-jmh/src/main/java/rpc/abg/benchmark/map/ConcurrentIntArrayMapBenchmark.java:20
Class
ConcurrentIntToIntArrayMap
高性能,仅适用于key值比较少并且key、value大于0的情况,最多不能超过512k个 @author Annabergite
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentIntToIntArrayMap.java:16
Class
ConcurrentIntToObjectArrayMap
高性能,仅适用于key值比较少的情况,不能超过512k个 @author Annabergite
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentIntToObjectArrayMap.java:16
Class
ConcurrentIntegerSequencer
高性能序号生成器,是AtomicInteger性能的10x,<br> 实现原理为每个线程持有100个数字,线程内简单递增,<br> 该生成器生成数字整体上并不是简单递增的,仅适用于特定场景 @author Annabergite
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentIntegerSequencer.java:14
Class
ConcurrentLongSequencer
高性能序号生成器,是AtomicLong性能的10x,<br> 实现原理为每个线程持有100个数字,线程内简单递增,<br> 该生成器生成数字整体上并不是简单递增的,仅适用于特定场景 @author Annabergite
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentLongSequencer.java:14
Class
ConcurrentObjectPool
@author Annabergite @param <T>
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool.java:17
Class
ConcurrentObjectPool2
@author Annabergite @param <T>
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool2.java:16
Class
ConcurrentObjectPool3
@author Annabergite @param <T>
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool3.java:17
Class
ConfigException
abg-cloud/src/main/java/rpc/abg/config/ConfigException.java:3
Class
ConfigUtils
abg-cloud/src/main/java/rpc/abg/config/ConfigUtils.java:7
Class
ConnectionException
abg-cloud/src/main/java/rpc/abg/transport/client/exception/ConnectionException.java:3
Class
ConnectorContext
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:41
Class
DefaultBenchmark
abg-jmh/src/main/java/rpc/abg/benchmark/kryo/DefaultBenchmark.java:35
Class
DirectConnectDiscover
abg-cloud/src/main/java/rpc/abg/discover/DirectConnectDiscover.java:12
Class
DirectConnectRegister
abg-cloud/src/main/java/rpc/abg/registry/DirectConnectRegister.java:13
Interface
Discover
服务发现,App级别,每个App一个Discover @author Annabergite
abg-cloud/src/main/java/rpc/abg/discover/Discover.java:15
Interface
DiscoverListener
abg-cloud/src/main/java/rpc/abg/discover/DiscoverListener.java:7
Class
EmptyMethodParam
abg-cloud/src/main/java/rpc/abg/param/EmptyMethodParam.java:3
Class
Entries
abg-utils/src/main/java/rpc/abg/util/FastMap.java:790
Class
Entry
abg-utils/src/main/java/rpc/abg/util/FastMap.java:737
Class
EventLoopGroupHolder
jvm实例共享EventLoopGroup @author Annabergite
abg-cloud/src/main/java/rpc/abg/common/EventLoopGroupHolder.java:18
Class
ExceptionBenchmark
abg-jmh/src/main/java/rpc/abg/benchmark/exception/ExceptionBenchmark.java:18
Class
FailoverInvokerFactory
客户端失败回退Invoker工厂类 @author Annabergite
abg-cloud/src/main/java/rpc/abg/invoke/FailoverInvokerFactory.java:27
Class
FastClassResolver
Base on kryo DefaultClassResolver. Resolves classes by ID or by fully qualified class name. @author Nathan Sweet
abg-kryo/src/main/java/rpc/abg/serialization/kryo/FastClassResolver.java:48
Class
FastClearableArrayList
ArrayList 的简化版,可快速 clear,非通用仅适用于特定场景 @author Annabergite @param <E>
abg-utils/src/main/java/rpc/abg/util/FastClearableArrayList.java:18
Class
FastClock
abg-utils/src/main/java/rpc/abg/util/SystemClock.java:109
Class
FastClockCacheLine0
abg-utils/src/main/java/rpc/abg/util/SystemClock.java:88
Class
FastClockCacheLine1
abg-utils/src/main/java/rpc/abg/util/SystemClock.java:97
Class
FastClockCacheLine2
abg-utils/src/main/java/rpc/abg/util/SystemClock.java:105
Class
FastClockMills
abg-utils/src/main/java/rpc/abg/util/SystemClock.java:93
Class
FastClockSeconds
abg-utils/src/main/java/rpc/abg/util/SystemClock.java:101
Class
FastIdStrategy
The FQCN(fully qualified class name) will serve as the id (string). Does not need any registration in the user-code (works out-of-the-box). The size o
abg-protostuff/src/main/java/io/protostuff/runtime/FastIdStrategy.java:40
Class
FastMap
Copy from kryo ObjectMap. An unordered map. This implementation is a cuckoo hash map using 3 hashes (if table size is less than 2^16) or 4 hashes (if
abg-utils/src/main/java/rpc/abg/util/FastMap.java:41
Class
FastSerializer
基于 Javassist 实现的 Serializer @author Annabergite @param <T>
abg-kryo/src/main/java/rpc/abg/serialization/kryo/FastSerializer.java:40
Class
FastSerializerBenchmark
abg-jmh/src/main/java/rpc/abg/benchmark/kryo/FastSerializerBenchmark.java:36
Class
ForeverRetryPolicy
abg-register-zk/src/main/java/rpc/abg/zk/common/ForeverRetryPolicy.java:10
Class
FutureBenchmark
@author Annabergite
abg-jmh/src/main/java/rpc/abg/benchmark/future/FutureBenchmark.java:24
Class
FutureContainer
@author Annabergite
abg-cloud/src/main/java/rpc/abg/transport/client/future/FutureContainer.java:20
Class
FutureHolderBenchmark
@author Annabergite
abg-jmh/src/main/java/rpc/abg/benchmark/future/FutureHolderBenchmark.java:25
Class
FutureUtils
abg-utils/src/main/java/rpc/abg/util/concurrent/FutureUtils.java:6
Class
FutureWithExpire
abg-jmh/src/main/java/rpc/abg/benchmark/future/FutureWithExpire.java:5
Class
HelloBootTest
abg-jmh/src/main/java/rpc/abg/benchmark/client/HelloBootTest.java:15
Class
HelloReferTest
abg-jmh/src/main/java/rpc/abg/benchmark/client/HelloReferTest.java:8
Interface
HelloService
abg-jmh/src/main/java/rpc/abg/benchmark/service/HelloService.java:7
Class
HelloServiceImpl
abg-jmh/src/main/java/rpc/abg/benchmark/service/HelloServiceImpl.java:7
Class
HexBenchmark
@author Annabergite
abg-jmh/src/main/java/rpc/abg/benchmark/hex/HexBenchmark.java:26
Class
HexBenchmark2
@author Annabergite
abg-jmh/src/main/java/rpc/abg/benchmark/hex/HexBenchmark2.java:23
Class
HexUtils
高性能,空间换时间 @author Annabergite
abg-utils/src/main/java/rpc/abg/util/HexUtils.java:18
Class
Holder
abg-jmh/src/main/java/rpc/abg/benchmark/threadlocal/ThreadLocalBenchmark.java:221
Class
HostPort
abg-cloud/src/main/java/rpc/abg/config/HostPort.java:5
Class
HttpClientUtils
abg-jmh/src/main/java/rpc/abg/benchmark/service/HttpClientUtils.java:16
Class
HttpParamExtractBenchmark
abg-jmh/src/main/java/rpc/abg/benchmark/httpparam/HttpParamExtractBenchmark.java:23
Class
HttpParamExtractor
abg-cloud/src/main/java/rpc/abg/param/HttpParamExtractor.java:13
Class
IPUtils
abg-utils/src/main/java/rpc/abg/util/IPUtils.java:3
Class
IPUtilsBenchmark
abg-jmh/src/main/java/rpc/abg/benchmark/ip/IPUtilsBenchmark.java:18
Class
IdentityHashMapBenchmark
abg-jmh/src/main/java/rpc/abg/benchmark/map/IdentityHashMapBenchmark.java:24
Class
IntArrayObj
abg-jmh/src/main/java/rpc/abg/benchmark/kryo/KryoByteBufTest.java:94
Class
IntLongNameLongNameLongNameLongNameLongNameLongNameLongNameLongNameLongNameLongNameLongNameLongNameLongNameLongNameLongNameLongNameLongNameLongNameLongNameLongNameLongNameLongNameLongNameLongNameObj
abg-jmh/src/main/java/rpc/abg/benchmark/kryo/KryoByteBufTest.java:78
Class
IntObj
abg-jmh/src/main/java/rpc/abg/benchmark/kryo/KryoByteBufTest.java:18
Class
IntToObjectArrayMap
高性能,仅适用于key值比较少的情况,不能超过512k个 @author Annabergite
abg-utils/src/main/java/rpc/abg/util/IntToObjectArrayMap.java:14
Class
IntegerSerializer
abg-jmh/src/main/java/rpc/abg/benchmark/serialization/manual/IntegerSerializer.java:5
Interface
IntegerService
abg-jmh/src/main/java/rpc/abg/benchmark/invoke/IntegerService.java:3
Class
IntegerServiceImpl
abg-jmh/src/main/java/rpc/abg/benchmark/invoke/IntegerServiceImpl.java:3
Class
InvokeException
abg-cloud/src/main/java/rpc/abg/invoke/InvokeException.java:3
next →
1–100 of 287, ranked by callers