MCPcopy Create free account

hub / github.com/anhan123456/vrpc / functions

Functions182 in github.com/anhan123456/vrpc

↓ 31 callersMethodget
获取第一个和当前服务相关的实例 @param clazz 一个服务接口的class实例 @return 实现类的实例 @param <T>
vrpc-framework/vrpc-core/src/main/java/com/expectlost/spi/SpiHandler.java:60
↓ 16 callersMethodgetInstance
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:65
↓ 12 callersMethodparseString
获得一个节点文本值 <port>7777</> @param doc 文档对象 @param xpath xpath解析器 @param expression xpath表达式 @return 节点的值
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/XmlResolver.java:213
↓ 10 callersMethodgetConfiguration
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:78
↓ 8 callersMethodgetCode
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/enumeration/RespCode.java:12
↓ 6 callersMethodclose
关闭zookeeper的方法 @param zooKeeper
vrpc-framework/vrpc-common/src/main/java/com/expectlost/utils/zookeeper/ZookeeperUtils.java:82
↓ 6 callersMethodgetCompressor
使用工厂方法获取一个CompressorWrapper @param compressorType 序列化的类型 @return CompressWrapper
vrpc-framework/vrpc-core/src/main/java/com/expectlost/compress/CompressorFactory.java:28
↓ 6 callersMethodgetId
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/enumeration/RequestType.java:11
↓ 6 callersMethodgetSerializer
使用工厂方法获取一个SerializerWrapper @param serializeType 序列化的类型 @return SerializerWrapper
vrpc-framework/vrpc-core/src/main/java/com/expectlost/serialize/SerializerFactory.java:34
↓ 6 callersMethodgetType
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/enumeration/RequestType.java:15
↓ 4 callersMethodexists
存在true 不存在false @param zooKeeper @param node @param watcher @return
vrpc-framework/vrpc-common/src/main/java/com/expectlost/utils/zookeeper/ZookeeperUtils.java:99
↓ 4 callersMethodgetInterface
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/ServiceConfig.java:7
↓ 4 callersMethodparseObject
解析一个节点,返回一个实例 @param doc 文档对象 @param xpath xpath解析器 @param expression xpath表达式 @param paramType 参数列表 @param param 参数 @param <T>
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/XmlResolver.java:256
↓ 3 callersMethodcreateNode
创建一个节点的方法 @param zooKeeper zookeeper实例 @param node zookeeper节点 @param watcher watcher @param createMode 节点模式 @return 节点创建结果
vrpc-framework/vrpc-common/src/main/java/com/expectlost/utils/zookeeper/ZookeeperUtils.java:53
↓ 3 callersMethodcreateZookeeper
使用默认配置创建zookeeper实例 @return Zookeeper实例
vrpc-framework/vrpc-common/src/main/java/com/expectlost/utils/zookeeper/ZookeeperUtils.java:20
↓ 3 callersMethodgetBootstrap
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/NettyBootstrapInitializer.java:32
↓ 3 callersMethodgetList
获取所有和当前服务相关的实例 @param clazz 一个服务接口的class实例 @return 实现类的实例集合 @param <T>
vrpc-framework/vrpc-core/src/main/java/com/expectlost/spi/SpiHandler.java:87
↓ 3 callersMethodgetRegistry
使用简单工程通过coDnnectString 获取 registry @return
vrpc-framework/vrpc-core/src/main/java/com/expectlost/discovery/RegistryConfig.java:21
↓ 3 callersMethodhash
具体的hash 算法 @param s @return
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/ConsistentHashBalancer.java:101
↓ 3 callersMethodlookup
从注册中心拉取服务列表 @param serviceName 服务名 @return 服务地址
vrpc-framework/vrpc-core/src/main/java/com/expectlost/discovery/Registry.java:23
↓ 2 callersMethodbuildCache
构建clazz相关的缓存 @param clazz 一个类的class实例
vrpc-framework/vrpc-core/src/main/java/com/expectlost/spi/SpiHandler.java:137
↓ 2 callersMethodcompress
压缩 @param bytes @return
vrpc-framework/vrpc-core/src/main/java/com/expectlost/compress/Compressor.java:9
↓ 2 callersMethoddecompress
解压缩 @param bytes @return
vrpc-framework/vrpc-core/src/main/java/com/expectlost/compress/Compressor.java:16
↓ 2 callersMethoddeserialize
(byte[] bytes, Class<T> clazz)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/serialize/Serializer.java:8
↓ 2 callersMethodgetAllClassNames
(String packageName)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:266
↓ 2 callersMethodgetClassNameByAbsolutePath
(String absolutePath,String basePath)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:311
↓ 2 callersMethodgetRegistry
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/ReferenceConfig.java:59
↓ 2 callersMethodgetRegistryType
(String connectString,boolean ifType)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/discovery/RegistryConfig.java:35
↓ 2 callersMethodgetSelector
子类实现扩展 @param serviceList @return 负载均衡选择器
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/AbstractLoadBalancer.java:34
↓ 2 callersMethodserialize
(Object object)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/serialize/Serializer.java:7
↓ 2 callersMethodsetInterface
(Class<?> interfaceProvider)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/ServiceConfig.java:11
↓ 2 callersMethodsetRef
(Object ref)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/ServiceConfig.java:19
↓ 2 callersMethodstart
启动netty服务
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:156
↓ 2 callersMethodstart
()
vrpc-demo/src/main/java/com/expectlost/netty/AppServer.java:19
↓ 2 callersMethodsum
(Integer a,Integer b)
vrpc-demo/vrpc-api/src/main/java/com/expectlost/HelloVrpc.java:14
↓ 1 callersMethodaddCompressor
给工厂中新增一个压缩方式 @param compressorObjectWrapper 压缩类型的包装
vrpc-framework/vrpc-core/src/main/java/com/expectlost/compress/CompressorFactory.java:51
↓ 1 callersMethodaddNodeToCircle
将每个节点挂载到hash环上 @param inetSocketAddress
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/ConsistentHashBalancer.java:50
↓ 1 callersMethodaddSerializer
新增一个新的序列化器 @param serializerObjectWrapper 序列化器的包装
vrpc-framework/vrpc-core/src/main/java/com/expectlost/serialize/SerializerFactory.java:59
↓ 1 callersMethodapplication
用来定义应用的名字 @return this
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:74
↓ 1 callersMethodcallTargetMethod
(RequestPayload requestPayload)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/handler/MethodCallHandler.java:46
↓ 1 callersMethoddecodeFrame
(ByteBuf byteBuf)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/handler/VrpcRequestDecoder.java:34
↓ 1 callersMethoddecodeFrame
(ByteBuf byteBuf)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/handler/VrpcResponseDecoder.java:33
↓ 1 callersMethoddetect
(String serviceName)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/core/HeartBeatDetector.java:25
↓ 1 callersMethodget
(String pattern)
vrpc-framework/vrpc-common/src/main/java/com/expectlost/DateUtil.java:9
↓ 1 callersMethodget
代理设计模式 生成一个 api接口的代理对象,代理对象调用实际走invoke函数 @return 代理对象
vrpc-framework/vrpc-core/src/main/java/com/expectlost/ReferenceConfig.java:50
↓ 1 callersMethodgetAvailableChannel
根据地址获取可用通道 @return
vrpc-framework/vrpc-core/src/main/java/com/expectlost/proxy/handler/RpcConsumerInvocationHandler.java:127
↓ 1 callersMethodgetChildren
通过传入一个服务名 获取可用节点 @param zooKeeper zk实例 @param serviceNode 服务节点 @return 子元素列表
vrpc-framework/vrpc-common/src/main/java/com/expectlost/utils/zookeeper/ZookeeperUtils.java:116
↓ 1 callersMethodgetId
()
vrpc-framework/vrpc-common/src/main/java/com/expectlost/IdGenerator.java:52
↓ 1 callersMethodgetImplNames
获取文件所有的实现名称 @param child 文件对象 @return 实现类的权限定名称结合
vrpc-framework/vrpc-core/src/main/java/com/expectlost/spi/SpiHandler.java:114
↓ 1 callersMethodgetIp
()
vrpc-framework/vrpc-common/src/main/java/com/expectlost/utils/NetUtils.java:14
↓ 1 callersMethodgetNext
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/Selector.java:7
↓ 1 callersMethodgetNextTimeStamp
()
vrpc-framework/vrpc-common/src/main/java/com/expectlost/IdGenerator.java:82
↓ 1 callersMethodgetRef
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/ServiceConfig.java:15
↓ 1 callersMethodgetSay
()
vrpc-framework/vrpc-core/src/test/java/com/expectlost/Test.java:33
↓ 1 callersMethodgetServiceName
(String path)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/watch/UpAndDownWatcher.java:66
↓ 1 callersMethodgetSocketWithMinUsage
(ConcurrentHashMap<InetSocketAddress, AtomicInteger> socketUsageMap)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/LRUBalancer.java:68
↓ 1 callersMethodinvoke
(Object proxy, Method method, Object[] args)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/proxy/handler/RpcConsumerInvocationHandler.java:42
↓ 1 callersMethodloadFromSpi
通过spi的方式加载配置项 @param configuration 配置上下文
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/SpiResolver.java:18
↓ 1 callersMethodloadFromXml
从配置文件读取配置信息,我们不使用dom4j,使用原生的api @param configuration 配置实例
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/XmlResolver.java:31
↓ 1 callersMethodprintAsBinary
(ByteBuf byteBuf)
vrpc-demo/src/test/java/com/expectlost/NettyTest.java:77
↓ 1 callersMethodpublish
发布服务 将接口实现注册到服务中心 @param service 封装的需要发布的服务 @return
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:132
↓ 1 callersMethodreLoadBalance
(String serviceName, List<InetSocketAddress> addresses)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/LoadBalancer.java:14
↓ 1 callersMethodrecursionFile
(String absolutePath, List<String> classNames,String basePath)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:282
↓ 1 callersMethodreference
(ReferenceConfig<?> reference)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:198
↓ 1 callersMethodregister
注册服务 @param serviceConfig 服务的配置内容
vrpc-framework/vrpc-core/src/main/java/com/expectlost/discovery/Registry.java:16
↓ 1 callersMethodresolveAppName
解析应用名称 @param doc 文档 @param xpath xpath解析器 @return 应用名
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/XmlResolver.java:99
↓ 1 callersMethodresolveCompressCompressor
解析压缩的具体实现 @param doc 文档 @param xpath xpath解析器 @return ObjectWrapper<Compressor>
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/XmlResolver.java:161
↓ 1 callersMethodresolveCompressType
解析压缩的算法名称 @param doc 文档 @param xpath xpath解析器 @return 压缩算法名称
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/XmlResolver.java:175
↓ 1 callersMethodresolveIdGenerator
解析id发号器 @param doc 文档 @param xpath xpath解析器 @return id发号器实例
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/XmlResolver.java:123
↓ 1 callersMethodresolveLoadBalancer
解析负载均衡器 @param doc 文档 @param xpath xpath解析器 @return 负载均衡器实例
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/XmlResolver.java:111
↓ 1 callersMethodresolvePort
解析端口号 @param doc 文档 @param xpath xpath解析器 @return 端口号
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/XmlResolver.java:86
↓ 1 callersMethodresolveRegistryConfig
解析注册中心 @param doc 文档 @param xpath xpath解析器 @return RegistryConfig
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/XmlResolver.java:147
↓ 1 callersMethodresolveSerializeType
解析序列化的方式 @param doc 文档 @param xpath xpath解析器 @return 序列化的方式
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/XmlResolver.java:186
↓ 1 callersMethodresolveSerializer
解析序列化器 @param doc 文档 @param xpath xpath解析器 @return 序列化器
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/XmlResolver.java:197
↓ 1 callersMethodrun
()
vrpc-demo/src/main/java/com/expectlost/netty/AppClient.java:18
↓ 1 callersMethodsayHi
通用接口 server和client都需要依赖 @param msg @return
vrpc-demo/vrpc-api/src/main/java/com/expectlost/HelloVrpc.java:11
↓ 1 callersMethodscan
(String packageName)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:226
↓ 1 callersMethodselectServiceAddress
根据服务名获取可用服务 @param serviceName 服务名称 @return
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/LoadBalancer.java:12
↓ 1 callersMethodsetInterface
(Class<T> interfaceRef)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/ReferenceConfig.java:40
↓ 1 callersMethodsetRegistry
(Registry registry)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/ReferenceConfig.java:63
MethodAppServer
(int port)
vrpc-demo/src/main/java/com/expectlost/netty/AppServer.java:15
MethodCompressException
()
vrpc-framework/vrpc-common/src/main/java/com/expectlost/exceptions/CompressException.java:4
MethodConfiguration
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/Configuration.java:50
MethodConsistentHashSelector
(List<InetSocketAddress> serviceList,int virtualNodes)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/ConsistentHashBalancer.java:37
MethodDiscoveryException
()
vrpc-framework/vrpc-common/src/main/java/com/expectlost/exceptions/DiscoveryException.java:7
MethodIdGenerator
(long dataCenterId, long machineId)
vrpc-framework/vrpc-common/src/main/java/com/expectlost/IdGenerator.java:43
MethodLRUSelector
(List<InetSocketAddress> serviceList)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/LRUBalancer.java:32
MethodLoadBalancerException
()
vrpc-framework/vrpc-common/src/main/java/com/expectlost/exceptions/LoadBalancerException.java:4
MethodMinumumResponseTimeSelector
(List<InetSocketAddress> serviceList)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/MinumumResponseTimeLoadBalancer.java:25
MethodNettyBootstrapInitializer
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/NettyBootstrapInitializer.java:20
MethodNetworkException
()
vrpc-framework/vrpc-common/src/main/java/com/expectlost/exceptions/NetworkException.java:9
MethodProtocalConfig
(String protocalName)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/ProtocalConfig.java:4
MethodRandomSelector
(List<InetSocketAddress> serviceList)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/RandomBalancer.java:25
MethodRegistryConfig
(String connectString)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/discovery/RegistryConfig.java:13
MethodRequestType
(byte id, String type)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/enumeration/RequestType.java:22
MethodRespCode
(byte code, String desc)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/enumeration/RespCode.java:16
MethodRoundRobinSelector
(List<InetSocketAddress> serviceList)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/RoundRobinLoadBalancer.java:29
MethodRpcConsumerInvocationHandler
(Registry registry, Class<?> interfaceRef)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/proxy/handler/RpcConsumerInvocationHandler.java:37
MethodSerializerException
()
vrpc-framework/vrpc-common/src/main/java/com/expectlost/exceptions/SerializerException.java:7
MethodVrpcBootstrap
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:58
next →1–100 of 182, ranked by callers