Functions — github.com/Snailclimb/guide-rpc-framework

hub / github.com/Snailclimb/guide-rpc-framework / functions

Functions187 in github.com/Snailclimb/guide-rpc-framework

⨍ Functions 187◇ Types & classes 95

↓ 1 callersMethodshutDownAllThreadPool

shutDown 所有线程池

rpc-framework-common/src/main/java/github/javaguide/utils/concurrent/threadpool/ThreadPoolFactoryUtil.java:52

↓ 1 callersMethodstart

()

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/server/NettyRpcServer.java:47

↓ 1 callersMethodtest

()

example-client/src/main/java/github/javaguide/HelloController.java:15

MethodChannelProvider

()

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/client/ChannelProvider.java:21

MethodConsistentHashSelector

(List<String> invokers, int replicaNumber, int identityHashCode)

rpc-framework-simple/src/main/java/github/javaguide/loadbalance/loadbalancer/ConsistentHashLoadBalance.java:45

MethodConsistentHashingLoadBalancer

构造函数，在初始化的时候，就需要进行hash环的构建了

rpc-framework-simple/src/main/java/github/javaguide/loadbalance/loadbalancer/ConsistentHashLoadBalanceNew.java:86

MethodCuratorUtils

()

rpc-framework-simple/src/main/java/github/javaguide/registry/zk/util/CuratorUtils.java:40

MethodCustomScanner

(BeanDefinitionRegistry registry, Class<? extends Annotation> annoType)

rpc-framework-simple/src/main/java/github/javaguide/spring/CustomScanner.java:17

MethodExtensionLoader

(Class<?> type)

rpc-framework-common/src/main/java/github/javaguide/extension/ExtensionLoader.java:50

MethodLRUCache

(int capacity)

rpc-framework-simple/src/test/java/github/LRUCache.java:105

MethodListM

()

rpc-framework-simple/src/test/java/github/LRUCache.java:52

MethodNettyRpcClient

()

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/client/NettyRpcClient.java:47

MethodNettyRpcClientHandler

()

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/client/NettyRpcClientHandler.java:32

MethodNettyRpcServerHandler

()

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/server/NettyRpcServerHandler.java:35

MethodNode

()

rpc-framework-simple/src/test/java/github/LRUCache.java:21

MethodPropertiesFileUtil

()

rpc-framework-common/src/main/java/github/javaguide/utils/PropertiesFileUtil.java:18

MethodRpcClientProxy

(RpcRequestTransport rpcRequestTransport, RpcServiceConfig rpcServiceConfig)

rpc-framework-simple/src/main/java/github/javaguide/proxy/RpcClientProxy.java:37

MethodRpcException

(RpcErrorMessageEnum rpcErrorMessageEnum, String detail)

rpc-framework-common/src/main/java/github/javaguide/exception/RpcException.java:10

MethodRpcMessageDecoder

()

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/codec/RpcMessageDecoder.java:45

MethodRpcMessageFrameDecoder

()

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/codec/RpcMessageFrameDecoder.java:14

MethodRpcRequestHandler

()

rpc-framework-simple/src/main/java/github/javaguide/remoting/handler/RpcRequestHandler.java:23

MethodSerializeException

(String message)

rpc-framework-common/src/main/java/github/javaguide/exception/SerializeException.java:8

MethodSerializeException

(String message)

rpc-framework-simple/src/main/java/github/javaguide/serialize/kyro/KryoSerializer.java:62

MethodSingletonFactory

()

rpc-framework-common/src/main/java/github/javaguide/factory/SingletonFactory.java:27

MethodSocketRpcClient

()

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/socket/SocketRpcClient.java:29

MethodSocketRpcRequestHandlerRunnable

(Socket socket)

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/socket/SocketRpcRequestHandlerRunnable.java:24

MethodSocketRpcServer

()

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/socket/SocketRpcServer.java:31

MethodSpringBeanPostProcessor

()

rpc-framework-simple/src/main/java/github/javaguide/spring/SpringBeanPostProcessor.java:34

MethodTestConsistentHashLoadBalance

()

rpc-framework-simple/src/test/java/github/javaguide/loadbalance/loadbalancer/ConsistentHashLoadBalanceTest.java:59

MethodTestZk

()

rpc-framework-simple/src/test/java/github/javaguide/loadbalance/loadbalancer/ConsistentHashLoadBalanceTest.java:35

