Functions — github.com/SunnyKate1998/miao-rpc-framework

hub / github.com/SunnyKate1998/miao-rpc-framework / functions

Functions95 in github.com/SunnyKate1998/miao-rpc-framework

⨍ Functions 95 ◇ Types & classes 54

↓ 17 callersMethodgetCode

()

src/main/java/top/miaofang/core/serializer/CommonSerializer.java:35

↓ 8 callersMethodget

(InetSocketAddress inetSocketAddress, CommonSerializer serializer)

src/main/java/top/miaofang/core/netty/client/ChannelProvider.java:34

↓ 5 callersMethodgetByCode

(int code)

src/main/java/top/miaofang/core/serializer/CommonSerializer.java:16

↓ 5 callersMethodintToBytes

(int value)

src/main/java/top/miaofang/common/util/ObjectWriter.java:34

↓ 5 callersMethodput

(String requestId, CompletableFuture<RpcResponse> future)

src/main/java/top/miaofang/core/netty/client/UnprocessedRequests.java:15

↓ 5 callersMethodremove

(String requestId)

src/main/java/top/miaofang/core/netty/client/UnprocessedRequests.java:19

↓ 4 callersMethodbytesToInt

(byte[] src)

src/main/java/top/miaofang/common/util/ObjectReader.java:57

↓ 3 callersMethodreadObject

(InputStream in)

src/main/java/top/miaofang/common/util/ObjectReader.java:24

↓ 3 callersMethodregister

将一个服务注册进注册表 @param serviceName 服务名称 @param inetSocketAddress 提供服务的地址

src/main/java/top/miaofang/core/registry/ServiceRegistry.java:17

↓ 3 callersMethodwriteObject

(OutputStream outputStream, Object object, CommonSerializer serializer)

src/main/java/top/miaofang/common/util/ObjectWriter.java:18

↓ 2 callersMethodconnect

(Bootstrap bootstrap, InetSocketAddress inetSocketAddress, CountDownLatch countDownLatch)

src/main/java/top/miaofang/core/netty/client/ChannelProvider.java:55

↓ 2 callersMethodcreateThreadPool

(String threadNamePrefix, Boolean daemon)

src/main/java/top/miaofang/common/factory/ThreadPoolFactory.java:63

↓ 2 callersMethoddeserialize

(byte[] bytes, Class<?> clazz)

src/main/java/top/miaofang/core/serializer/CommonSerializer.java:33

↓ 2 callersMethodgetProxy

(Class<T> clazz)

src/main/java/top/miaofang/core/client/RpcClientProxy.java:21

↓ 2 callersMethodgetSchema

(Class clazz)

src/main/java/top/miaofang/core/serializer/ProtobufSerializer.java:50

↓ 2 callersMethodhandle

(RpcRequest rpcRequest)

src/main/java/top/miaofang/core/server/RequestHandler.java:27

↓ 2 callersMethodlookupService

根据服务名称查找服务实体 @param serviceName 服务名称 @return 服务实体

src/main/java/top/miaofang/core/registry/ServiceDiscovery.java:17

↓ 2 callersMethodpublishService

(T service, String serviceName)

src/main/java/top/miaofang/core/server/AbstractRpcServer.java:69

↓ 2 callersMethodserialize

(Object obj)

src/main/java/top/miaofang/core/serializer/CommonSerializer.java:31

↓ 2 callersMethodsuccess

(T data, String requestId)

src/main/java/top/miaofang/common/entity/RpcResponse.java:36

↓ 1 callersMethodaddClearAllHook

()

src/main/java/top/miaofang/core/hook/ShutdownHook.java:21

↓ 1 callersMethodaddServiceProvider

(T service, String serviceName)

src/main/java/top/miaofang/core/provider/ServiceProvider.java:10

↓ 1 callersMethodbye

(String name)

src/main/java/top/miaofang/api/ByeService.java:8

↓ 1 callersMethodcheck

(RpcRequest rpcRequest, RpcResponse rpcResponse)

src/main/java/top/miaofang/common/util/RpcMessageChecker.java:24

↓ 1 callersMethodclearRegistry

()

src/main/java/top/miaofang/common/util/NacosUtil.java:56

↓ 1 callersMethodcreateDefaultThreadPool

(String threadNamePrefix)

src/main/java/top/miaofang/common/factory/ThreadPoolFactory.java:33

↓ 1 callersMethodcreateThreadFactory

创建 ThreadFactory 。如果threadNamePrefix不为空则使用自建ThreadFactory，否则使用defaultThreadFactory @param threadNamePrefix 作为创建的线程名字的前缀 @param daemon 指定是否为

