Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/anhan123456/vrpc
/ functions
Functions
182 in github.com/anhan123456/vrpc
⨍
Functions
182
◇
Types & classes
84
↓ 31 callers
Method
get
获取第一个和当前服务相关的实例 @param clazz 一个服务接口的class实例 @return 实现类的实例 @param <T>
vrpc-framework/vrpc-core/src/main/java/com/expectlost/spi/SpiHandler.java:60
↓ 16 callers
Method
getInstance
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:65
↓ 12 callers
Method
parseString
获得一个节点文本值 <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 callers
Method
getConfiguration
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:78
↓ 8 callers
Method
getCode
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/enumeration/RespCode.java:12
↓ 6 callers
Method
close
关闭zookeeper的方法 @param zooKeeper
vrpc-framework/vrpc-common/src/main/java/com/expectlost/utils/zookeeper/ZookeeperUtils.java:82
↓ 6 callers
Method
getCompressor
使用工厂方法获取一个CompressorWrapper @param compressorType 序列化的类型 @return CompressWrapper
vrpc-framework/vrpc-core/src/main/java/com/expectlost/compress/CompressorFactory.java:28
↓ 6 callers
Method
getId
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/enumeration/RequestType.java:11
↓ 6 callers
Method
getSerializer
使用工厂方法获取一个SerializerWrapper @param serializeType 序列化的类型 @return SerializerWrapper
vrpc-framework/vrpc-core/src/main/java/com/expectlost/serialize/SerializerFactory.java:34
↓ 6 callers
Method
getType
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/enumeration/RequestType.java:15
↓ 4 callers
Method
exists
存在true 不存在false @param zooKeeper @param node @param watcher @return
vrpc-framework/vrpc-common/src/main/java/com/expectlost/utils/zookeeper/ZookeeperUtils.java:99
↓ 4 callers
Method
getInterface
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/ServiceConfig.java:7
↓ 4 callers
Method
parseObject
解析一个节点,返回一个实例 @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 callers
Method
createNode
创建一个节点的方法 @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 callers
Method
createZookeeper
使用默认配置创建zookeeper实例 @return Zookeeper实例
vrpc-framework/vrpc-common/src/main/java/com/expectlost/utils/zookeeper/ZookeeperUtils.java:20
↓ 3 callers
Method
getBootstrap
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/NettyBootstrapInitializer.java:32
↓ 3 callers
Method
getList
获取所有和当前服务相关的实例 @param clazz 一个服务接口的class实例 @return 实现类的实例集合 @param <T>
vrpc-framework/vrpc-core/src/main/java/com/expectlost/spi/SpiHandler.java:87
↓ 3 callers
Method
getRegistry
使用简单工程通过coDnnectString 获取 registry @return
vrpc-framework/vrpc-core/src/main/java/com/expectlost/discovery/RegistryConfig.java:21
↓ 3 callers
Method
hash
具体的hash 算法 @param s @return
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/ConsistentHashBalancer.java:101
↓ 3 callers
Method
lookup
从注册中心拉取服务列表 @param serviceName 服务名 @return 服务地址
vrpc-framework/vrpc-core/src/main/java/com/expectlost/discovery/Registry.java:23
↓ 2 callers
Method
buildCache
构建clazz相关的缓存 @param clazz 一个类的class实例
vrpc-framework/vrpc-core/src/main/java/com/expectlost/spi/SpiHandler.java:137
↓ 2 callers
Method
compress
压缩 @param bytes @return
vrpc-framework/vrpc-core/src/main/java/com/expectlost/compress/Compressor.java:9
↓ 2 callers
Method
decompress
解压缩 @param bytes @return
vrpc-framework/vrpc-core/src/main/java/com/expectlost/compress/Compressor.java:16
↓ 2 callers
Method
deserialize
(byte[] bytes, Class<T> clazz)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/serialize/Serializer.java:8
↓ 2 callers
Method
getAllClassNames
(String packageName)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:266
↓ 2 callers
Method
getClassNameByAbsolutePath
(String absolutePath,String basePath)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:311
↓ 2 callers
Method
getRegistry
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/ReferenceConfig.java:59
↓ 2 callers
Method
getRegistryType
(String connectString,boolean ifType)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/discovery/RegistryConfig.java:35
↓ 2 callers
Method
getSelector
子类实现扩展 @param serviceList @return 负载均衡选择器
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/AbstractLoadBalancer.java:34
↓ 2 callers
Method
serialize
(Object object)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/serialize/Serializer.java:7
↓ 2 callers
Method
setInterface
(Class<?> interfaceProvider)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/ServiceConfig.java:11
↓ 2 callers
Method
setRef
(Object ref)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/ServiceConfig.java:19
↓ 2 callers
Method
start
启动netty服务
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:156
↓ 2 callers
Method
start
()
vrpc-demo/src/main/java/com/expectlost/netty/AppServer.java:19
↓ 2 callers
Method
sum
(Integer a,Integer b)
vrpc-demo/vrpc-api/src/main/java/com/expectlost/HelloVrpc.java:14
↓ 1 callers
Method
addCompressor
给工厂中新增一个压缩方式 @param compressorObjectWrapper 压缩类型的包装
vrpc-framework/vrpc-core/src/main/java/com/expectlost/compress/CompressorFactory.java:51
↓ 1 callers
Method
addNodeToCircle
将每个节点挂载到hash环上 @param inetSocketAddress
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/ConsistentHashBalancer.java:50
↓ 1 callers
Method
addSerializer
新增一个新的序列化器 @param serializerObjectWrapper 序列化器的包装
vrpc-framework/vrpc-core/src/main/java/com/expectlost/serialize/SerializerFactory.java:59
↓ 1 callers
Method
application
用来定义应用的名字 @return this
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:74
↓ 1 callers
Method
callTargetMethod
(RequestPayload requestPayload)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/handler/MethodCallHandler.java:46
↓ 1 callers
Method
decodeFrame
(ByteBuf byteBuf)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/handler/VrpcRequestDecoder.java:34
↓ 1 callers
Method
decodeFrame
(ByteBuf byteBuf)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/handler/VrpcResponseDecoder.java:33
↓ 1 callers
Method
detect
(String serviceName)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/core/HeartBeatDetector.java:25
↓ 1 callers
Method
get
(String pattern)
vrpc-framework/vrpc-common/src/main/java/com/expectlost/DateUtil.java:9
↓ 1 callers
Method
get
代理设计模式 生成一个 api接口的代理对象,代理对象调用实际走invoke函数 @return 代理对象
vrpc-framework/vrpc-core/src/main/java/com/expectlost/ReferenceConfig.java:50
↓ 1 callers
Method
getAvailableChannel
根据地址获取可用通道 @return
vrpc-framework/vrpc-core/src/main/java/com/expectlost/proxy/handler/RpcConsumerInvocationHandler.java:127
↓ 1 callers
Method
getChildren
通过传入一个服务名 获取可用节点 @param zooKeeper zk实例 @param serviceNode 服务节点 @return 子元素列表
vrpc-framework/vrpc-common/src/main/java/com/expectlost/utils/zookeeper/ZookeeperUtils.java:116
↓ 1 callers
Method
getId
()
vrpc-framework/vrpc-common/src/main/java/com/expectlost/IdGenerator.java:52
↓ 1 callers
Method
getImplNames
获取文件所有的实现名称 @param child 文件对象 @return 实现类的权限定名称结合
vrpc-framework/vrpc-core/src/main/java/com/expectlost/spi/SpiHandler.java:114
↓ 1 callers
Method
getIp
()
vrpc-framework/vrpc-common/src/main/java/com/expectlost/utils/NetUtils.java:14
↓ 1 callers
Method
getNext
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/Selector.java:7
↓ 1 callers
Method
getNextTimeStamp
()
vrpc-framework/vrpc-common/src/main/java/com/expectlost/IdGenerator.java:82
↓ 1 callers
Method
getRef
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/ServiceConfig.java:15
↓ 1 callers
Method
getSay
()
vrpc-framework/vrpc-core/src/test/java/com/expectlost/Test.java:33
↓ 1 callers
Method
getServiceName
(String path)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/watch/UpAndDownWatcher.java:66
↓ 1 callers
Method
getSocketWithMinUsage
(ConcurrentHashMap<InetSocketAddress, AtomicInteger> socketUsageMap)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/LRUBalancer.java:68
↓ 1 callers
Method
invoke
(Object proxy, Method method, Object[] args)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/proxy/handler/RpcConsumerInvocationHandler.java:42
↓ 1 callers
Method
loadFromSpi
通过spi的方式加载配置项 @param configuration 配置上下文
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/SpiResolver.java:18
↓ 1 callers
Method
loadFromXml
从配置文件读取配置信息,我们不使用dom4j,使用原生的api @param configuration 配置实例
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/XmlResolver.java:31
↓ 1 callers
Method
printAsBinary
(ByteBuf byteBuf)
vrpc-demo/src/test/java/com/expectlost/NettyTest.java:77
↓ 1 callers
Method
publish
发布服务 将接口实现注册到服务中心 @param service 封装的需要发布的服务 @return
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:132
↓ 1 callers
Method
reLoadBalance
(String serviceName, List<InetSocketAddress> addresses)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/LoadBalancer.java:14
↓ 1 callers
Method
recursionFile
(String absolutePath, List<String> classNames,String basePath)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:282
↓ 1 callers
Method
reference
(ReferenceConfig<?> reference)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:198
↓ 1 callers
Method
register
注册服务 @param serviceConfig 服务的配置内容
vrpc-framework/vrpc-core/src/main/java/com/expectlost/discovery/Registry.java:16
↓ 1 callers
Method
resolveAppName
解析应用名称 @param doc 文档 @param xpath xpath解析器 @return 应用名
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/XmlResolver.java:99
↓ 1 callers
Method
resolveCompressCompressor
解析压缩的具体实现 @param doc 文档 @param xpath xpath解析器 @return ObjectWrapper<Compressor>
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/XmlResolver.java:161
↓ 1 callers
Method
resolveCompressType
解析压缩的算法名称 @param doc 文档 @param xpath xpath解析器 @return 压缩算法名称
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/XmlResolver.java:175
↓ 1 callers
Method
resolveIdGenerator
解析id发号器 @param doc 文档 @param xpath xpath解析器 @return id发号器实例
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/XmlResolver.java:123
↓ 1 callers
Method
resolveLoadBalancer
解析负载均衡器 @param doc 文档 @param xpath xpath解析器 @return 负载均衡器实例
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/XmlResolver.java:111
↓ 1 callers
Method
resolvePort
解析端口号 @param doc 文档 @param xpath xpath解析器 @return 端口号
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/XmlResolver.java:86
↓ 1 callers
Method
resolveRegistryConfig
解析注册中心 @param doc 文档 @param xpath xpath解析器 @return RegistryConfig
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/XmlResolver.java:147
↓ 1 callers
Method
resolveSerializeType
解析序列化的方式 @param doc 文档 @param xpath xpath解析器 @return 序列化的方式
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/XmlResolver.java:186
↓ 1 callers
Method
resolveSerializer
解析序列化器 @param doc 文档 @param xpath xpath解析器 @return 序列化器
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/XmlResolver.java:197
↓ 1 callers
Method
run
()
vrpc-demo/src/main/java/com/expectlost/netty/AppClient.java:18
↓ 1 callers
Method
sayHi
通用接口 server和client都需要依赖 @param msg @return
vrpc-demo/vrpc-api/src/main/java/com/expectlost/HelloVrpc.java:11
↓ 1 callers
Method
scan
(String packageName)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:226
↓ 1 callers
Method
selectServiceAddress
根据服务名获取可用服务 @param serviceName 服务名称 @return
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/LoadBalancer.java:12
↓ 1 callers
Method
setInterface
(Class<T> interfaceRef)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/ReferenceConfig.java:40
↓ 1 callers
Method
setRegistry
(Registry registry)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/ReferenceConfig.java:63
Method
AppServer
(int port)
vrpc-demo/src/main/java/com/expectlost/netty/AppServer.java:15
Method
CompressException
()
vrpc-framework/vrpc-common/src/main/java/com/expectlost/exceptions/CompressException.java:4
Method
Configuration
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/Configuration.java:50
Method
ConsistentHashSelector
(List<InetSocketAddress> serviceList,int virtualNodes)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/ConsistentHashBalancer.java:37
Method
DiscoveryException
()
vrpc-framework/vrpc-common/src/main/java/com/expectlost/exceptions/DiscoveryException.java:7
Method
IdGenerator
(long dataCenterId, long machineId)
vrpc-framework/vrpc-common/src/main/java/com/expectlost/IdGenerator.java:43
Method
LRUSelector
(List<InetSocketAddress> serviceList)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/LRUBalancer.java:32
Method
LoadBalancerException
()
vrpc-framework/vrpc-common/src/main/java/com/expectlost/exceptions/LoadBalancerException.java:4
Method
MinumumResponseTimeSelector
(List<InetSocketAddress> serviceList)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/MinumumResponseTimeLoadBalancer.java:25
Method
NettyBootstrapInitializer
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/NettyBootstrapInitializer.java:20
Method
NetworkException
()
vrpc-framework/vrpc-common/src/main/java/com/expectlost/exceptions/NetworkException.java:9
Method
ProtocalConfig
(String protocalName)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/ProtocalConfig.java:4
Method
RandomSelector
(List<InetSocketAddress> serviceList)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/RandomBalancer.java:25
Method
RegistryConfig
(String connectString)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/discovery/RegistryConfig.java:13
Method
RequestType
(byte id, String type)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/enumeration/RequestType.java:22
Method
RespCode
(byte code, String desc)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/enumeration/RespCode.java:16
Method
RoundRobinSelector
(List<InetSocketAddress> serviceList)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/RoundRobinLoadBalancer.java:29
Method
RpcConsumerInvocationHandler
(Registry registry, Class<?> interfaceRef)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/proxy/handler/RpcConsumerInvocationHandler.java:37
Method
SerializerException
()
vrpc-framework/vrpc-common/src/main/java/com/expectlost/exceptions/SerializerException.java:7
Method
VrpcBootstrap
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:58
next →
1–100 of 182, ranked by callers