MCPcopy Create free account

hub / github.com/anhan123456/vrpc / functions

Functions182 in github.com/anhan123456/vrpc

MethodVrpcRequestDecoder
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/handler/VrpcRequestDecoder.java:104
MethodVrpcResponseDecoder
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/handler/VrpcResponseDecoder.java:101
MethodZookeeperRegistry
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/discovery/impl/ZookeeperRegistry.java:29
MethodchannelRead
(ChannelHandlerContext ctx, Object msg)
vrpc-demo/src/main/java/com/expectlost/netty/MyChannelHandler.java:15
MethodchannelRead
(ChannelHandlerContext ctx, Object msg)
vrpc-demo/src/main/java/com/expectlost/netty/MyChannelHandler2.java:14
MethodchannelRead0
(ChannelHandlerContext channelHandlerContext, VrpcRequest vrpcRequest)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/handler/MethodCallHandler.java:19
MethodchannelRead0
(ChannelHandlerContext channelHandlerContext, VrpcResponse response)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/handler/MySimpleChannelInBoundHandler.java:16
Methodcompress
(String compressType)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:217
Methodcompress
(byte[] bytes)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/compress/impl/GzipCompressor.java:16
MethodcreateZk
()
vrpc-demo/src/test/java/com/expectlost/ZookeeperTest.java:18
Methoddecode
(ChannelHandlerContext ctx, ByteBuf in)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/handler/VrpcRequestDecoder.java:24
Methoddecode
(ChannelHandlerContext ctx, ByteBuf in)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/handler/VrpcResponseDecoder.java:23
Methoddecompress
(byte[] bytes)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/compress/impl/GzipCompressor.java:45
Methoddeserialize
(byte[] bytes, Class<T> clazz)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/serialize/impl/HessianSerializer.java:35
Methoddeserialize
(byte[] bytes, Class<T> clazz)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/serialize/impl/JdkSerializer.java:32
Methoddeserialize
(byte[] bytes, Class<T> clazz)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/serialize/impl/JsonSerializer.java:24
Methodencode
(ChannelHandlerContext channelHandlerContext, VrpcRequest vrpcRequest, ByteBuf byteBuf)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/handler/VrpcRequestEncoder.java:42
Methodencode
(ChannelHandlerContext channelHandlerContext, VrpcResponse vrpcResponse, ByteBuf byteBuf)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/handler/VrpcResponseEncoder.java:40
MethodexceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
vrpc-demo/src/main/java/com/expectlost/netty/MyChannelHandler.java:24
MethodexceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
vrpc-demo/src/main/java/com/expectlost/netty/MyChannelHandler2.java:20
MethodgetDesc
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/enumeration/RespCode.java:8
MethodgetInterface
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/ReferenceConfig.java:36
MethodgetNext
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/LRUBalancer.java:38
MethodgetNext
获取可用节点 @return
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/ConsistentHashBalancer.java:73
MethodgetNext
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/RandomBalancer.java:29
MethodgetNext
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/MinumumResponseTimeLoadBalancer.java:29
MethodgetNext
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/RoundRobinLoadBalancer.java:34
MethodgetSay
()
vrpc-framework/vrpc-core/src/test/java/com/expectlost/Test.java:15
MethodgetSelector
(List<InetSocketAddress> serviceList)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/LRUBalancer.java:21
MethodgetSelector
(List<InetSocketAddress> serviceList)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/ConsistentHashBalancer.java:22
MethodgetSelector
(List<InetSocketAddress> serviceList)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/RandomBalancer.java:17
MethodgetSelector
(List<InetSocketAddress> serviceList)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/MinumumResponseTimeLoadBalancer.java:18
MethodgetSelector
(List<InetSocketAddress> serviceList)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/RoundRobinLoadBalancer.java:20
MethodinitChannel
(SocketChannel socketChannel)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:169
MethodinitChannel
(SocketChannel socketChannel)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/channelHandler/ConsumerChannelInitializer.java:13
MethodinitChannel
(SocketChannel socketChannel)
vrpc-demo/src/main/java/com/expectlost/netty/AppServer.java:32
MethodinitChannel
(SocketChannel socketChannel)
vrpc-demo/src/main/java/com/expectlost/netty/AppClient.java:30
MethodloadBalancer
配置负载均衡策略 @param loadBalancer @return
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:100
Methodlookup
@param serviceName 服务名 @return 服务列表
vrpc-framework/vrpc-core/src/main/java/com/expectlost/discovery/impl/ZookeeperRegistry.java:67
Methodlookup
(String serviceName)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/discovery/impl/NacosRegistry.java:15
Methodmain
(String[] args)
vrpc-framework/vrpc-common/src/main/java/com/expectlost/IdGenerator.java:92
Methodmain
(String[] args)
vrpc-framework/vrpc-core/src/test/java/com/expectlost/Test.java:20
Methodmain
(String[] args)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:322
Methodmain
(String[] args)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/spi/SpiHandler.java:174
Methodmain
(String[] args)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/config/Configuration.java:64
Methodmain
(String[] args)
vrpc-demo/vrpc-consumer-demo/src/main/java/com/expectlost/ConsumerApplication.java:12
Methodmain
(String[] args)
vrpc-demo/src/main/java/com/expectlost/netty/AppServer.java:56
Methodmain
(String[] args)
vrpc-demo/src/main/java/com/expectlost/netty/AppClient.java:54
Methodmain
(String[] args)
vrpc-demo/vrpc-provider-demo/src/main/java/com/expectlost/ProviderApplication.java:7
Methodmain
(String[] args)
vrpc-manager/src/main/java/com/expectlost/Application.java:15
Methodprocess
(WatchedEvent watchedEvent)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/watch/UpAndDownWatcher.java:23
Methodprocess
(WatchedEvent event)
vrpc-demo/src/main/java/com/expectlost/netty/MyWatcher.java:7
Methodprotocal
配置当前暴露的服务使用的协议 @param protocalConfig 协议封装 @return 当前实例
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:113
MethodreLoadBalance
(String serviceName, List<InetSocketAddress> addresses)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/AbstractLoadBalancer.java:14
Methodregister
(ServiceConfig<?> service)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/discovery/impl/ZookeeperRegistry.java:38
Methodregister
(ServiceConfig<?> serviceConfig)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/discovery/impl/NacosRegistry.java:10
Methodregistry
用来配置注册中心 @return this当前实例
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:87
MethodremoveNodeFromCircle
(InetSocketAddress inetSocketAddress)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/ConsistentHashBalancer.java:62
Methodrun
()
vrpc-framework/vrpc-core/src/main/java/com/expectlost/core/HeartBeatDetector.java:58
Methodsay
()
vrpc-framework/vrpc-core/src/test/java/com/expectlost/Test.java:30
MethodsayHi
通用接口 server和client都需要依赖 @param msg @return
vrpc-demo/vrpc-api/src/main/java/com/expectlost/HelloVrpc2.java:11
MethodsayHi
(String msg)
vrpc-demo/vrpc-provider-demo/src/main/java/com/expectlost/impl/HelloVrpcImpl.java:8
MethodsayHi
(String msg)
vrpc-demo/vrpc-provider-demo/src/main/java/com/expectlost/impl/HelloVrpcImpl2.java:9
MethodselectServiceAddress
(String serviceName)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/AbstractLoadBalancer.java:19
Methodserialize
(String serializeType)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/VrpcBootstrap.java:209
Methodserialize
(Object object)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/serialize/SerializeUtil.java:11
Methodserialize
(Object object)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/serialize/impl/HessianSerializer.java:13
Methodserialize
(Object object)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/serialize/impl/JdkSerializer.java:11
Methodserialize
(Object object)
vrpc-framework/vrpc-core/src/main/java/com/expectlost/serialize/impl/JsonSerializer.java:14
Methodsum
(Integer a, Integer b)
vrpc-demo/vrpc-api/src/main/java/com/expectlost/HelloVrpc2.java:14
Methodsum
(Integer a, Integer b)
vrpc-demo/vrpc-provider-demo/src/main/java/com/expectlost/impl/HelloVrpcImpl.java:13
Methodsum
(Integer a, Integer b)
vrpc-demo/vrpc-provider-demo/src/main/java/com/expectlost/impl/HelloVrpcImpl2.java:14
MethodtestCompositeByteBuf
()
vrpc-demo/src/test/java/com/expectlost/NettyTest.java:18
MethodtestCompress
()
vrpc-demo/src/test/java/com/expectlost/NettyTest.java:93
MethodtestCreatePNode
()
vrpc-demo/src/test/java/com/expectlost/ZookeeperTest.java:47
MethodtestDeCompress
()
vrpc-demo/src/test/java/com/expectlost/NettyTest.java:106
MethodtestDeletePNode
()
vrpc-demo/src/test/java/com/expectlost/ZookeeperTest.java:76
MethodtestMessage
()
vrpc-demo/src/test/java/com/expectlost/NettyTest.java:52
MethodtestSlice
()
vrpc-demo/src/test/java/com/expectlost/NettyTest.java:40
MethodtestWatcher
()
vrpc-demo/src/test/java/com/expectlost/ZookeeperTest.java:106
MethodtestWrapper
()
vrpc-demo/src/test/java/com/expectlost/NettyTest.java:29
MethodtoBinary
(int i )
vrpc-framework/vrpc-core/src/main/java/com/expectlost/loadbalancer/impl/ConsistentHashBalancer.java:115
← previous101–182 of 182, ranked by callers