Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/annabergite/abg-rpc
/ functions
Functions
1,654 in github.com/annabergite/abg-rpc
⨍
Functions
1,654
◇
Types & classes
287
↓ 2 callers
Method
ensureSize
(int length)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:67
↓ 2 callers
Method
error
(Object message)
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:359
↓ 2 callers
Method
error
(Object message)
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:444
↓ 2 callers
Method
error
(Object message)
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:565
↓ 2 callers
Method
exchange
(final Object value)
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool2.java:114
↓ 2 callers
Method
execute
远程调用,无参,无失败回退 @param serviceId 远程serviceId @param timeout millseconds @return
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:188
↓ 2 callers
Method
forceCast
(Class<?> clazz)
abg-utils/src/main/java/rpc/abg/util/SourceCodeUtils.java:51
↓ 2 callers
Method
fromHex
high performance @param hex @return
abg-utils/src/main/java/rpc/abg/util/HexUtils.java:252
↓ 2 callers
Method
fromHex2
(String hex)
abg-utils/src/main/java/rpc/abg/util/HexUtils.java:295
↓ 2 callers
Method
get
@param key @return null为找不到
abg-utils/src/main/java/rpc/abg/util/IntToObjectArrayMap.java:65
↓ 2 callers
Method
get
@param key @return null为找不到
abg-utils/src/main/java/rpc/abg/util/concurrent/ConcurrentIntToObjectArrayMap.java:70
↓ 2 callers
Method
get
某个位置的值 @param index @return
abg-utils/src/main/java/rpc/abg/util/concurrent/AtomicMuiltInteger.java:78
↓ 2 callers
Method
getAppConfigList
()
abg-cloud/src/main/java/rpc/abg/config/client/ClientConfig.java:11
↓ 2 callers
Method
getByteBuf
()
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:55
↓ 2 callers
Method
getClassIdMap
获取已注册的 classId @return
abg-cloud/src/main/java/rpc/abg/common/TurboConnectService.java:73
↓ 2 callers
Method
getClientAddress
获取当前远程调用的客户端地址 @return
abg-cloud/src/main/java/rpc/abg/common/RemoteContext.java:26
↓ 2 callers
Method
getConnectErrorThreshold
()
abg-cloud/src/main/java/rpc/abg/config/client/AppConfig.java:90
↓ 2 callers
Method
getCr
()
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:78
↓ 2 callers
Method
getCs
()
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:70
↓ 2 callers
Method
getEpochMinutes
()
abg-utils/src/main/java/rpc/abg/util/uuid/LongId.java:31
↓ 2 callers
Method
getFailoverInvokerFieldName
(App app, Method method)
abg-cloud/src/main/java/rpc/abg/remote/RemoteServiceFactory.java:201
↓ 2 callers
Method
getGetMethod
获取字段的get方法 @param targetClass @param field @return
abg-utils/src/main/java/rpc/abg/util/ReflectUtils.java:20
↓ 2 callers
Method
getMaxRequestWait
()
abg-cloud/src/main/java/rpc/abg/config/client/AppConfig.java:66
↓ 2 callers
Method
getParentId
()
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:54
↓ 2 callers
Method
getPermissions
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:88
↓ 2 callers
Method
getRegistration
(Class<?> type)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/FastSerializer.java:182
↓ 2 callers
Method
getRegistration
(Class type)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/FastClassResolver.java:95
↓ 2 callers
Method
getRemoteMethod
获取当前远程调用的接口方法, 可能为空 @return
abg-cloud/src/main/java/rpc/abg/common/RemoteContext.java:52
↓ 2 callers
Method
getRestPath
获取rest访问路径 @param method 不能为空 @return 当未配置或未正确配置时返回null
abg-cloud/src/main/java/rpc/abg/invoke/InvokerUtils.java:119
↓ 2 callers
Method
getResult
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/Page.java:40
↓ 2 callers
Method
getServerAddress
()
abg-cloud/src/main/java/rpc/abg/config/server/RegisterConfig.java:37
↓ 2 callers
Method
getService
通过服务接口获取远程代理实现类,结果缓存起来使用,不要每次调用 @param clazz 服务接口 @return
abg-cloud/src/main/java/rpc/abg/remote/RemoteServiceFactory.java:69
↓ 2 callers
Method
getServiceMethodName
()
abg-cloud/src/main/java/rpc/abg/transport/client/MethodRouter.java:50
↓ 2 callers
Method
getSetMethod
获取字段的set方法 @param targetClass @param field @return
abg-utils/src/main/java/rpc/abg/util/ReflectUtils.java:67
↓ 2 callers
Method
getSr
()
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:94
↓ 2 callers
Method
getSs
()
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:86
↓ 2 callers
Method
getStatus
()
abg-cloud/src/main/java/rpc/abg/transport/server/rest/protocol/RestHttpResponse.java:44
↓ 2 callers
Method
getValue
(Class<?> clazz)
abg-jmh/src/main/java/rpc/abg/benchmark/map/IdentityHashMapBenchmark.java:68
↓ 2 callers
Method
hasNext
()
abg-utils/src/main/java/rpc/abg/util/FastMap.java:861
↓ 2 callers
Method
hashCode
()
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId128.java:116
↓ 2 callers
Method
initSerializer
()
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:107
↓ 2 callers
Method
ipToLong
@param ip ipv4 only @return 找不到返回-1
abg-utils/src/main/java/rpc/abg/util/IPUtils.java:12
↓ 2 callers
Method
isKeepAlive
()
abg-cloud/src/main/java/rpc/abg/transport/server/rest/protocol/RestHttpResponse.java:60
↓ 2 callers
Method
isSupportedClassId
是否支持classID @return
abg-cloud/src/main/java/rpc/abg/serialization/Serializer.java:84
↓ 2 callers
Method
isZombie
()
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:527
↓ 2 callers
Method
iterator
()
abg-utils/src/main/java/rpc/abg/util/FastMap.java:874
↓ 2 callers
Method
loadServiceId
添加时调用一次就行了 @throws Exception
abg-cloud/src/main/java/rpc/abg/transport/client/App.java:701
↓ 2 callers
Method
next
()
abg-utils/src/main/java/rpc/abg/util/FastMap.java:828
↓ 2 callers
Method
offset
(int key)
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool2.java:153
↓ 2 callers
Method
onChange
当服务发生变化时调用 @param serverWithWeight
abg-cloud/src/main/java/rpc/abg/discover/DiscoverListener.java:14
↓ 2 callers
Method
onSend
客户端发送前执行 @param request 不为空 @return true表示允许发送,false表示不允许发送,不允许发送的情况将执行failover方法
abg-cloud/src/main/java/rpc/abg/filter/RpcClientFilter.java:18
↓ 2 callers
Method
parse
(String resourceName)
abg-cloud/src/main/java/rpc/abg/config/client/ClientConfig.java:24
↓ 2 callers
Method
push
(K insertKey, V insertValue, int index1, K key1, int index2, K key2, int index3, K key3, int index4, K key4
abg-utils/src/main/java/rpc/abg/util/FastMap.java:268
↓ 2 callers
Method
put
存储线程变量 @param index 需要从AttachmentThreadUtils.nextVarIndex()获取到 @param value
abg-utils/src/main/java/rpc/abg/util/concurrent/AttachmentThread.java:48
↓ 2 callers
Method
put_internal
(K key, V value)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:121
↓ 2 callers
Method
readBoolean
Reads a 1 byte boolean.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:346
↓ 2 callers
Method
readByKryo
()
abg-jmh/src/main/java/rpc/abg/benchmark/serialization/TracerSerializerBenchmark.java:114
↓ 2 callers
Method
readByteArray
()
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:461
↓ 2 callers
Method
readShort
Reads a 2 byte short.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:283
↓ 2 callers
Method
readStringFast
()
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:209
↓ 2 callers
Method
register
注册invoker @param service 实现类实例,重复调用时不会覆盖,会一直使用首次注册的实例 @param clazz 服务接口
abg-cloud/src/main/java/rpc/abg/invoke/ServerInvokerFactory.java:127
↓ 2 callers
Method
registerPojoID
(Map<String, Integer> pojoIDMap)
abg-protostuff/src/main/java/io/protostuff/runtime/FastIdStrategy.java:95
↓ 2 callers
Method
registerService
手动注册一个服务 @param map
abg-cloud/src/main/java/rpc/abg/server/TurboServer.java:209
↓ 2 callers
Method
release
释放eventLoopGroup,内部使用引用计数,当计数为0时实际关闭 @param eventLoopGroup
abg-cloud/src/main/java/rpc/abg/common/EventLoopGroupHolder.java:57
↓ 2 callers
Method
remove
(K key)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:441
↓ 2 callers
Method
remove
(int requestId)
abg-jmh/src/main/java/rpc/abg/benchmark/future/ResponseFutureContainer2.java:43
↓ 2 callers
Method
removeStashIndex
(int index)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:497
↓ 2 callers
Method
resolve
()
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:667
↓ 2 callers
Method
resolveClass
(String className)
abg-protostuff/src/main/java/io/protostuff/runtime/FastIdStrategy.java:673
↓ 2 callers
Method
schema
客户端或者服务端获取ProtostuffSchema,该方法速度慢 @param clazz @return
abg-protostuff/src/main/java/rpc/abg/serialization/protostuff/ProtostuffSerializer.java:192
↓ 2 callers
Method
serializer
(int id)
abg-jmh/src/main/java/rpc/abg/benchmark/serialization/manual/Register.java:33
↓ 2 callers
Method
setApp
(String app)
abg-cloud/src/main/java/rpc/abg/config/client/AppConfig.java:46
↓ 2 callers
Method
setBuffer
Sets the buffer that will be written to. maxCapacity is set to the specified buffer's capacity. @see #setBuffer(ByteBuf, int)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:44
↓ 2 callers
Method
setByteBuf
(ByteBuf buffer)
abg-protostuff/src/main/java/io/protostuff/ByteBufOutput.java:29
↓ 2 callers
Method
setByteBuf
(ByteBuf buffer, boolean protostuffMessage)
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:59
↓ 2 callers
Method
setClassIds
设置classID @param classIds
abg-cloud/src/main/java/rpc/abg/serialization/Serializer.java:93
↓ 2 callers
Method
setConnect
建立连接 @param serverAddresss @throws Exception
abg-cloud/src/main/java/rpc/abg/transport/client/App.java:122
↓ 2 callers
Method
setCr
(long cr)
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:82
↓ 2 callers
Method
setCs
(long cs)
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:74
↓ 2 callers
Method
setGroup
(String group)
abg-cloud/src/main/java/rpc/abg/config/client/AppConfig.java:38
↓ 2 callers
Method
setPageNo
(int pageNo)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/Page.java:28
↓ 2 callers
Method
setRequest
(Request request)
abg-cloud/src/main/java/rpc/abg/transport/client/future/RequestWithFuture.java:23
↓ 2 callers
Method
setServiceMethodNameToServiceIdMap
(Map<String, Integer> serviceMethodNameToServiceIdMap)
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:519
↓ 2 callers
Method
setSourceClassName
(String sourceClassName)
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:647
↓ 2 callers
Method
setSourceMethodName
(String sourceMethodName)
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:661
↓ 2 callers
Method
setSr
(long sr)
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:98
↓ 2 callers
Method
setSs
(long ss)
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:90
↓ 2 callers
Method
setTotal
(int total)
abg-jmh/src/main/java/rpc/abg/benchmark/bean/Page.java:36
↓ 2 callers
Method
skipField
Reads and discards a single field, given its tag value. @return {@code false} if the tag is an endgroup tag, in which case nothing is skipped
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:140
↓ 2 callers
Method
startRestServer
(HostPort hostPort)
abg-cloud/src/main/java/rpc/abg/server/TurboServer.java:182
↓ 2 callers
Method
startRpcServer
(HostPort hostPort)
abg-cloud/src/main/java/rpc/abg/server/TurboServer.java:155
↓ 2 callers
Method
sum
所有位置的和 @return
abg-utils/src/main/java/rpc/abg/util/concurrent/AtomicMuiltInteger.java:88
↓ 2 callers
Method
sum
所有位置的和 @return
abg-jmh/src/main/java/rpc/abg/benchmark/concurrent/AtomicMuiltInteger1.java:85
↓ 2 callers
Method
sum
获取weight之和,配合{@link #get(int)}使用<br> <pre> int seed = rendom.nextInt(sum()); T t = get(seed); </pre> @return
abg-cloud/src/main/java/rpc/abg/loadbalance/WeightableGroup.java:104
↓ 2 callers
Method
supportCast
(Class<?> clazz)
abg-utils/src/main/java/rpc/abg/util/TypeUtils.java:19
↓ 2 callers
Method
supportHttpForm
()
abg-cloud/src/main/java/rpc/abg/invoke/Invoker.java:63
↓ 2 callers
Method
test
()
abg-jmh/src/main/java/rpc/abg/benchmark/client/TruboClientBootTest.java:30
↓ 2 callers
Method
toClass
(String serviceClassName)
abg-cloud/src/main/java/rpc/abg/invoke/InvokerUtils.java:170
↓ 2 callers
Method
toHex2
略慢 @param bytes @return
abg-utils/src/main/java/rpc/abg/util/HexUtils.java:111
↓ 2 callers
Method
toHexString
128位编码, 长度为32 @return
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId128.java:146
← previous
next →
301–400 of 1,654, ranked by callers