Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/dingwpmz/netty-learning
/ functions
Functions
316 in github.com/dingwpmz/netty-learning
⨍
Functions
316
◇
Types & classes
63
↓ 1 callers
Method
getServerChannelMaxIdleTimeSeconds
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:89
↓ 1 callers
Method
getServerOnewaySemaphoreValue
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:65
↓ 1 callers
Method
getServerSocketRcvBufSize
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:105
↓ 1 callers
Method
getServerSocketSndBufSize
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:97
↓ 1 callers
Method
getServerWorkerThreads
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:49
↓ 1 callers
Method
getTimeoutMillis
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:92
↓ 1 callers
Method
getType
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:76
↓ 1 callers
Method
getType
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyEvent.java:32
↓ 1 callers
Method
initNettyLogger
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyLogger.java:34
↓ 1 callers
Method
initValueIndex
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:133
↓ 1 callers
Method
isClientCloseSocketIfTimeout
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:43
↓ 1 callers
Method
isSendRequestOK
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:84
↓ 1 callers
Method
isServerPooledByteBufAllocatorEnable
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:113
↓ 1 callers
Method
isStopped
()
netty-framework/src/main/java/com/prestigeding/remoting/common/ServiceThread.java:78
↓ 1 callers
Method
isUseEpollNativeSelector
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:121
↓ 1 callers
Method
loadSslContext
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:157
↓ 1 callers
Method
logTheFinalUsedTlsConfig
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/TlsHelper.java:198
↓ 1 callers
Method
markOnewayRPC
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:57
↓ 1 callers
Method
name
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyLogger.java:60
↓ 1 callers
Method
onChannelClose
(final String remoteAddr, final Channel channel)
netty-framework/src/main/java/com/prestigeding/remoting/ChannelEventListener.java:24
↓ 1 callers
Method
onChannelConnect
(final String remoteAddr, final Channel channel)
netty-framework/src/main/java/com/prestigeding/remoting/ChannelEventListener.java:22
↓ 1 callers
Method
onChannelException
(final String remoteAddr, final Channel channel)
netty-framework/src/main/java/com/prestigeding/remoting/ChannelEventListener.java:26
↓ 1 callers
Method
onChannelIdle
(final String remoteAddr, final Channel channel)
netty-framework/src/main/java/com/prestigeding/remoting/ChannelEventListener.java:28
↓ 1 callers
Method
operationComplete
(final ResponseFuture responseFuture)
netty-framework/src/main/java/com/prestigeding/remoting/InvokeCallback.java:22
↓ 1 callers
Method
parse
(String mode)
netty-framework/src/main/java/com/prestigeding/remoting/common/TlsMode.java:40
↓ 1 callers
Method
parseClientAuthMode
(String authMode)
netty-framework/src/main/java/com/prestigeding/remoting/netty/TlsHelper.java:215
↓ 1 callers
Method
prepareSharableHandlers
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:341
↓ 1 callers
Method
processRequestCommand
Process incoming request command issued by remote peer. @param ctx channel handler context. @param cmd request command.
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:201
↓ 1 callers
Method
processResponseCommand
Process response from remote peer to the previous issued requests. @param ctx channel handler context. @param cmd response command instance.
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:297
↓ 1 callers
Method
rejectRequest
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRequestProcessor.java:29
↓ 1 callers
Method
setBodyByteBuf
(ByteBuf bodyByteBuf)
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:162
↓ 1 callers
Method
setCause
(Throwable cause)
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:104
↓ 1 callers
Method
setCode
(int code)
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:72
↓ 1 callers
Method
setRemark
(String remark)
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:128
↓ 1 callers
Method
setResponseCommand
(RemotingCommand responseCommand)
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:112
↓ 1 callers
Method
string2SocketAddress
(final String addr)
netty-framework/src/main/java/com/prestigeding/remoting/common/RemotingHelper.java:48
↓ 1 callers
Method
waitResponse
(final long timeoutMillis)
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:70
Method
ChannelWrapper
(ChannelFuture channelFuture)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:551
Method
Handler
(SocketChannel sc, ByteBuffer reqBuffer, SubReactorThread parent)
reactor-nio/src/main/java/com/prestigeding/nio/reactor/Handler.java:15
Method
HandshakeHandler
(TlsMode tlsMode)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:354
Method
LanguageCode
(byte code)
netty-framework/src/main/java/com/prestigeding/remoting/protocol/LanguageCode.java:36
Method
MainReactor
(ServerSocketChannel channel)
reactor-nio/src/main/java/com/prestigeding/nio/reactor/MainReactor.java:13
Method
NettyBridgeLogger
(String name)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyLogger.java:56
Method
NettyDecoder
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyDecoder.java:34
Method
NettyEvent
(NettyEventType type, String remoteAddr, Channel channel)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyEvent.java:26
Method
NettyRemotingAbstract
Constructor, specifying capacity of one-way and asynchronous semaphores. @param permitsOneway Number of permits for one-way requests. @param permitsA
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:117
Method
NettyRemotingClient
(final NettyClientConfig nettyClientConfig)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:87
Method
NettyRemotingServer
(final NettyServerConfig nettyServerConfig)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:89
Method
NioTask
(SocketChannel sc, int op)
reactor-nio/src/main/java/com/prestigeding/nio/reactor/NioTask.java:11
Method
Pair
(T1 object1, T2 object2)
netty-framework/src/main/java/com/prestigeding/remoting/common/Pair.java:23
Method
RemotingCommand
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:41
Method
RemotingCommandException
(String message)
netty-framework/src/main/java/com/prestigeding/remoting/exception/RemotingCommandException.java:22
Method
RemotingConnectException
(String addr)
netty-framework/src/main/java/com/prestigeding/remoting/exception/RemotingConnectException.java:22
Method
RemotingException
(String message)
netty-framework/src/main/java/com/prestigeding/remoting/exception/RemotingException.java:22
Method
RemotingSendRequestException
(String addr)
netty-framework/src/main/java/com/prestigeding/remoting/exception/RemotingSendRequestException.java:22
Method
RemotingTimeoutException
(String message)
netty-framework/src/main/java/com/prestigeding/remoting/exception/RemotingTimeoutException.java:23
Method
RemotingTooMuchRequestException
(String message)
netty-framework/src/main/java/com/prestigeding/remoting/exception/RemotingTooMuchRequestException.java:22
Method
RequestTask
(final Runnable runnable, final Channel channel, final RemotingCommand request)
netty-framework/src/main/java/com/prestigeding/remoting/netty/RequestTask.java:30
Method
ResponseFuture
(Channel channel, int opaque, long timeoutMillis, InvokeCallback invokeCallback, SemaphoreReleaseOnlyO
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:42
Method
SemaphoreReleaseOnlyOnce
(Semaphore semaphore)
netty-framework/src/main/java/com/prestigeding/remoting/common/SemaphoreReleaseOnlyOnce.java:26
Method
ServiceThread
()
netty-framework/src/main/java/com/prestigeding/remoting/common/ServiceThread.java:35
Method
SubReactorThread
业务线程池 @param businessExecutorPool
reactor-nio/src/main/java/com/prestigeding/nio/reactor/SubReactorThread.java:24
Method
SubReactorThreadGroup
()
reactor-nio/src/main/java/com/prestigeding/nio/reactor/SubReactorThreadGroup.java:22
Method
TlsMode
(String name)
netty-framework/src/main/java/com/prestigeding/remoting/common/TlsMode.java:36
Method
addExtField
(String key, String value)
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:141
Method
callback
(RemotingCommand response)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:213
Method
channelActive
(ChannelHandlerContext ctx)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:435
Method
channelInactive
(ChannelHandlerContext ctx)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:446
Method
channelRead0
(ChannelHandlerContext ctx, RemotingCommand msg)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:574
Method
channelRead0
(ChannelHandlerContext ctx, ByteBuf msg)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:358
Method
channelRead0
(ChannelHandlerContext ctx, RemotingCommand msg)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:412
Method
channelRegistered
(ChannelHandlerContext ctx)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:421
Method
channelUnregistered
(ChannelHandlerContext ctx)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:428
Method
checkFields
()
netty-framework/src/main/java/com/prestigeding/remoting/CommandCustomHeader.java:22
Method
clone
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyServerConfig.java:129
Method
close
(ChannelHandlerContext ctx, ChannelPromise promise)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:607
Method
decode
(ChannelHandlerContext ctx, ByteBuf in)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyDecoder.java:40
Method
decryptPrivateKey
(final String privateKeyEncryptPath, final boolean forClient)
netty-framework/src/main/java/com/prestigeding/remoting/netty/TlsHelper.java:80
Method
disconnect
(ChannelHandlerContext ctx, ChannelPromise promise)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:595
Method
encode
(ChannelHandlerContext ctx, RemotingCommand cmd, ByteBuf out)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyEncoder.java:37
Method
encode
Encode a message into a {@link io.netty.buffer.ByteBuf}. This method will be called for each written message that can be handled by this encoder. @pa
netty-framework/src/main/java/com/prestigeding/remoting/netty/FileRegionEncoder.java:49
Method
exceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:637
Method
exceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:475
Method
executeInvokeCallback
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/ResponseFuture.java:51
Method
getBodyByteBuf
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:157
Method
getCallbackExecutor
()
netty-framework/src/main/java/com/prestigeding/remoting/RemotingClient.java:48
Method
getCallbackExecutor
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:538
Method
getCallbackExecutor
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:336
Method
getChannelEventListener
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingClient.java:533
Method
getChannelEventListener
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:330
Method
getChannelNotActiveInterval
()
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyClientConfig.java:83
Method
getCode
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:68
Method
getExtFields
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:132
Method
getFlag
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:115
Method
getLanguage
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:91
Method
getLocalAddress
()
netty-framework/src/main/java/com/prestigeding/remoting/common/RemotingUtil.java:94
Method
getOpaque
()
netty-framework/src/main/java/com/prestigeding/remoting/protocol/RemotingCommand.java:107
Method
getProcessorPair
(final int requestCode)
netty-framework/src/main/java/com/prestigeding/remoting/RemotingServer.java:37
Method
getProcessorPair
(int requestCode)
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingServer.java:307
Method
getRPCHook
Custom RPC hook. Just be compatible with the previous version, use getRPCHooks instead.
netty-framework/src/main/java/com/prestigeding/remoting/netty/NettyRemotingAbstract.java:362
← previous
next →
101–200 of 316, ranked by callers