Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/DreamOfTheRedChamber/system-design-interviews
/ functions
Functions
297 in github.com/DreamOfTheRedChamber/system-design-interviews
⨍
Functions
297
◇
Types & classes
125
↓ 71 callers
Method
start
(RequestHandlerRegistry requestHandlerRegistry, int port)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/TransportServer.java:21
↓ 21 callers
Method
join
( )
code/multithreads/basics/conditionVariable/ConditionVariableWithReentrantLock.java:45
↓ 19 callers
Method
get
(int type)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/RequestHandlerRegistry.java:48
↓ 16 callers
Method
put
()
code/multithreads/ObjectMethods/ProducerConsumerWithWaitNotify.java:66
↓ 13 callers
Method
size
计算对象序列化后的长度,主要用于申请存放序列化数据的字节数组 @param entry 待序列化的对象 @return 对象序列化后的长度
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/serialize/Serializer.java:22
↓ 12 callers
Method
put
(ResponseFuture responseFuture)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/InFlightRequests.java:40
↓ 9 callers
Method
getHeader
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/command/Command.java:28
↓ 9 callers
Method
take
()
code/multithreads/ObjectMethods/ProducerConsumerWithWaitNotify.java:80
↓ 8 callers
Method
close
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/TransportClient.java:28
↓ 8 callers
Method
getRequestId
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/command/Header.java:31
↓ 7 callers
Method
load
(Class<S> service)
code/simple-rpc-framework-master/rpc-api/src/main/java/com/github/liyue2008/rpc/spi/ServiceSupport.java:30
↓ 6 callers
Method
length
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/command/Header.java:51
↓ 5 callers
Method
print
( String s )
code/multithreads/basics/conditionVariable/ConditionVariableWithReentrantLock.java:64
↓ 4 callers
Method
getCode
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/command/ResponseHeader.java:49
↓ 4 callers
Method
getInterfaceName
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/client/stubs/RpcRequest.java:31
↓ 4 callers
Method
getMethodName
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/client/stubs/RpcRequest.java:35
↓ 4 callers
Method
getPayload
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/command/Command.java:36
↓ 4 callers
Method
getVersion
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/command/Header.java:39
↓ 4 callers
Method
parse
(byte [] buffer, int offset, int length, Class<E> eClass)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/serialize/SerializeSupport.java:48
↓ 4 callers
Method
remove
(int requestId)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/InFlightRequests.java:59
↓ 4 callers
Method
toShortSafely
(int v)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/serialize/impl/MetadataSerializer.java:124
↓ 3 callers
Method
getCode
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/command/Code.java:48
↓ 3 callers
Method
getError
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/command/ResponseHeader.java:57
↓ 3 callers
Method
getSerializedArguments
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/client/stubs/RpcRequest.java:39
↓ 3 callers
Method
getType
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/command/Header.java:47
↓ 3 callers
Method
print
( String s)
code/multithreads/basics/conditionVariable/ConditionVariableWithSynchronizedKeyWord.java:53
↓ 3 callers
Method
serialize
(E entry)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/serialize/SerializeSupport.java:73
↓ 3 callers
Method
toString
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/nameservice/Metadata.java:27
↓ 3 callers
Method
type
用一个字节标识对象类型,每种类型的数据应该具有不同的类型值
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/serialize/Serializer.java:45
↓ 3 callers
Method
type
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/server/RpcRequestHandler.java:67
↓ 2 callers
Method
bar
()
code/multithreads/basics/mutex/SynchronizedReentrant.java:22
↓ 2 callers
Method
firstThread
()
code/multithreads/basics/reentrantlock/ReentrantLockHelloWorld.java:37
↓ 2 callers
Method
foo
()
code/multithreads/basics/mutex/SynchronizedObjectsClassLevel.java:27
↓ 2 callers
Method
foo
()
code/multithreads/basics/mutex/SynchronizedObjectsInstanceLevel.java:13
↓ 2 callers
Method
getMessage
(Object... args)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/command/Code.java:52
↓ 2 callers
Method
getNameService
获取注册中心的引用 @param nameServiceUri 注册中心URI @return 注册中心引用
code/simple-rpc-framework-master/rpc-api/src/main/java/com/github/liyue2008/rpc/RpcAccessPoint.java:51
↓ 2 callers
Method
getSerializeClass
返回序列化对象类型的Class对象。
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/serialize/Serializer.java:50
↓ 2 callers
Method
increment
()
code/multithreads/basics/reentrantlock/ReentrantLockHelloWorld.java:30
↓ 2 callers
Method
loadAll
(Class<S> service)
code/simple-rpc-framework-master/rpc-api/src/main/java/com/github/liyue2008/rpc/spi/ServiceSupport.java:36
↓ 2 callers
Method
newEventLoopGroup
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/NettyServer.java:80
↓ 2 callers
Method
stop
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/TransportServer.java:22
↓ 2 callers
Method
type
支持的请求类型
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/RequestHandler.java:34
↓ 1 callers
Method
addServiceProvider
服务端注册服务的实现实例 @param service 实现实例 @param serviceClass 服务的接口类的Class @param <T> 服务接口的类型 @return 服务地址
code/simple-rpc-framework-master/rpc-api/src/main/java/com/github/liyue2008/rpc/RpcAccessPoint.java:44
↓ 1 callers
Method
addServiceProvider
(Class<? extends T> serviceClass, T serviceProvider)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/server/ServiceProviderRegistry.java:21
↓ 1 callers
Method
bar
()
code/multithreads/basics/mutex/SynchronizedObjectsClassLevel.java:44
↓ 1 callers
Method
bar
()
code/multithreads/basics/mutex/SynchronizedClassObjectClassLevel.java:26
↓ 1 callers
Method
bar
()
code/multithreads/basics/mutex/SynchronizedMethods.java:36
↓ 1 callers
Method
bar
()
code/multithreads/basics/mutex/SynchronizedCodeBlocks.java:18
↓ 1 callers
Method
bar
()
code/multithreads/basics/mutex/SynchronizedObjectsInstanceLevel.java:30
↓ 1 callers
Method
connect
连接注册中心 @param nameServiceUri 注册中心地址
code/simple-rpc-framework-master/rpc-api/src/main/java/com/github/liyue2008/rpc/NameService.java:36
↓ 1 callers
Method
consume
()
code/multithreads/basics/reentrantlock/ReentrantLockProducerConsumer.java:27
↓ 1 callers
Method
consume
()
code/multithreads/basics/conditionVariable/WaitNotifyHelloWorld.java:14
↓ 1 callers
Method
consume
()
code/multithreads/basics/conditionVariable/WaitNotifyProducerConsumer.java:39
↓ 1 callers
Method
createChannel
(SocketAddress address, long connectionTimeout)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/NettyClient.java:66
↓ 1 callers
Method
createStub
(Transport transport, Class<T> serviceClass)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/client/StubFactory.java:23
↓ 1 callers
Method
createTransport
(SocketAddress address, long connectionTimeout)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/TransportClient.java:27
↓ 1 callers
Method
decodeHeader
(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/CommandDecoder.java:50
↓ 1 callers
Method
doBind
(ServerBootstrap serverBootstrap)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/NettyServer.java:74
↓ 1 callers
Method
doWork
()
code/multithreads/basics/concurrencyLibrary/CountDownLatches.java:46
↓ 1 callers
Method
doWork
()
code/multithreads/basics/concurrencyLibrary/CyclicBarriers.java:55
↓ 1 callers
Method
download
()
code/multithreads/basics/semaphore/DownloadRateLimiter.java:40
↓ 1 callers
Method
downloadData
()
code/multithreads/basics/semaphore/DownloadRateLimiter.java:23
↓ 1 callers
Method
encodeHeader
(ChannelHandlerContext channelHandlerContext, Header header, ByteBuf byteBuf)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/CommandEncoder.java:42
↓ 1 callers
Method
finish
()
code/multithreads/basics/terminateThread/TerminateThread.java:34
↓ 1 callers
Method
foo
()
code/multithreads/basics/mutex/SynchronizedClassObjectClassLevel.java:11
↓ 1 callers
Method
foo
()
code/multithreads/basics/mutex/SynchronizedMethods.java:22
↓ 1 callers
Method
foo
()
code/multithreads/basics/mutex/SynchronizedReentrant.java:9
↓ 1 callers
Method
foo
()
code/multithreads/basics/mutex/SynchronizedCodeBlocks.java:9
↓ 1 callers
Method
foobar
()
code/multithreads/basics/mutex/SynchronizedClassObjectClassLevel.java:34
↓ 1 callers
Method
foobar
()
code/multithreads/basics/mutex/SynchronizedMethods.java:42
↓ 1 callers
Method
getFuture
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/ResponseFuture.java:39
↓ 1 callers
Method
getInstance
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/RequestHandlerRegistry.java:32
↓ 1 callers
Method
getRemoteService
客户端获取远程服务的引用 @param uri 远程服务地址 @param serviceClass 服务的接口类的Class @param <T> 服务接口的类型 @return 远程服务引用
code/simple-rpc-framework-master/rpc-api/src/main/java/com/github/liyue2008/rpc/RpcAccessPoint.java:35
↓ 1 callers
Method
getTimestamp
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/ResponseFuture.java:43
↓ 1 callers
Method
handle
处理请求 @param requestCommand 请求命令 @return 响应命令
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/RequestHandler.java:29
↓ 1 callers
Method
hello
(String name)
code/simple-rpc-framework-master/hello-service-api/src/main/java/com/github/liyue2008/rpc/hello/HelloService.java:21
↓ 1 callers
Method
increase
()
code/multithreads/basics/volatileKeyword/MultipleWriters.java:12
↓ 1 callers
Method
increase
()
code/multithreads/basics/atomic/AtomicTest.java:14
↓ 1 callers
Method
join
( )
code/multithreads/basics/conditionVariable/ConditionVariableWithSynchronizedKeyWord.java:40
↓ 1 callers
Method
lookupService
查询服务地址 @param serviceName 服务名称 @return 服务地址
code/simple-rpc-framework-master/rpc-api/src/main/java/com/github/liyue2008/rpc/NameService.java:49
↓ 1 callers
Method
needMoreNums
()
code/multithreads/StopThreads/WrongWays/InterruptedAlwaysSucceed.java:68
↓ 1 callers
Method
needMoreNums
()
code/multithreads/StopThreads/WrongWays/VolatileUnluckyCase.java:75
↓ 1 callers
Method
newBootstrap
(ChannelHandler channelHandler, EventLoopGroup ioEventGroup)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/NettyClient.java:52
↓ 1 callers
Method
newBootstrap
(ChannelHandler channelHandler, EventLoopGroup acceptEventGroup, EventLoopGroup ioEventGroup)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/NettyServer.java:100
↓ 1 callers
Method
newChannelHandlerPipeline
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/NettyClient.java:90
↓ 1 callers
Method
newChannelHandlerPipeline
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/NettyServer.java:88
↓ 1 callers
Method
newIoEventGroup
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/netty/NettyClient.java:102
↓ 1 callers
Method
next
()
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/client/RequestIdSupport.java:24
↓ 1 callers
Method
parse
反序列化对象 @param bytes 存放序列化数据的字节数组 @param offset 数组的偏移量,从这个位置开始写入序列化数据 @param length 对象序列化后的长度 @return 反序列化之后生成的对象
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/serialize/Serializer.java:40
↓ 1 callers
Method
parseEntryType
(byte[] buffer)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/serialize/SerializeSupport.java:41
↓ 1 callers
Method
produce
()
code/multithreads/basics/reentrantlock/ReentrantLockProducerConsumer.java:19
↓ 1 callers
Method
produce
()
code/multithreads/basics/conditionVariable/WaitNotifyHelloWorld.java:5
↓ 1 callers
Method
produce
()
code/multithreads/basics/conditionVariable/WaitNotifyProducerConsumer.java:13
↓ 1 callers
Method
reInterrupt
()
code/multithreads/StopThreads/Behaviors/RestoreInterruptFlagBeingClearedbyTryCatch.java:21
↓ 1 callers
Method
registerService
注册服务 @param serviceName 服务名称 @param uri 服务地址
code/simple-rpc-framework-master/rpc-api/src/main/java/com/github/liyue2008/rpc/NameService.java:42
↓ 1 callers
Method
registerType
(byte type, Class<E> eClass, Serializer<E> serializer)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/serialize/SerializeSupport.java:44
↓ 1 callers
Method
send
发送请求命令 @param request 请求命令 @return 返回值是一个Future,Future
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/transport/Transport.java:30
↓ 1 callers
Method
serialize
序列化对象。将给定的对象序列化成字节数组 @param entry 待序列化的对象 @param bytes 存放序列化数据的字节数组 @param offset 数组的偏移量,从这个位置开始写入序列化数据 @param length 对象序列化后的长度,也就是{@link Serializer#s
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/serialize/Serializer.java:31
↓ 1 callers
Method
setTransport
(Transport transport)
code/simple-rpc-framework-master/rpc-netty/src/main/java/com/github/liyue2008/rpc/client/ServiceStub.java:23
↓ 1 callers
Method
start
()
code/multithreads/basics/conditionVariable/ConditionVariableWithSynchronizedKeyWord.java:14
next →
1–100 of 297, ranked by callers