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
↓ 186 callers
Method
unsafe
()
abg-utils/src/main/java/rpc/abg/util/UnsafeUtils.java:22
↓ 172 callers
Method
getName
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:32
↓ 122 callers
Method
put
Returns the old value associated with the specified key, or null.
abg-utils/src/main/java/rpc/abg/util/FastMap.java:115
↓ 103 callers
Method
byteToHexLE
(byte b)
abg-utils/src/main/java/rpc/abg/util/HexUtils.java:77
↓ 68 callers
Method
register
注册服务 @param group @param app @param protocol @param serverAddress @param serverWeight 0-100
abg-cloud/src/main/java/rpc/abg/registry/Register.java:34
↓ 56 callers
Method
equals
(Object obj)
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId.java:127
↓ 56 callers
Method
info
Logs a message with info log level. @param message log this message
abg-jcl/src/main/java/org/apache/commons/logging/Log.java:161
↓ 55 callers
Method
get
某个位置的值 @param index @return
abg-jmh/src/main/java/rpc/abg/benchmark/concurrent/AtomicMuiltInteger2.java:84
↓ 55 callers
Method
isInfoEnabled
Is info logging currently enabled? <p>Call this method to prevent having to perform expensive operations (for example, <code>String</code> concatenati
abg-jcl/src/main/java/org/apache/commons/logging/Log.java:97
↓ 54 callers
Method
get
根据种子获取一个元素, 配合 {@link #sum()}使用<br> <pre> int seed = rendom.nextInt(sum()); T t = get(seed); </pre> @param seed @return
abg-cloud/src/main/java/rpc/abg/loadbalance/WeightableGroup.java:119
↓ 52 callers
Method
clear
()
abg-jmh/src/main/java/rpc/abg/benchmark/pool/ConcurrentObjectPool3.java:190
↓ 45 callers
Method
get
(K key)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:379
↓ 43 callers
Method
setBuffer
Sets a new byteBuf, discarding any previous byteBuf. The byte order, position, limit and capacity are set to match the specified byteBuf. The total is
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:27
↓ 43 callers
Method
writeInt
Writes a 4 byte int.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:179
↓ 42 callers
Method
readByte
Reads a single byte.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:147
↓ 40 callers
Method
writeByte
(byte value)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:154
↓ 38 callers
Method
invoke
(Object... params)
abg-cloud/src/main/java/rpc/abg/invoke/Invoker.java:9
↓ 38 callers
Method
size
()
abg-utils/src/main/java/rpc/abg/util/FastClearableArrayList.java:73
↓ 37 callers
Method
isWarnEnabled
Is warn logging currently enabled? <p>Call this method to prevent having to perform expensive operations (for example, <code>String</code> concatenati
abg-jcl/src/main/java/org/apache/commons/logging/Log.java:88
↓ 35 callers
Method
isErrorEnabled
Is error logging currently enabled? <p>Call this method to prevent having to perform expensive operations (for example, <code>String</code> concatenat
abg-jcl/src/main/java/org/apache/commons/logging/Log.java:79
↓ 35 callers
Method
warn
Logs a message with warn log level. @param message log this message
abg-jcl/src/main/java/org/apache/commons/logging/Log.java:148
↓ 33 callers
Method
error
Logs a message with error log level. @param message log this message
abg-jcl/src/main/java/org/apache/commons/logging/Log.java:135
↓ 33 callers
Method
writeVarInt
(ByteBuf byteBuf, int value)
abg-utils/src/main/java/rpc/abg/util/ByteBufUtils.java:7
↓ 28 callers
Method
current
()
abg-utils/src/main/java/rpc/abg/util/concurrent/ThreadLocalBytes.java:15
↓ 27 callers
Method
log
(Level level, Object message, Throwable exception)
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:297
↓ 26 callers
Method
getLog
Convenience method to return a named logger. @param clazz containing Class from which a log name will be derived
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:98
↓ 24 callers
Method
readObject
(ByteBuf buf, Class<T> clazz)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/KryoContext.java:134
↓ 23 callers
Method
getBytes
()
abg-jmh/src/main/java/rpc/abg/benchmark/string/StringTest.java:48
↓ 23 callers
Method
toString
()
abg-cloud/src/main/java/rpc/abg/trace/Tracer.java:102
↓ 22 callers
Method
add
(E e)
abg-utils/src/main/java/rpc/abg/util/FastClearableArrayList.java:49
↓ 22 callers
Method
writeObject
(final int fieldNumber, final T value, final Schema<T> schema, final boolean repeated)
abg-protostuff/src/main/java/io/protostuff/ByteBufOutput.java:206
↓ 20 callers
Method
write
写入对象 @param buffer @param value
abg-cloud/src/main/java/rpc/abg/serialization/JsonMapper.java:24
↓ 19 callers
Method
getOrUpdate
(int key, Supplier<T> producer)
abg-utils/src/main/java/rpc/abg/util/IntToObjectArrayMap.java:85
↓ 19 callers
Method
getServiceMethodName
@param group 不能包含# / @param app 不能包含# / @param method 不能为空 @return
abg-cloud/src/main/java/rpc/abg/invoke/InvokerUtils.java:51
↓ 19 callers
Method
getUser
(long id)
abg-jmh/src/main/java/rpc/abg/benchmark/service/UserService.java:32
↓ 19 callers
Method
isEmpty
()
abg-utils/src/main/java/rpc/abg/util/FastClearableArrayList.java:78
↓ 18 callers
Method
getId
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:24
↓ 18 callers
Method
indexOf
(Object o)
abg-utils/src/main/java/rpc/abg/util/FastClearableArrayList.java:143
↓ 18 callers
Method
offset
(int index)
abg-utils/src/main/java/rpc/abg/util/concurrent/AtomicMuiltInteger.java:127
↓ 18 callers
Method
write
(ByteBuf byteBuf, T object)
abg-jmh/src/main/java/rpc/abg/benchmark/serialization/manual/Serializer.java:7
↓ 17 callers
Method
readInt
()
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:179
↓ 16 callers
Method
read
(ByteBuf byteBuf)
abg-jmh/src/main/java/rpc/abg/benchmark/serialization/manual/Serializer.java:9
↓ 16 callers
Method
resize
(int newSize)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:646
↓ 15 callers
Method
currentTimeMillis
()
abg-jmh/src/main/java/rpc/abg/benchmark/uuid/UUIDBenchmark.java:50
↓ 15 callers
Method
fast
很快,但不是那么靠谱,要求高精度的地方不能用 @return
abg-utils/src/main/java/rpc/abg/util/SystemClock.java:30
↓ 15 callers
Method
getRequestId
()
abg-cloud/src/main/java/rpc/abg/protocol/Request.java:25
↓ 15 callers
Method
readRawVarint32
Reads a var int 32 from the internal byte buffer.
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:526
↓ 14 callers
Method
checkIfPackedField
Check if this field have been packed into a length-delimited field. If so, update internal state to reflect that packed fields are being read. @throw
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:231
↓ 14 callers
Method
get
@param index 通过 {@link #nextVarIndex()} 获得 @return
abg-utils/src/main/java/rpc/abg/util/concurrent/AttachmentThreadUtils.java:126
↓ 13 callers
Method
add
(RequestWithFuture requestWithFuture)
abg-cloud/src/main/java/rpc/abg/transport/client/future/FutureContainer.java:25
↓ 13 callers
Method
containsKey
(K key)
abg-utils/src/main/java/rpc/abg/util/FastMap.java:578
↓ 13 callers
Method
equals
(Object obj)
abg-cloud/src/main/java/rpc/abg/config/HostPort.java:51
↓ 13 callers
Method
map
Used by {@link RuntimeSchema#map(Class, Class)}.
abg-protostuff/src/main/java/io/protostuff/runtime/FastIdStrategy.java:162
↓ 13 callers
Method
newInstance
()
abg-cloud/src/main/java/rpc/abg/protocol/recycle/RecycleRequest.java:20
↓ 13 callers
Method
writeShort
Writes a 2 byte short.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:273
↓ 12 callers
Method
currentThread
()
abg-jmh/src/main/java/rpc/abg/benchmark/threadlocal/ThreadLocalBenchmark.java:200
↓ 12 callers
Method
getParameterTypes
()
abg-cloud/src/main/java/rpc/abg/invoke/Invoker.java:51
↓ 12 callers
Method
listUser
(int pageNo)
abg-jmh/src/main/java/rpc/abg/benchmark/service/UserService.java:35
↓ 12 callers
Method
mills
返回当前毫秒 @return
abg-utils/src/main/java/rpc/abg/util/SystemClock.java:55
↓ 12 callers
Method
nextVarIndex
寻找下一个线程本地变量位置 @return
abg-utils/src/main/java/rpc/abg/util/concurrent/AttachmentThreadUtils.java:31
↓ 12 callers
Method
set
设置某位置的值 @param index @param value
abg-jmh/src/main/java/rpc/abg/benchmark/concurrent/AtomicMuiltInteger2.java:122
↓ 12 callers
Method
toLatin1String
very unsafe @param bytes @return
abg-utils/src/main/java/rpc/abg/util/UnsafeStringUtils.java:148
↓ 11 callers
Method
appendGetFieldValue
(StringBuilder builder, Field field)
abg-kryo/src/main/java/rpc/abg/serialization/kryo/FastSerializer.java:358
↓ 11 callers
Method
getStringOrElse
(Config config, String path, String defaultValue)
abg-cloud/src/main/java/rpc/abg/config/ConfigUtils.java:9
↓ 11 callers
Method
hexToByteLE
(short hex)
abg-utils/src/main/java/rpc/abg/util/HexUtils.java:93
↓ 11 callers
Method
loadClass
(String name)
abg-utils/src/main/java/rpc/abg/util/SingleClassLoader.java:22
↓ 11 callers
Method
writeBytes
(int fieldNumber, ByteString value, boolean repeated)
abg-protostuff/src/main/java/io/protostuff/ByteBufOutput.java:188
↓ 10 callers
Method
addLast
添加过滤器到最后面,最后面的会被最后执行 @param filter
abg-cloud/src/main/java/rpc/abg/client/AbgClient.java:213
↓ 10 callers
Method
fill
Fills the byteBuf with more bytes. Can be overridden to fill the bytes from a source other than the InputStream.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:63
↓ 10 callers
Method
getSchema
()
abg-protostuff/src/main/java/io/protostuff/runtime/FastIdStrategy.java:777
↓ 10 callers
Method
getServiceId
()
abg-cloud/src/main/java/rpc/abg/invoke/Invoker.java:43
↓ 10 callers
Method
getValue
()
abg-jmh/src/main/java/rpc/abg/benchmark/invoke/IntegerService.java:4
↓ 10 callers
Method
indexOf
@param array 不为null,不含null元素 @param value 不为null @return
abg-cloud/src/main/java/rpc/abg/param/HttpParamExtractor.java:265
↓ 10 callers
Method
isDebugEnabled
Is debug logging currently enabled? <p>Call this method to prevent having to perform expensive operations (for example, <code>String</code> concatenat
abg-jcl/src/main/java/org/apache/commons/logging/Log.java:106
↓ 10 callers
Method
log
(java.util.logging.Level level, Object message, Throwable exception)
abg-jcl/src/main/java/org/apache/commons/logging/LogFactory.java:605
↓ 10 callers
Method
release
(Object obj)
abg-cloud/src/main/java/rpc/abg/recycle/RecycleUtils.java:5
↓ 10 callers
Method
remove
(int requestId)
abg-cloud/src/main/java/rpc/abg/transport/client/future/FutureContainer.java:33
↓ 10 callers
Method
start
()
abg-cloud/src/main/java/rpc/abg/transport/server/rpc/NettyRpcServer.java:43
↓ 10 callers
Method
toHexString
96位编码, 长度为24 @return
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId.java:148
↓ 10 callers
Method
trace
Logs a message with trace log level. @param message log this message
abg-jcl/src/main/java/org/apache/commons/logging/Log.java:187
↓ 10 callers
Method
writeBool
(int fieldNumber, boolean value, boolean repeated)
abg-protostuff/src/main/java/io/protostuff/ByteBufOutput.java:113
↓ 9 callers
Method
clear
()
abg-cloud/src/main/java/rpc/abg/transport/client/ConnectorContext.java:515
↓ 9 callers
Method
getSchemaWrapper
(String className, boolean load)
abg-protostuff/src/main/java/io/protostuff/runtime/FastIdStrategy.java:199
↓ 9 callers
Method
hashCode
()
abg-utils/src/main/java/rpc/abg/util/uuid/ObjectId.java:118
↓ 9 callers
Method
read
读取对象 @param buffer @param type @return
abg-cloud/src/main/java/rpc/abg/serialization/JsonMapper.java:16
↓ 9 callers
Method
readLong
Reads an 8 byte long.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufInput.java:293
↓ 9 callers
Method
readString
()
abg-protostuff/src/main/java/io/protostuff/ByteBufInput.java:374
↓ 9 callers
Method
setRemoteMethod
(Method remoteMethod)
abg-cloud/src/main/java/rpc/abg/common/RemoteContext.java:56
↓ 9 callers
Method
setServiceMethodName
(String serviceMethodName)
abg-cloud/src/main/java/rpc/abg/common/RemoteContext.java:69
↓ 9 callers
Method
toHex
high performance @param bytes @return
abg-utils/src/main/java/rpc/abg/util/HexUtils.java:135
↓ 9 callers
Method
toString
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:120
↓ 9 callers
Method
toString
()
abg-cloud/src/main/java/rpc/abg/protocol/Request.java:57
↓ 9 callers
Method
writeLong
Writes an 8 byte long.
abg-kryo/src/main/java/rpc/abg/serialization/kryo/ByteBufOutput.java:280
↓ 9 callers
Method
writeVarLong
(ByteBuf byteBuf, long value)
abg-utils/src/main/java/rpc/abg/util/ByteBufUtils.java:158
↓ 8 callers
Method
equals
(Object obj)
abg-cloud/src/main/java/rpc/abg/invoke/ReflectInvoker.java:93
↓ 8 callers
Method
execute
仅用于测试,不要用于正式使用 @param method @param timeout 超时时间,millseconds @param methodParam @return
abg-cloud/src/main/java/rpc/abg/transport/client/App.java:415
↓ 8 callers
Method
getAddress
()
abg-jmh/src/main/java/rpc/abg/benchmark/bean/User.java:72
↓ 8 callers
Method
getOrUpdate
@param index 通过 {@link #nextVarIndex()} 获得 @param producer 尽量使用final常量以获得更好的性能 @return
abg-utils/src/main/java/rpc/abg/util/concurrent/AttachmentThreadUtils.java:45
↓ 8 callers
Method
getServerAddress
获取当前远程调用的服务端地址 @return
abg-cloud/src/main/java/rpc/abg/common/RemoteContext.java:39
↓ 8 callers
Method
getService
获取一个远程服务,必须先注册 :<br> {@link #register(Class)} or {@link #register(String, String, Class, Object)} @param clazz @return
abg-cloud/src/main/java/rpc/abg/client/AbgClient.java:195
next →
1–100 of 1,654, ranked by callers