src/main/java/top/miaofang/common/factory/ThreadPoolFactory.java:77

↓ 1 callersMethoddecode

(ChannelHandlerContext ctx, ByteBuf in, List<Object> out)

src/main/java/top/miaofang/core/codec/CommonDecoder.java:26

↓ 1 callersMethodfail

(ResponseCode code, String requestId)

src/main/java/top/miaofang/common/entity/RpcResponse.java:44

↓ 1 callersMethodfindAndAddClassesInPackageByFile

(String packageName, String packagePath, final boolea

src/main/java/top/miaofang/common/util/ReflectUtil.java:111

↓ 1 callersMethodgetAllInstance

(String serviceName)

src/main/java/top/miaofang/common/util/NacosUtil.java:52

↓ 1 callersMethodgetClasses

(String packageName)

src/main/java/top/miaofang/common/util/ReflectUtil.java:25

↓ 1 callersMethodgetInstance

(Class<T> clazz)

src/main/java/top/miaofang/common/factory/SingletonFactory.java:16

↓ 1 callersMethodgetNacosNamingService

()

src/main/java/top/miaofang/common/util/NacosUtil.java:36

↓ 1 callersMethodgetServiceProvider

(String serviceName)

src/main/java/top/miaofang/core/provider/ServiceProvider.java:12

↓ 1 callersMethodgetShutdownHook

()

src/main/java/top/miaofang/core/hook/ShutdownHook.java:17

↓ 1 callersMethodgetStackTrace

()

src/main/java/top/miaofang/common/util/ReflectUtil.java:20

↓ 1 callersMethodhandleRequest

(Object obj)

src/main/java/top/miaofang/core/serializer/JsonSerializer.java:52

↓ 1 callersMethodhello

(HelloObject object)

src/main/java/top/miaofang/api/HelloService.java:7

↓ 1 callersMethodinitializeBootstrap

()

src/main/java/top/miaofang/core/netty/client/ChannelProvider.java:82

↓ 1 callersMethodinvoke

(Object proxy, Method method, Object[] args)

src/main/java/top/miaofang/core/client/RpcClientProxy.java:26

↓ 1 callersMethodinvokeTargetMethod

(RpcRequest rpcRequest, Object service)

src/main/java/top/miaofang/core/server/RequestHandler.java:39

↓ 1 callersMethodregisterService

(String serviceName, InetSocketAddress address)

src/main/java/top/miaofang/common/util/NacosUtil.java:45

↓ 1 callersMethodscanServices

()

src/main/java/top/miaofang/core/server/AbstractRpcServer.java:29

↓ 1 callersMethodselect

(List<Instance> instances)

src/main/java/top/miaofang/core/loadbalancer/LoadBalancer.java:12

↓ 1 callersMethodsendRequest

(RpcRequest rpcRequest)

src/main/java/top/miaofang/core/client/RpcClient.java:10

↓ 1 callersMethodshutDownAll

()

src/main/java/top/miaofang/common/factory/ThreadPoolFactory.java:48

↓ 1 callersMethodstart

()

src/main/java/top/miaofang/core/netty/server/NettyServer.java:51

MethodCommonEncoder

(CommonSerializer serializer)

src/main/java/top/miaofang/core/codec/CommonEncoder.java:20

MethodNacosServiceDiscovery

(LoadBalancer loadBalancer)

src/main/java/top/miaofang/core/registry/NacosServiceDiscovery.java:25

MethodNettyClient

()

src/main/java/top/miaofang/core/netty/client/NettyClient.java:56

MethodNettyServer

(String host, int port)

src/main/java/top/miaofang/core/netty/server/NettyServer.java:38

MethodRequestHandlerThread

(Socket socket, RequestHandler requestHandler, ServiceRegistry serviceRegistry, CommonSerializer serializer)

src/main/java/top/miaofang/core/server/RequestHandlerThread.java:30

MethodRpcClientProxy

(RpcClient client)

src/main/java/top/miaofang/core/client/RpcClientProxy.java:17

MethodRpcException

(RpcError error, String detail)

src/main/java/top/miaofang/common/exception/RpcException.java:10

MethodRpcMessageChecker

()

src/main/java/top/miaofang/common/util/RpcMessageChecker.java:21

MethodSerializerException

(String msg)

src/main/java/top/miaofang/common/exception/SerializerException.java:9

MethodSingletonFactory

()

src/main/java/top/miaofang/common/factory/SingletonFactory.java:14

MethodSocketClient

()

src/main/java/top/miaofang/socket/client/SocketClient.java:36

MethodThreadPoolFactory

()

src/main/java/top/miaofang/common/factory/ThreadPoolFactory.java:30

Methodaccept

(File file)

src/main/java/top/miaofang/common/util/ReflectUtil.java:123

MethodaddServiceProvider

(T service, String serviceName)

src/main/java/top/miaofang/core/provider/ServiceProviderImpl.java:24

Methodbye

(String name)

src/main/java/top/miaofang/test/server/ByeServiceImpl.java:11

MethodchannelRead0

(ChannelHandlerContext ctx, RpcResponse msg)

src/main/java/top/miaofang/core/netty/client/NettyClientHandler.java:19

MethodchannelRead0

(ChannelHandlerContext ctx, RpcRequest msg)

src/main/java/top/miaofang/core/netty/server/NettyServerHandler.java:33

Methodcomplete

(RpcResponse rpcResponse)

src/main/java/top/miaofang/core/netty/client/UnprocessedRequests.java:23

Methoddeserialize

(byte[] bytes, Class<?> clazz)

src/main/java/top/miaofang/core/serializer/ProtobufSerializer.java:36

Methoddeserialize

(byte[] bytes, Class<?> clazz)

src/main/java/top/miaofang/core/serializer/KryoSerializer.java:46

Methoddeserialize

(byte[] bytes, Class<?> clazz)

src/main/java/top/miaofang/core/serializer/JsonSerializer.java:33

Methodencode

(ChannelHandlerContext ctx, Object msg, ByteBuf out)

src/main/java/top/miaofang/core/codec/CommonEncoder.java:24

MethodexceptionCaught

(ChannelHandlerContext ctx, Throwable cause)

src/main/java/top/miaofang/core/netty/client/NettyClientHandler.java:31

MethodexceptionCaught

(ChannelHandlerContext ctx, Throwable cause)

src/main/java/top/miaofang/core/netty/server/NettyServerHandler.java:47

MethodgetCode

()

src/main/java/top/miaofang/core/serializer/ProtobufSerializer.java:45

MethodgetCode

()

src/main/java/top/miaofang/core/serializer/KryoSerializer.java:60

MethodgetCode

()

src/main/java/top/miaofang/core/serializer/JsonSerializer.java:64

MethodgetServiceProvider

(String serviceName)

src/main/java/top/miaofang/core/provider/ServiceProviderImpl.java:32

Methodhello

(HelloObject object)

src/main/java/top/miaofang/test/server/HelloServiceImpl.java:14

MethodinitChannel

(SocketChannel ch)

src/main/java/top/miaofang/core/netty/client/ChannelProvider.java:36

MethodinitChannel

(SocketChannel ch)

src/main/java/top/miaofang/core/netty/server/NettyServer.java:66

MethodlookupService

(String serviceName)

src/main/java/top/miaofang/core/registry/NacosServiceDiscovery.java:30

Methodmain

(String[] args)

src/main/java/top/miaofang/Main.java:4

Methodmain

(String[] args)

src/main/java/top/miaofang/test/client/NettyTestClient.java:20

Methodmain

(String[] args)

src/main/java/top/miaofang/test/server/NettyTestServer.java:19

Methodmain

(String[] args)

src/main/java/top/miaofang/test/server/SocketTestServer.java:13

MethodpublishService

(T service, String serviceName)

src/main/java/top/miaofang/core/server/RpcServer.java:11

Methodregister

(String serviceName, InetSocketAddress inetSocketAddress)

src/main/java/top/miaofang/core/registry/NacosServiceRegistry.java:21

Methodrun

()

src/main/java/top/miaofang/core/server/RequestHandlerThread.java:37

Methodselect

(List<Instance> instances)

src/main/java/top/miaofang/core/loadbalancer/RandomLoadBalancer.java:13

Methodselect

(List<Instance> instances)

src/main/java/top/miaofang/core/loadbalancer/RoundRobinLoadBalancer.java:14

MethodsendRequest

(RpcRequest rpcRequest)

src/main/java/top/miaofang/core/netty/client/NettyClient.java:71

MethodsendRequest

(RpcRequest rpcRequest)

src/main/java/top/miaofang/socket/client/SocketClient.java:51

Methodserialize

(Object obj)

src/main/java/top/miaofang/core/serializer/ProtobufSerializer.java:22

Methodserialize

(Object obj)

src/main/java/top/miaofang/core/serializer/KryoSerializer.java:32

Methodserialize

(Object obj)

src/main/java/top/miaofang/core/serializer/JsonSerializer.java:22

Methodstart

()

src/main/java/top/miaofang/core/server/RpcServer.java:9