MethodThreadPoolFactoryUtil

()

rpc-framework-common/src/main/java/github/javaguide/utils/concurrent/threadpool/ThreadPoolFactoryUtil.java:25

MethodZkServiceDiscoveryImpl

()

rpc-framework-simple/src/main/java/github/javaguide/registry/zk/ZkServiceDiscoveryImpl.java:28

MethodZkServiceProviderImpl

()

rpc-framework-simple/src/main/java/github/javaguide/provider/impl/ZkServiceProviderImpl.java:35

MethodaddService

@param rpcServiceConfig rpc service related attributes

rpc-framework-simple/src/main/java/github/javaguide/provider/ServiceProvider.java:16

MethodchannelRead

Read the message transmitted by the server

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/client/NettyRpcClientHandler.java:40

MethodchannelRead

(ChannelHandlerContext ctx, Object msg)

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/server/NettyRpcServerHandler.java:39

Methoddecode

ByteBuf -> RPC Message

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/codec/RpcMessageCodec.java:89

Methoddecode

(ChannelHandlerContext ctx, ByteBuf in)

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/codec/RpcMessageDecoder.java:68

Methoddeserialize

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

rpc-framework-simple/src/main/java/github/javaguide/serialize/protostuff/ProtostuffSerializer.java:38

MethoddoSelect

(List<String> serviceAddresses, RpcRequest rpcRequest)

rpc-framework-simple/src/main/java/github/javaguide/loadbalance/loadbalancer/ConsistentHashLoadBalanceNew.java:34

MethoddoSelect

(List<String> serviceAddresses, RpcRequest rpcRequest)

rpc-framework-simple/src/main/java/github/javaguide/loadbalance/loadbalancer/ConsistentHashLoadBalance.java:26

MethoddoSelect

(List<String> serviceAddresses, RpcRequest rpcRequest)

rpc-framework-simple/src/main/java/github/javaguide/loadbalance/loadbalancer/RandomLoadBalance.java:16

Methodencode

(ChannelHandlerContext ctx, RpcMessage rpcMessage, ByteBuf out)

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/codec/RpcMessageEncoder.java:47

Methodencode

RPC Message -> ByteBuf

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/codec/RpcMessageCodec.java:39

MethodexceptionCaught

Called when an exception occurs in processing a client message

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/client/NettyRpcClientHandler.java:81

MethodexceptionCaught

(ChannelHandlerContext ctx, Throwable cause)

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/server/NettyRpcServerHandler.java:87

MethodgetAllNodes

获取所有物理节点

rpc-framework-simple/src/main/java/github/javaguide/loadbalance/loadbalancer/ConsistentHashLoadBalanceNew.java:219

MethodgetInstanceOld

(Class<T> c)

rpc-framework-common/src/main/java/github/javaguide/factory/SingletonFactory.java:136

MethodgetService

(String rpcServiceName)

rpc-framework-simple/src/main/java/github/javaguide/provider/impl/ZkServiceProviderImpl.java:52

MethodgzipCompressTest

()

rpc-framework-simple/src/test/java/github/javaguide/compress/gzip/GzipCompressTest.java:13

Methodhash

(String key)

rpc-framework-simple/src/main/java/github/javaguide/loadbalance/loadbalancer/ConsistentHashLoadBalanceNew.java:237

Methodhello

(Hello hello)

example-server/src/main/java/github/javaguide/serviceimpl/HelloServiceImpl2.java:18

Methodhello

(Hello hello)

example-server/src/main/java/github/javaguide/serviceimpl/HelloServiceImpl.java:20

Methodhello

()

rpc-framework-simple/src/test/java/github/javaguide/DemoRpcServiceImpl.java:14

Methodhello

()

rpc-framework-simple/src/test/java/github/javaguide/DemoRpcService.java:4

MethodhessianSerializerTest

()

rpc-framework-simple/src/test/java/github/javaguide/serialize/hessian/HessianSerializerTest.java:12

MethodinitChannel

(SocketChannel ch)

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/client/NettyRpcClient.java:59

MethodinitChannel

(SocketChannel ch)

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/server/NettyRpcServer.java:73

MethodkryoSerializerTest

()

rpc-framework-simple/src/test/java/github/javaguide/serialize/kyro/KryoSerializerTest.java:12

Methodmain

