MCPcopy Create free account

hub / github.com/BBLLMYD/netty-stroll / functions

Functions155 in github.com/BBLLMYD/netty-stroll

⨍ Functions 155◇ Types & classes 85
↓ 13 callersMethodnewInstance
(String fileName)
signal-base/src/main/java/com/skr/signal/common/util/PropertiesUtil.java:18
↓ 9 callersMethodreadProperty
(String key)
signal-base/src/main/java/com/skr/signal/common/util/PropertiesUtil.java:22
↓ 7 callersMethoderror
(Integer code, String message)
signal-front/src/main/java/com/skr/signal/front/dto/Resp.java:33
↓ 6 callersMethodput
(String requestId, CompletableFuture<RpcResponse> future)
signal-base/src/main/java/com/skr/signal/base/rpc/client/AsyncResultContainer.java:13
↓ 5 callersMethodcreate
(Class<T> interfaceClass)
signal-base/src/main/java/com/skr/signal/base/rpc/client/proxy/RpcClient.java:28
↓ 4 callersMethodconnect
(int port, String host)
signal-base/src/main/java/com/skr/signal/base/heartbeat/demo/HeartBeatsClient.java:28
↓ 4 callersMethodgetClassName
(String packageName, String fileName)
signal-base/src/main/java/com/skr/signal/common/util/ClassUtil.java:122
↓ 4 callersMethodrun
()
signal-base/src/main/java/com/skr/signal/base/rpc/server/RpcServer.java:53
↓ 4 callersMethodstart
()
signal-base/src/main/java/com/skr/signal/base/rpc/server/RpcServer.java:91
↓ 3 callersMethodgetInstance
()
signal-base/src/main/java/com/skr/signal/base/rpc/client/proxy/RpcClient.java:46
↓ 3 callersMethodremove
(InetSocketAddress inetSocketAddress)
signal-base/src/main/java/com/skr/signal/base/rpc/client/ChannelManager.java:41
↓ 2 callersMethodbuildResponse
(String content)
signal-front/src/main/java/com/skr/signal/front/async/AsyncHandleUnit.java:51
↓ 2 callersMethodcomplete
(RpcResponse rpcResponse)
signal-base/src/main/java/com/skr/signal/base/rpc/client/AsyncResultContainer.java:17
↓ 2 callersMethodgetChannel
(InetSocketAddress inetSocketAddress)
signal-base/src/main/java/com/skr/signal/base/rpc/client/ChannelManager.java:21
↓ 2 callersMethodgetClassFiles
(String packagePath)
signal-base/src/main/java/com/skr/signal/common/util/ClassUtil.java:113
↓ 2 callersMethodgetClassList
(String packageName, boolean isRecursive)
signal-base/src/main/java/com/skr/signal/common/util/ClassUtil.java:21
↓ 2 callersMethodgetInstance
()
signal-base/src/main/java/com/skr/signal/base/rpc/client/RpcNettyClient.java:79
↓ 2 callersMethodgetSchema
(Class<T> cls)
signal-base/src/main/java/com/skr/signal/base/rpc/letter/serialize/impl/ProtoStuffSerializer.java:20
↓ 2 callersMethodgetSingleInstance
()
signal-base/src/main/java/com/skr/signal/base/rpc/letter/serialize/SerializableFactory.java:15
↓ 2 callersMethodgetSubPackageName
(String packageName, String filePath)
signal-base/src/main/java/com/skr/signal/common/util/ClassUtil.java:140
↓ 2 callersMethodgetSubPackagePath
(String packagePath, String filePath)
signal-base/src/main/java/com/skr/signal/common/util/ClassUtil.java:132
↓ 2 callersMethodinitZkClient
(String address)
signal-base/src/main/java/com/skr/signal/base/registry/impl/zookeeper/CuratorUtils.java:71
↓ 2 callersMethodregistryAddress
(String registryAddress)
signal-base/src/main/java/com/skr/signal/base/registry/ServiceRegistry.java:11
↓ 1 callersMethodaddClass
(List<Class<?>> classList, String packagePath, String packageName, boolean isRecursive)
signal-base/src/main/java/com/skr/signal/common/util/ClassUtil.java:91
↓ 1 callersMethodaddClassByAnnotation
(List<Class<?>> classList, String packagePath, String packageName, Class<? extends Annotation> annotationClass
signal-base/src/main/java/com/skr/signal/common/util/ClassUtil.java:148
↓ 1 callersMethodasyncResponse
(AsyncHandleUnit asyncHandleUnit)
signal-front/src/main/java/com/skr/signal/front/async/AsyncResponseManager.java:25
↓ 1 callersMethodbuildResponseTypeData
(Request request)
signal-front/src/main/java/com/skr/signal/front/handler/Handler.java:36
↓ 1 callersMethodcheckPrefix
(String prefix)
signal-front/src/main/java/com/skr/signal/front/initialize/NamedThreadFactory.java:24
↓ 1 callersMethodcompute
(String args)
signal-base/src/main/java/com/skr/signal/common/service/ComputeService.java:9
↓ 1 callersMethodcreatePersistentNode
(String path)
signal-base/src/main/java/com/skr/signal/base/registry/impl/zookeeper/CuratorUtils.java:27
↓ 1 callersMethodcreateProxy
(Class<T> interfaceClass)
signal-base/src/main/java/com/skr/signal/base/rpc/client/RpcNettyClient.java:131
↓ 1 callersMethoddata
(String args)
signal-base/src/main/java/com/skr/signal/common/service/DataService.java:9
↓ 1 callersMethoddeSerializable
()
signal-front/src/main/java/com/skr/signal/front/handler/Handler.java:20
↓ 1 callersMethoddeserialize
(byte[] data, Class<T> cls)
signal-base/src/main/java/com/skr/signal/base/rpc/letter/serialize/SignalSerializable.java:11
↓ 1 callersMethoddiscover
(String serviceName)
signal-base/src/main/java/com/skr/signal/base/registry/ServiceDiscover.java:9
↓ 1 callersMethoddoConnect
(InetSocketAddress inetSocketAddress)
signal-base/src/main/java/com/skr/signal/base/rpc/client/RpcNettyClient.java:83
↓ 1 callersMethodfilterServices
(List<String> services)
signal-base/src/main/java/com/skr/signal/base/registry/LoadPolicy.java:14
↓ 1 callersMethodgetAnswer
(String json)
signal-front/src/main/java/com/skr/signal/front/handler/Handler.java:29
↓ 1 callersMethodgetChildrenNodes
(String serviceName)
signal-base/src/main/java/com/skr/signal/base/registry/impl/zookeeper/CuratorUtils.java:42
↓ 1 callersMethodgetHandler
(String url)
signal-front/src/main/java/com/skr/signal/front/initialize/HandlerInitializer.java:51
↓ 1 callersMethodgetProperties
()
signal-base/src/main/java/com/skr/signal/common/util/PropertiesUtil.java:43
↓ 1 callersMethodgetRequestTypeData
(String json)
signal-front/src/main/java/com/skr/signal/front/handler/Handler.java:46
↓ 1 callersMethodhandle
(Request request)
signal-front/src/main/java/com/skr/signal/front/handler/Handler.java:18
↓ 1 callersMethodhandle
(RpcRequest request)
signal-base/src/main/java/com/skr/signal/base/rpc/server/RpcHandler.java:45
↓ 1 callersMethodhandlers
()
signal-base/src/main/java/com/skr/signal/base/heartbeat/demo/HeartBeatsClient.java:36
↓ 1 callersMethodhandlers
()
signal-base/src/main/java/com/skr/signal/base/heartbeat/demo/ConnectionWatcher.java:90
↓ 1 callersMethodhandshakeFuture
()
signal-route/src/main/java/com/skr/signal/route/websocket/WebSocketClientHandler.java:38
↓ 1 callersMethodinit
()
signal-front/src/main/java/com/skr/signal/front/initialize/HandlerInitializer.java:30
↓ 1 callersMethodinvoke
(Object proxy, Method method, Object[] args)
signal-base/src/main/java/com/skr/signal/base/rpc/client/proxy/RpcClient.java:51
↓ 1 callersMethodloadPolicy
(LoadPolicy loadPolicy)
signal-base/src/main/java/com/skr/signal/base/registry/ServiceDiscover.java:11
↓ 1 callersMethodregister
(String service, String address)
signal-base/src/main/java/com/skr/signal/base/registry/ServiceRegistry.java:9
↓ 1 callersMethodregisterWatcher
(CuratorFramework zkClient, String serviceName)
signal-base/src/main/java/com/skr/signal/base/registry/impl/zookeeper/CuratorUtils.java:85
↓ 1 callersMethodroute
(String args)
signal-base/src/main/java/com/skr/signal/common/service/RouteService.java:12
↓ 1 callersMethodrun
()
signal-front/src/main/java/com/skr/signal/front/initialize/HttpServer.java:21
↓ 1 callersMethodsendRpcRequest
(RpcRequest rpcRequest)
signal-base/src/main/java/com/skr/signal/base/rpc/client/RpcNettyClient.java:97
↓ 1 callersMethodserialize
(T obj)
signal-base/src/main/java/com/skr/signal/base/rpc/letter/serialize/SignalSerializable.java:9
↓ 1 callersMethodsetHandshaker
(WebSocketClientHandshaker handshaker)
signal-route/src/main/java/com/skr/signal/route/websocket/WebSocketClientHandler.java:26
↓ 1 callersMethodshutDownHook
()
signal-base/src/main/java/com/skr/signal/base/rpc/server/RpcServer.java:86
↓ 1 callersMethodstart
()
signal-base/src/main/java/com/skr/signal/base/heartbeat/demo/HeartBeatServer.java:33
MethodConnectionWatcher
(Bootstrap bootstrap, Timer timer, int port, String host, boolean reconnect)
signal-base/src/main/java/com/skr/signal/base/heartbeat/demo/ConnectionWatcher.java:26
MethodHeartBeatServer
(int port)
signal-base/src/main/java/com/skr/signal/base/heartbeat/demo/HeartBeatServer.java:29
MethodNamedThreadFactory
(String threadNamePrefix)
signal-front/src/main/java/com/skr/signal/front/initialize/NamedThreadFactory.java:18
MethodPropertiesUtil
(String fileName)
signal-base/src/main/java/com/skr/signal/common/util/PropertiesUtil.java:14
MethodRpcClient
()
signal-base/src/main/java/com/skr/signal/base/rpc/client/proxy/RpcClient.java:44
MethodRpcHandler
(Map<String, Object> handlerMap)
signal-base/src/main/java/com/skr/signal/base/rpc/server/RpcHandler.java:24
MethodRpcNettyClient
()
signal-base/src/main/java/com/skr/signal/base/rpc/client/RpcNettyClient.java:76
MethodRpcServer
(String serverAddress, ServiceRegistry serviceRegistry)
signal-base/src/main/java/com/skr/signal/base/rpc/server/RpcServer.java:46
MethodServiceException
(String msg)
signal-front/src/main/java/com/skr/signal/front/exception/ServiceException.java:15
Methodaccept
(File file)
signal-base/src/main/java/com/skr/signal/common/util/ClassUtil.java:115
MethodbuildBaseInitializer
(ChannelPipeline pipeline)
signal-base/src/main/java/com/skr/signal/base/heartbeat/BaseClientInitializerWraper.java:16
MethodbuildBaseInitializer
(ChannelPipeline pipeline)
signal-base/src/main/java/com/skr/signal/base/heartbeat/BaseServerInitializerWraper.java:16
MethodchannelActive
(ChannelHandlerContext ctx)
signal-base/src/main/java/com/skr/signal/base/rpc/client/RpcClientHandler.java:33
MethodchannelActive
(ChannelHandlerContext ctx)
signal-base/src/main/java/com/skr/signal/base/heartbeat/demo/HeartBeatClientHandler.java:14
MethodchannelActive
channel链路每次active的时候，将其连接的次数重新☞ 0
signal-base/src/main/java/com/skr/signal/base/heartbeat/demo/ConnectionWatcher.java:38
MethodchannelInactive
(ChannelHandlerContext ctx)
signal-base/src/main/java/com/skr/signal/base/heartbeat/demo/HeartBeatClientHandler.java:21
MethodchannelInactive
(ChannelHandlerContext ctx)
signal-base/src/main/java/com/skr/signal/base/heartbeat/demo/ConnectionWatcher.java:47
MethodchannelRead
(ChannelHandlerContext channelHandlerContext, Object httpObject)
signal-front/src/main/java/com/skr/signal/front/initialize/HttpDistributor.java:36
MethodchannelRead
(ChannelHandlerContext ctx, Object msg)
signal-base/src/main/java/com/skr/signal/base/heartbeat/HeartbeatServerHandlerDefault.java:48
MethodchannelRead
(ChannelHandlerContext ctx, Object msg)
signal-base/src/main/java/com/skr/signal/base/heartbeat/HeartbeatClientHandlerDefault.java:40
MethodchannelRead
(ChannelHandlerContext ctx, Object msg)
signal-base/src/main/java/com/skr/signal/base/heartbeat/demo/HeartBeatClientHandler.java:28
MethodchannelRead
(ChannelHandlerContext ctx, Object msg)
signal-base/src/main/java/com/skr/signal/base/heartbeat/demo/HeartBeatServerHandler.java:14
MethodchannelRead0
(ChannelHandlerContext ctx, TextWebSocketFrame msg)
signal-data/src/main/java/com/skr/signal/data/websocket/handler/WebSocketHandler.java:15
MethodchannelRead0
(ChannelHandlerContext ctx, Object msg)
signal-route/src/main/java/com/skr/signal/route/websocket/WebSocketClientHandler.java:43
MethodchannelRead0
(ChannelHandlerContext ctx, RpcResponse response)
signal-base/src/main/java/com/skr/signal/base/rpc/client/RpcClientHandler.java:44
MethodchannelRead0
(ChannelHandlerContext ctx, RpcRequest request)
signal-base/src/main/java/com/skr/signal/base/rpc/server/RpcHandler.java:28
MethodchannelRegistered
(ChannelHandlerContext ctx)
signal-base/src/main/java/com/skr/signal/base/rpc/client/RpcClientHandler.java:38
MethodclearRegistry
清空注册中心的数据
signal-base/src/main/java/com/skr/signal/base/registry/impl/zookeeper/CuratorUtils.java:61
Methodcompute
(String args)
signal-core/src/main/java/com/skr/signal/core/service/impl/ComputeServiceImpl.java:17
MethodcreateWithTag
(Class<T> interfaceClass,String tag)
signal-base/src/main/java/com/skr/signal/base/rpc/client/proxy/RpcClient.java:38
Methoddata
(String args)
signal-data/src/main/java/com/skr/signal/data/service/DataServiceImpl.java:15
Methoddecode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out)
signal-base/src/main/java/com/skr/signal/base/rpc/letter/RpcDecoder.java:21
Methoddeserialize
(byte[] data, Class<T> cls)
signal-base/src/main/java/com/skr/signal/base/rpc/letter/serialize/impl/ProtoStuffSerializer.java:38
Methoddiscover
(String serviceName)
signal-base/src/main/java/com/skr/signal/base/registry/impl/zookeeper/ZKServiceDiscovery.java:35
Methodencode
(ChannelHandlerContext ctx, Object in, ByteBuf out)
signal-base/src/main/java/com/skr/signal/base/rpc/letter/RpcEncoder.java:18
MethodexceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
signal-data/src/main/java/com/skr/signal/data/websocket/handler/WebSocketHandler.java:35
MethodexceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
signal-front/src/main/java/com/skr/signal/front/initialize/HttpDistributor.java:69
MethodexceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
signal-base/src/main/java/com/skr/signal/base/rpc/client/RpcClientHandler.java:50
MethodexceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
signal-base/src/main/java/com/skr/signal/base/rpc/server/RpcHandler.java:61
MethodexceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
signal-base/src/main/java/com/skr/signal/base/heartbeat/HeartbeatServerHandlerDefault.java:54
MethodexceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
signal-base/src/main/java/com/skr/signal/base/heartbeat/demo/HeartBeatServerHandler.java:20
next →1–100 of 155, ranked by callers