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
Method
VrpcRequestDecoder
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/handler/VrpcRequestDecoder.java:104
Method
VrpcResponseDecoder
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/handler/VrpcResponseDecoder.java:101
Method
ZookeeperRegistry
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/discovery/impl/ZookeeperRegistry.java:29
Method
channelRead
(ChannelHandlerContext ctx, Object msg)
vrpc-demo/src/main/java/com/expectlost/netty/MyChannelHandler.java:15
Method
channelRead
(ChannelHandlerContext ctx, Object msg)
vrpc-demo/src/main/java/com/expectlost/netty/MyChannelHandler2.java:14
Method
channelRead0
(ChannelHandlerContext channelHandlerContext, VrpcRequest vrpcRequest)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/handler/MethodCallHandler.java:19
Method
channelRead0
(ChannelHandlerContext channelHandlerContext, VrpcResponse response)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/handler/MySimpleChannelInBoundHandler.java:16
Method
compress
(String compressType)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:217
Method
compress
(byte[] bytes)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/compress/impl/GzipCompressor.java:16
Method
createZk
()
vrpc-demo/src/test/java/com/expectlost/ZookeeperTest.java:18
Method
decode
(ChannelHandlerContext ctx, ByteBuf in)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/handler/VrpcRequestDecoder.java:24
Method
decode
(ChannelHandlerContext ctx, ByteBuf in)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/handler/VrpcResponseDecoder.java:23
Method
decompress
(byte[] bytes)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/compress/impl/GzipCompressor.java:45
Method
deserialize
(byte[] bytes, Class<T> clazz)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/serialize/impl/HessianSerializer.java:35
Method
deserialize
(byte[] bytes, Class<T> clazz)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/serialize/impl/JdkSerializer.java:32
Method
deserialize
(byte[] bytes, Class<T> clazz)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/serialize/impl/JsonSerializer.java:24
Method
encode
(ChannelHandlerContext channelHandlerContext, VrpcRequest vrpcRequest, ByteBuf byteBuf)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/handler/VrpcRequestEncoder.java:42
Method
encode
(ChannelHandlerContext channelHandlerContext, VrpcResponse vrpcResponse, ByteBuf byteBuf)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/handler/VrpcResponseEncoder.java:40
Method
exceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
vrpc-demo/src/main/java/com/expectlost/netty/MyChannelHandler.java:24
Method
exceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
vrpc-demo/src/main/java/com/expectlost/netty/MyChannelHandler2.java:20
Method
getDesc
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/enumeration/RespCode.java:8
Method
getInterface
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/ReferenceConfig.java:36
Method
getNext
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/LRUBalancer.java:38
Method
getNext
获取可用节点 @return
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/ConsistentHashBalancer.java:73
Method
getNext
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/RandomBalancer.java:29
Method
getNext
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/MinumumResponseTimeLoadBalancer.java:29
Method
getNext
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/RoundRobinLoadBalancer.java:34
Method
getSay
()
vrpc-framework/vrpc-core/src/test/java/com/expectlost/Test.java:15
Method
getSelector
(List<InetSocketAddress> serviceList)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/LRUBalancer.java:21
Method
getSelector
(List<InetSocketAddress> serviceList)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/ConsistentHashBalancer.java:22
Method
getSelector
(List<InetSocketAddress> serviceList)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/RandomBalancer.java:17
Method
getSelector
(List<InetSocketAddress> serviceList)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/MinumumResponseTimeLoadBalancer.java:18
Method
getSelector
(List<InetSocketAddress> serviceList)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/RoundRobinLoadBalancer.java:20
Method
initChannel
(SocketChannel socketChannel)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:169
Method
initChannel
(SocketChannel socketChannel)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/ConsumerChannelInitializer.java:13
Method
initChannel
(SocketChannel socketChannel)
vrpc-demo/src/main/java/com/expectlost/netty/AppServer.java:32
Method
initChannel
(SocketChannel socketChannel)
vrpc-demo/src/main/java/com/expectlost/netty/AppClient.java:30
Method
loadBalancer
配置负载均衡策略 @param loadBalancer @return
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:100
Method
lookup
@param serviceName 服务名 @return 服务列表
vrpc-framework/vrpc-core/src/main/java/com/expectlost/discovery/impl/ZookeeperRegistry.java:67
Method
lookup
(String serviceName)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/discovery/impl/NacosRegistry.java:15
Method
main
(String[] args)
vrpc-framework/vrpc-common/src/main/java/com/expectlost/IdGenerator.java:92
Method
main
(String[] args)
vrpc-framework/vrpc-core/src/test/java/com/expectlost/Test.java:20
Method
main
(String[] args)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:322
Method
main
(String[] args)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/spi/SpiHandler.java:174
Method
main
(String[] args)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/Configuration.java:64
Method
main
(String[] args)
vrpc-demo/vrpc-consumer-demo/src/main/java/com/expectlost/ConsumerApplication.java:12
Method
main
(String[] args)
vrpc-demo/src/main/java/com/expectlost/netty/AppServer.java:56
Method
main
(String[] args)
vrpc-demo/src/main/java/com/expectlost/netty/AppClient.java:54
Method
main
(String[] args)
vrpc-demo/vrpc-provider-demo/src/main/java/com/expectlost/ProviderApplication.java:7
Method
main
(String[] args)
vrpc-manager/src/main/java/com/expectlost/Application.java:15
Method
process
(WatchedEvent watchedEvent)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/watch/UpAndDownWatcher.java:23
Method
process
(WatchedEvent event)
vrpc-demo/src/main/java/com/expectlost/netty/MyWatcher.java:7
Method
protocal
配置当前暴露的服务使用的协议 @param protocalConfig 协议封装 @return 当前实例
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:113
Method
reLoadBalance
(String serviceName, List<InetSocketAddress> addresses)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/AbstractLoadBalancer.java:14
Method
register
(ServiceConfig<?> service)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/discovery/impl/ZookeeperRegistry.java:38
Method
register
(ServiceConfig<?> serviceConfig)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/discovery/impl/NacosRegistry.java:10
Method
registry
用来配置注册中心 @return this当前实例
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:87
Method
removeNodeFromCircle
(InetSocketAddress inetSocketAddress)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/ConsistentHashBalancer.java:62
Method
run
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/core/HeartBeatDetector.java:58
Method
say
()
vrpc-framework/vrpc-core/src/test/java/com/expectlost/Test.java:30
Method
sayHi
通用接口 server和client都需要依赖 @param msg @return
vrpc-demo/vrpc-api/src/main/java/com/expectlost/HelloVrpc2.java:11
Method
sayHi
(String msg)
vrpc-demo/vrpc-provider-demo/src/main/java/com/expectlost/impl/HelloVrpcImpl.java:8
Method
sayHi
(String msg)
vrpc-demo/vrpc-provider-demo/src/main/java/com/expectlost/impl/HelloVrpcImpl2.java:9
Method
selectServiceAddress
(String serviceName)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/AbstractLoadBalancer.java:19
Method
serialize
(String serializeType)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:209
Method
serialize
(Object object)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/serialize/SerializeUtil.java:11
Method
serialize
(Object object)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/serialize/impl/HessianSerializer.java:13
Method
serialize
(Object object)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/serialize/impl/JdkSerializer.java:11
Method
serialize
(Object object)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/serialize/impl/JsonSerializer.java:14
Method
sum
(Integer a, Integer b)
vrpc-demo/vrpc-api/src/main/java/com/expectlost/HelloVrpc2.java:14
Method
sum
(Integer a, Integer b)
vrpc-demo/vrpc-provider-demo/src/main/java/com/expectlost/impl/HelloVrpcImpl.java:13
Method
sum
(Integer a, Integer b)
vrpc-demo/vrpc-provider-demo/src/main/java/com/expectlost/impl/HelloVrpcImpl2.java:14
Method
testCompositeByteBuf
()
vrpc-demo/src/test/java/com/expectlost/NettyTest.java:18
Method
testCompress
()
vrpc-demo/src/test/java/com/expectlost/NettyTest.java:93
Method
testCreatePNode
()
vrpc-demo/src/test/java/com/expectlost/ZookeeperTest.java:47
Method
testDeCompress
()
vrpc-demo/src/test/java/com/expectlost/NettyTest.java:106
Method
testDeletePNode
()
vrpc-demo/src/test/java/com/expectlost/ZookeeperTest.java:76
Method
testMessage
()
vrpc-demo/src/test/java/com/expectlost/NettyTest.java:52
Method
testSlice
()
vrpc-demo/src/test/java/com/expectlost/NettyTest.java:40
Method
testWatcher
()
vrpc-demo/src/test/java/com/expectlost/ZookeeperTest.java:106
Method
testWrapper
()
vrpc-demo/src/test/java/com/expectlost/NettyTest.java:29
Method
toBinary
(int i )
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/ConsistentHashBalancer.java:115
← previous
101–182 of 182, ranked by callers