(String[] args)

example-client/src/main/java/github/javaguide/SocketClientMain.java:13

Methodmain

(String[] args)

example-client/src/main/java/github/javaguide/NettyClientMain.java:12

Methodmain

(String[] args)

example-server/src/main/java/SocketServerMain.java:11

Methodmain

(String[] args)

example-server/src/main/java/NettyServerMain.java:16

Methodmain

(String[] args)

rpc-framework-simple/src/test/java/github/LRUCache.java:149

MethodpostProcessAfterInitialization

客户端进行rpc调用的时候，让clientProxy帮忙调用而不是真正自己进行通信调用为标注了@RpcReference注解的字段动态生成代理对象，从而实现远程服务的调用这里并不需要进行缓存，因为创建的bean实际上已经被Spring容器缓存了。也就是说，对于单例模式的Bean，这个方法只

rpc-framework-simple/src/main/java/github/javaguide/spring/SpringBeanPostProcessor.java:69

MethodpostProcessBeforeInitialization

对带有@RpcSerivce注解的类进行代理，直接将类发布到ZK上注意是在初始化之前，将类注册到zk上

rpc-framework-simple/src/main/java/github/javaguide/spring/SpringBeanPostProcessor.java:44

Methodprint

()

rpc-framework-simple/src/test/java/github/LRUCache.java:85

MethodprintThreadPoolStatus

打印线程池的状态 @param threadPool 线程池对象

rpc-framework-common/src/main/java/github/javaguide/utils/concurrent/threadpool/ThreadPoolFactoryUtil.java:99

MethodpublishService

(RpcServiceConfig rpcServiceConfig)

rpc-framework-simple/src/main/java/github/javaguide/provider/impl/ZkServiceProviderImpl.java:61

MethodregisterBeanDefinitions

(AnnotationMetadata annotationMetadata, BeanDefinitionRegistry beanDefinitionRegistry)

rpc-framework-simple/src/main/java/github/javaguide/spring/CustomScannerRegistrar.java:33

MethodregisterService

(RpcServiceConfig rpcServiceConfig)

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/server/NettyRpcServer.java:43

Methodrun

()

rpc-framework-common/src/test/java/github/javaguide/factory/SingleTonFactoryTest.java:62

Methodrun

()

rpc-framework-simple/src/test/java/github/javaguide/loadbalance/loadbalancer/ConsistentHashLoadBalanceTest.java:109

Methodrun

()

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/socket/SocketRpcRequestHandlerRunnable.java:29

MethodselectServiceAddress

(List<String> serviceAddresses, RpcRequest rpcRequest)

rpc-framework-simple/src/main/java/github/javaguide/loadbalance/AbstractLoadBalance.java:15

MethodsendRpcRequest

(RpcRequest rpcRequest)

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/socket/SocketRpcClient.java:33

MethodsendRpcRequest

(RpcRequest rpcRequest)

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/client/NettyRpcClient.java:95

Methodserialize

(Object obj)

rpc-framework-simple/src/main/java/github/javaguide/serialize/protostuff/ProtostuffSerializer.java:25

MethodsetKey

(K key)

rpc-framework-simple/src/test/java/github/LRUCache.java:37

Methodshould_register_service_successful_and_lookup_service_by_service_name

()

rpc-framework-simple/src/test/java/github/javaguide/registry/ZkServiceRegistryImplTest.java:23

Methodtest

()

rpc-framework-common/src/test/java/github/javaguide/factory/SingleTonFactoryTest.java:24

Methodtest

()

rpc-framework-common/src/test/java/github/javaguide/extention/ExtentionTest.java:15

Methodtest

()

rpc-framework-common/src/test/java/github/javaguide/extention/ExtentionTest.java:39

Methodtest

()

rpc-framework-common/src/test/java/github/javaguide/extention/ExtentionTest.java:47

MethodtestExtention

()

rpc-framework-simple/src/test/java/github/javaguide/ExtentionTest.java:17

MethoduserEventTriggered

(ChannelHandlerContext ctx, Object evt)

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/client/NettyRpcClientHandler.java:59

MethoduserEventTriggered

(ChannelHandlerContext ctx, Object evt)

rpc-framework-simple/src/main/java/github/javaguide/remoting/transport/netty/server/NettyRpcServerHandler.java:74

← previous101–187 of 187, ranked by callers