MCPcopy Index your code

hub / github.com/IAMPadA/Panda-Rpc-Framework / functions

Functions103 in github.com/IAMPadA/Panda-Rpc-Framework

⨍ Functions 103◇ Types & classes 55
↓ 18 callersMethodgetCode
()
rpc-core/src/main/java/com/panda/rpc/serializer/CommonSerializer.java:36
↓ 11 callersMethodget
(InetSocketAddress inetSocketAddress, CommonSerializer serializer)
rpc-core/src/main/java/com/panda/rpc/transport/netty/client/ChannelProvider.java:51
↓ 7 callersMethodgetByCode
(int code)
rpc-core/src/main/java/com/panda/rpc/serializer/CommonSerializer.java:17
↓ 6 callersMethodput
(String requestId, CompletableFuture<RpcResponse> future)
rpc-core/src/main/java/com/panda/rpc/transport/netty/client/UnprocessedRequests.java:17
↓ 6 callersMethodremove
(String requestId)
rpc-core/src/main/java/com/panda/rpc/transport/netty/client/UnprocessedRequests.java:21
↓ 5 callersMethodintToBytes
@description 将Int转换为字节数组 @param [value] @return [byte[]] @date [2021-03-10 22:15]
rpc-core/src/main/java/com/panda/rpc/transport/socket/util/ObjectWriter.java:42
↓ 4 callersMethodbytesToInt
@description 字节数组转换为Int @param [src] @return [int] @date [2021-03-10 21:57]
rpc-core/src/main/java/com/panda/rpc/transport/socket/util/ObjectReader.java:64
↓ 4 callersMethodgetProxy
(Class<T> clazz)
rpc-core/src/main/java/com/panda/rpc/transport/RpcClientProxy.java:33
↓ 4 callersMethodreadObject
(InputStream in)
rpc-core/src/main/java/com/panda/rpc/transport/socket/util/ObjectReader.java:25
↓ 4 callersMethodwriteObject
(OutputStream out, Object object, CommonSerializer serializer)
rpc-core/src/main/java/com/panda/rpc/transport/socket/util/ObjectWriter.java:22
↓ 3 callersMethodregister
@description 将一个服务注册到注册表 @param [ServiceName, inetSocketAddress] 服务名称，提供服务的地址 @return [void] @date [2021-03-13 14:44]
rpc-core/src/main/java/com/panda/rpc/register/ServiceRegistry.java:18
↓ 2 callersMethodaddClearAllHook
()
rpc-core/src/main/java/com/panda/rpc/hook/ShutdownHook.java:27
↓ 2 callersMethodbye
(String name)
rpc-api/src/main/java/com/panda/rpc/api/ByeService.java:10
↓ 2 callersMethodcheck
(RpcRequest rpcRequest, RpcResponse rpcResponse)
rpc-common/src/main/java/com/panda/rpc/util/RpcMessageChecker.java:24
↓ 2 callersMethodcomplete
(RpcResponse rpcResponse)
rpc-core/src/main/java/com/panda/rpc/transport/netty/client/UnprocessedRequests.java:25
↓ 2 callersMethodconnect
@description Netty客户端创建通道连接 @param [bootstrap, inetSocketAddress] @return [void] @date [2021-03-11 14:19]
rpc-core/src/main/java/com/panda/rpc/transport/netty/client/ChannelProvider.java:89
↓ 2 callersMethodcreateThreadPool
(String threadNamePrefix, Boolean daemon)
rpc-common/src/main/java/com/panda/rpc/factory/ThreadPoolFactory.java:68
↓ 2 callersMethoddeserialize
(byte[] bytes, Class<?> clazz)
rpc-core/src/main/java/com/panda/rpc/serializer/CommonSerializer.java:34
↓ 2 callersMethodgetInstance
(Class<T> clazz)
rpc-common/src/main/java/com/panda/rpc/factory/SingletonFactory.java:17
↓ 2 callersMethodgetSchema
@description 获取Schema @param [clazz] @return [io.protostuff.Schema] @date [2021-03-11 21:38]
rpc-core/src/main/java/com/panda/rpc/serializer/ProtostuffSerializer.java:69
↓ 2 callersMethodgetShutdownHook
()
rpc-core/src/main/java/com/panda/rpc/hook/ShutdownHook.java:22
↓ 2 callersMethodhandle
(RpcRequest rpcRequest)
rpc-core/src/main/java/com/panda/rpc/handler/RequestHandler.java:28
↓ 2 callersMethodhello
@description 接口方法 @param [object] @return [java.lang.String] @date [2021-02-03 15:28]
rpc-api/src/main/java/com/panda/rpc/api/HelloService.java:15
↓ 2 callersMethodlookupService
@description 根据服务名称查找服务端地址 @param [serviceName] @return [java.net.InetSocketAddress] @date [2021-03-14 10:09]
rpc-core/src/main/java/com/panda/rpc/register/ServiceDiscovery.java:17
↓ 2 callersMethodpublishService
@description 将服务保存在本地的注册表，同时注册到Nacos @param [service, serviceName] @return [void] @date [2021-03-16 12:32]
rpc-core/src/main/java/com/panda/rpc/transport/AbstractRpcServer.java:87
↓ 2 callersMethodscanServices
()
rpc-core/src/main/java/com/panda/rpc/transport/AbstractRpcServer.java:31
↓ 2 callersMethodsendRequest
(RpcRequest rpcRequest)
rpc-core/src/main/java/com/panda/rpc/transport/RpcClient.java:15
↓ 2 callersMethodserialize
(Object obj)
rpc-core/src/main/java/com/panda/rpc/serializer/CommonSerializer.java:32
↓ 1 callersMethodaccept
(File file)
rpc-common/src/main/java/com/panda/rpc/util/ReflectUtil.java:124
↓ 1 callersMethodaddServiceProvider
(T service, String serviceName)
rpc-core/src/main/java/com/panda/rpc/provider/ServiceProvider.java:10
↓ 1 callersMethodclearRegistry
@description 注销服务 @param [] @return [void] @date [2021-03-14 13:37]
rpc-common/src/main/java/com/panda/rpc/util/NacosUtil.java:80
↓ 1 callersMethodcreateDefaultThreadPool
(String threadNamePrefix)
rpc-common/src/main/java/com/panda/rpc/factory/ThreadPoolFactory.java:32
↓ 1 callersMethodcreateThreadFactory
@description 创建ThreadFactory，如果threadNamePrefix不为空则使用自建ThreadFactory，否则使用defaultThreadFactory @param threadNamePrefix 作为创建的线程名字的前缀，指定有意义的线程名称，方便出错时回溯
rpc-common/src/main/java/com/panda/rpc/factory/ThreadPoolFactory.java:85
↓ 1 callersMethoddecode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out)
rpc-core/src/main/java/com/panda/rpc/codec/CommonDecoder.java:27
↓ 1 callersMethodfail
@description 失败时服务端返回的对象 @param [code] @return [com.panda.rpc.entity.RpcResponse<T>] @date [2021-02-03 17:42]
rpc-common/src/main/java/com/panda/rpc/entity/RpcResponse.java:55
↓ 1 callersMethodfindAndAddClassesInPackageByFile
(String packageName, String packagePath, final boolea
rpc-common/src/main/java/com/panda/rpc/util/ReflectUtil.java:112
↓ 1 callersMethodgetAllInstance
@description 获取所有提供该服务的服务端地址 @param [namingService, serviceName] @return [java.util.List<com.alibaba.nacos.api.naming.pojo.Instance>] @date [2021-03-1
rpc-common/src/main/java/com/panda/rpc/util/NacosUtil.java:70
↓ 1 callersMethodgetClasses
(String packageName)
rpc-common/src/main/java/com/panda/rpc/util/ReflectUtil.java:27
↓ 1 callersMethodgetNacosNamingService
@description 连接到Nacos创建命名空间 @param [] @return [com.alibaba.nacos.api.naming.NamingService] @date [2021-03-14 9:33]
rpc-common/src/main/java/com/panda/rpc/util/NacosUtil.java:42
↓ 1 callersMethodgetServiceProvider
(String serviceName)
rpc-core/src/main/java/com/panda/rpc/provider/ServiceProvider.java:12
↓ 1 callersMethodgetStackTrace
()
rpc-common/src/main/java/com/panda/rpc/util/ReflectUtil.java:22
↓ 1 callersMethodhandleRequest
@description 使用JSON反序列化Object数组，无法保证反序列化后仍然为原实例类，通常直接被反序列化成String类型，因此要特殊处理 @param [obj] @return [java.lang.Object] @date [2021-02-22 15:03]
rpc-core/src/main/java/com/panda/rpc/serializer/JsonSerializer.java:54
↓ 1 callersMethodinitializeBootstrap
()
rpc-core/src/main/java/com/panda/rpc/transport/netty/client/ChannelProvider.java:37
↓ 1 callersMethodinvoke
(Object proxy, Method method, Object[] args)
rpc-core/src/main/java/com/panda/rpc/transport/RpcClientProxy.java:39
↓ 1 callersMethodinvokeTargetMethod
(RpcRequest rpcRequest,Object service)
rpc-core/src/main/java/com/panda/rpc/handler/RequestHandler.java:34
↓ 1 callersMethodregisterService
@description 注册服务到Nacos @param [namingService, serviceName, inetSocketAddress] @return [void] @date [2021-03-14 9:34]
rpc-common/src/main/java/com/panda/rpc/util/NacosUtil.java:57
↓ 1 callersMethodselect
@description 从一系列Instance中选择一个 @param [instances] @return [com.alibaba.nacos.api.naming.pojo.Instance] @date [2021-03-15 16:00]
rpc-core/src/main/java/com/panda/rpc/loadbalancer/LoadBalancer.java:20
↓ 1 callersMethodshutDownAll
()
rpc-common/src/main/java/com/panda/rpc/factory/ThreadPoolFactory.java:50
↓ 1 callersMethodstart
@description 服务端启动 @param [] @return [void] @date [2021-02-05 11:57]
rpc-core/src/main/java/com/panda/rpc/transport/socket/server/SocketServer.java:57
↓ 1 callersMethodstart
()
rpc-core/src/main/java/com/panda/rpc/transport/netty/server/NettyServer.java:44
↓ 1 callersMethodsuccess
@description 成功时服务端返回的对象 @param [data] @return [com.panda.rpc.entity.RpcResponse<T>] @date [2021-02-03 17:31]
rpc-common/src/main/java/com/panda/rpc/entity/RpcResponse.java:41
MethodCommonEncoder
(CommonSerializer serializer)
rpc-core/src/main/java/com/panda/rpc/codec/CommonEncoder.java:21
MethodNacosServiceDiscovery
(LoadBalancer loadBalancer)
rpc-core/src/main/java/com/panda/rpc/register/NacosServiceDiscovery.java:27
MethodNettyClient
()
rpc-core/src/main/java/com/panda/rpc/transport/netty/client/NettyClient.java:49
MethodNettyClientHandler
()
rpc-core/src/main/java/com/panda/rpc/transport/netty/client/NettyClientHandler.java:30
MethodNettyServer
(String host, int port)
rpc-core/src/main/java/com/panda/rpc/transport/netty/server/NettyServer.java:30
MethodNettyServerHandler
()
rpc-core/src/main/java/com/panda/rpc/transport/netty/server/NettyServerHandler.java:23
MethodRpcClientProxy
(RpcClient client)
rpc-core/src/main/java/com/panda/rpc/transport/RpcClientProxy.java:28
MethodRpcException
(RpcError error, String detail)
rpc-common/src/main/java/com/panda/rpc/exception/RpcException.java:12
MethodRpcMessageChecker
()
rpc-common/src/main/java/com/panda/rpc/util/RpcMessageChecker.java:21
MethodSerializeException
(String msg)
rpc-common/src/main/java/com/panda/rpc/exception/SerializeException.java:9
MethodSingletonFactory
()
rpc-common/src/main/java/com/panda/rpc/factory/SingletonFactory.java:15
MethodSocketClient
()
rpc-core/src/main/java/com/panda/rpc/transport/socket/client/SocketClient.java:38
MethodSocketRequestHandlerThread
(Socket socket, RequestHandler requestHandler, CommonSerializer serializer)
rpc-core/src/main/java/com/panda/rpc/transport/socket/server/SocketRequestHandlerThread.java:29
MethodSocketServer
(String host, int port)
rpc-core/src/main/java/com/panda/rpc/transport/socket/server/SocketServer.java:35
MethodaddServiceProvider
@description 保存服务到本地服务注册表 @param [service, serviceClass] 服务的实现类对象，服务类（接口） @return [void] @date [2021-03-14 9:51]
rpc-core/src/main/java/com/panda/rpc/provider/ServiceProviderImpl.java:36
Methodbye
(String name)
test-server/src/main/java/com/panda/rpc/test/ByeServiceImpl.java:14
MethodchannelRead0
(ChannelHandlerContext ctx, RpcResponse msg)
rpc-core/src/main/java/com/panda/rpc/transport/netty/client/NettyClientHandler.java:52
MethodchannelRead0
(ChannelHandlerContext ctx, RpcRequest msg)
rpc-core/src/main/java/com/panda/rpc/transport/netty/server/NettyServerHandler.java:40
Methoddeserialize
(byte[] bytes, Class<?> clazz)
rpc-core/src/main/java/com/panda/rpc/serializer/ProtostuffSerializer.java:48
Methoddeserialize
(byte[] bytes, Class<?> clazz)
rpc-core/src/main/java/com/panda/rpc/serializer/HessianSerializer.java:44
Methoddeserialize
(byte[] bytes, Class<?> clazz)
rpc-core/src/main/java/com/panda/rpc/serializer/KryoSerializer.java:52
Methoddeserialize
(byte[] bytes, Class<?> clazz)
rpc-core/src/main/java/com/panda/rpc/serializer/JsonSerializer.java:34
Methodencode
(ChannelHandlerContext ctx, Object msg, ByteBuf out)
rpc-core/src/main/java/com/panda/rpc/codec/CommonEncoder.java:25
MethodexceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
rpc-core/src/main/java/com/panda/rpc/transport/netty/client/NettyClientHandler.java:63
MethodexceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
rpc-core/src/main/java/com/panda/rpc/transport/netty/server/NettyServerHandler.java:60
MethodgetCode
()
rpc-core/src/main/java/com/panda/rpc/serializer/ProtostuffSerializer.java:58
MethodgetCode
()
rpc-core/src/main/java/com/panda/rpc/serializer/HessianSerializer.java:60
MethodgetCode
()
rpc-core/src/main/java/com/panda/rpc/serializer/KryoSerializer.java:66
MethodgetCode
()
rpc-core/src/main/java/com/panda/rpc/serializer/JsonSerializer.java:66
MethodgetServiceProvider
(String serviceName)
rpc-core/src/main/java/com/panda/rpc/provider/ServiceProviderImpl.java:46
Methodhello
(HelloObject object)
test-server/src/main/java/com/panda/rpc/test/HelloServiceImpl.java:22
MethodinitChannel
(SocketChannel ch)
rpc-core/src/main/java/com/panda/rpc/transport/netty/client/ChannelProvider.java:62
MethodinitChannel
(SocketChannel ch)
rpc-core/src/main/java/com/panda/rpc/transport/netty/server/NettyServer.java:69
MethodlookupService
@description 根据服务名称从注册中心获取到一个服务提供者的地址 @param [serviceName] @return [java.net.InetSocketAddress] @date [2021-03-14 10:19]
rpc-core/src/main/java/com/panda/rpc/register/NacosServiceDiscovery.java:40
Methodmain
(String[] args)
test-client/src/main/java/com/panda/test/SocketTestClient.java:18
Methodmain
(String[] args)
test-client/src/main/java/com/panda/test/NettyTestClient.java:17
Methodmain
(String[] args)
test-server/src/main/java/com/panda/rpc/test/NettyTestServer.java:15
Methodmain
(String[] args)
test-server/src/main/java/com/panda/rpc/test/SocketTestServer.java:15
MethodpublishService
@description 向Nacos注册服务 @param [service, serviceClass] @return [void] @date [2021-03-13 15:56]
rpc-core/src/main/java/com/panda/rpc/transport/RpcServer.java:22
Methodregister
@description 将服务的名称和地址注册进服务注册中心 @param [serviceName, inetSocketAddress] @return [void] @date [2021-03-13 15:40]
rpc-core/src/main/java/com/panda/rpc/register/NacosServiceRegistry.java:27
Methodrun
()
rpc-core/src/main/java/com/panda/rpc/transport/socket/server/SocketRequestHandlerThread.java:35
Methodselect
(List<Instance> instances)
rpc-core/src/main/java/com/panda/rpc/loadbalancer/RandomLoadBalancer.java:15
Methodselect
(List<Instance> instances)
rpc-core/src/main/java/com/panda/rpc/loadbalancer/RoundRobinLoadBalancer.java:19
MethodsendRequest
(RpcRequest rpcRequest)
rpc-core/src/main/java/com/panda/rpc/transport/socket/client/SocketClient.java:56
MethodsendRequest
(RpcRequest rpcRequest)
rpc-core/src/main/java/com/panda/rpc/transport/netty/client/NettyClient.java:68
Methodserialize
(Object obj)
rpc-core/src/main/java/com/panda/rpc/serializer/ProtostuffSerializer.java:32
Methodserialize
(Object obj)
rpc-core/src/main/java/com/panda/rpc/serializer/HessianSerializer.java:23
Methodserialize
(Object obj)
rpc-core/src/main/java/com/panda/rpc/serializer/KryoSerializer.java:38
Methodserialize
(Object obj)
rpc-core/src/main/java/com/panda/rpc/serializer/JsonSerializer.java:24
next →1–100 of 103, ranked by callers