Functions — github.com/PPPHUANG/rpc-spring-starter

hub / github.com/PPPHUANG/rpc-spring-starter / functions

Functions403 in github.com/PPPHUANG/rpc-spring-starter

⨍ Functions 403◇ Types & classes 85

↓ 1 callersMethodgetCompresser

()

src/main/java/cn/ppphuang/rpcspringstarter/server/handler/RequestBaseHandler.java:83

↓ 1 callersMethodgetDefaultRpcProcessor

(String name)

src/main/java/cn/ppphuang/rpcspringstarter/config/RpcAutoConfiguration.java:167

↓ 1 callersMethodgetExtensionClasses

()

src/main/java/cn/ppphuang/rpcspringstarter/common/extension/ExtensionLoader.java:113

↓ 1 callersMethodgetNettyChannelPoolMaxConnections

()

src/main/java/cn/ppphuang/rpcspringstarter/properties/RpcConfig.java:154

↓ 1 callersMethodgetParaName

(Type type, Class<?> clazz)

src/main/java/cn/ppphuang/rpcspringstarter/server/ProxyFactory.java:272

↓ 1 callersMethodgetProtocol

()

src/main/java/cn/ppphuang/rpcspringstarter/server/RpcServer.java:53

↓ 1 callersMethodgetProtocol

()

src/main/java/cn/ppphuang/rpcspringstarter/common/model/RpcMessage.java:33

↓ 1 callersMethodgetRequestHandler

(String name)

src/main/java/cn/ppphuang/rpcspringstarter/config/RpcAutoConfiguration.java:155

↓ 1 callersMethodgetRpcStatus

()

src/main/java/cn/ppphuang/rpcspringstarter/common/model/RpcResponse.java:127

↓ 1 callersMethodgetService

(ServiceObject so)

src/main/java/cn/ppphuang/rpcspringstarter/server/register/ZookeeperServerRegister.java:47

↓ 1 callersMethodgetServiceList

(String serviceName)

src/main/java/cn/ppphuang/rpcspringstarter/client/net/ClientProxyFactory.java:125

↓ 1 callersMethodgetServices

(String name)

src/main/java/cn/ppphuang/rpcspringstarter/client/discovery/ServiceDiscoverer.java:14

↓ 1 callersMethodgetSimpleParaName

(Type type, Class<?> clazz)

src/main/java/cn/ppphuang/rpcspringstarter/server/ProxyFactory.java:261

↓ 1 callersMethodhandle

⛔️ 已禁用提示 请检查是否包含 IO 操作。纯内存操作请使用 {@link #handleNonBlocking(BiFunction)}。

src/main/java/cn/ppphuang/rpcspringstarter/client/async/RpcCompletableFuture.java:134

↓ 1 callersMethodhandleNonBlocking

✅ 无阻塞安全调用 仅当确信回调逻辑为纯内存操作且执行极快时使用。

src/main/java/cn/ppphuang/rpcspringstarter/client/async/RpcCompletableFuture.java:150

↓ 1 callersMethodhandleRequest

(byte[] data)

src/main/java/cn/ppphuang/rpcspringstarter/server/RequestHandler.java:29

↓ 1 callersMethodinjectService

(ApplicationContext context)

src/main/java/cn/ppphuang/rpcspringstarter/server/register/DefaultRpcProcessor.java:55

↓ 1 callersMethodinjectService

(ApplicationContext context)

src/main/java/cn/ppphuang/rpcspringstarter/server/register/DefaultRpcBaseProcessor.java:57

↓ 1 callersMethodinstance

()

src/main/java/cn/ppphuang/rpcspringstarter/client/async/CompletableFutureAsyncCallBack.java:20

↓ 1 callersMethodinvoke

具体代理调用 @return RpcResponse

src/main/java/cn/ppphuang/rpcspringstarter/server/handler/RequestBaseHandler.java:65

↓ 1 callersMethodisAsync

()

src/main/java/cn/ppphuang/rpcspringstarter/common/model/RpcResponse.java:95

↓ 1 callersMethodisEnableNettyChannelPool

()

src/main/java/cn/ppphuang/rpcspringstarter/properties/RpcConfig.java:146

↓ 1 callersMethodisLogResult

()

src/main/java/cn/ppphuang/rpcspringstarter/client/async/AbstractLogAction.java:44

↓ 1 callersMethodisNettyChannelPoolGetNewOnAcquireTimeout

()

src/main/java/cn/ppphuang/rpcspringstarter/properties/RpcConfig.java:162

↓ 1 callersMethodloadExtensionClasses

()

src/main/java/cn/ppphuang/rpcspringstarter/common/extension/ExtensionLoader.java:127

↓ 1 callersMethodloadFile

(Map<String, Class<?>> extensionClasses, String dir)

src/main/java/cn/ppphuang/rpcspringstarter/common/extension/ExtensionLoader.java:133

↓ 1 callersMethodloadResource

(Map<String, Class<?>> extensionClasses, ClassLoader classLoader, URL resourceUrl)

src/main/java/cn/ppphuang/rpcspringstarter/common/extension/ExtensionLoader.java:151

↓ 1 callersMethodlogBusinessError

(Throwable throwable)

src/main/java/cn/ppphuang/rpcspringstarter/client/async/AbstractLogAction.java:40

↓ 1 callersMethodmakeInvoke

(ArrayList<Method> methods, CtClass proxyClass, String exceptionName, String objectName)

src/main/java/cn/ppphuang/rpcspringstarter/server/ProxyFactory.java:237

↓ 1 callersMethodmakeMethodString

(CtClass proxyClass, Method[] methods, String uniqueMethodName)

src/main/java/cn/ppphuang/rpcspringstarter/server/ProxyFactory.java:68

↓ 1 callersMethodmakeProxyFiled

(String interfaceName, String springBeanName)

src/main/java/cn/ppphuang/rpcspringstarter/server/ProxyFactory.java:227

↓ 1 callersMethodmarshallingRequest

编组请求 @param request @return @throws Exception

src/main/java/cn/ppphuang/rpcspringstarter/common/protocol/MessageProtocol.java:22

↓ 1 callersMethodonException

重写此方法，可以在callBack中自行处理业务处理异常，也可以重写此方法兜底处理 @param context @param result @param e

src/main/java/cn/ppphuang/rpcspringstarter/client/async/AsyncReceiveHandler.java:46

↓ 1 callersMethodregisterShutdownHook

(ServerRegister register, RpcServer rpcServer)

src/main/java/cn/ppphuang/rpcspringstarter/server/ShutdownHook.java:14

↓ 1 callersMethodremoveAll

删除指定服务的缓存 @param serviceName

src/main/java/cn/ppphuang/rpcspringstarter/client/cache/ServerDiscoveryCache.java:54

↓ 1 callersMethodrespData

()

src/main/java/cn/ppphuang/rpcspringstarter/client/net/handler/SendHandler.java:78

↓ 1 callersMethodselectOne

(List<Service> services)

src/main/java/cn/ppphuang/rpcspringstarter/client/balance/SmoothWeightRoundBalance.java:23

↓ 1 callersMethodselectOne

选择一个服务端 @param services @return

src/main/java/cn/ppphuang/rpcspringstarter/client/balance/LoadBalance.java:21

↓ 1 callersMethodsendAsyncRequest

(InetSocketAddress socketAddress, RpcRequest request, RpcProtocolEnum messageProtocol, RpcCompressEnum compres

src/main/java/cn/ppphuang/rpcspringstarter/client/net/NettyNetPoolClientPool.java:107

↓ 1 callersMethodsendAsyncRequest

(RpcRequest request, RpcProtocolEnum messageProtocol, RpcCompressEnum compresser)

src/main/java/cn/ppphuang/rpcspringstarter/client/net/handler/SendHandlerV2.java:72

↓ 1 callersMethodsendRequest

请求接口返回字节数组 @param data @param service @return @throws InterruptedException

src/main/java/cn/ppphuang/rpcspringstarter/client/net/NetClient.java:24

↓ 1 callersMethodsendSyncRequest

(InetSocketAddress socketAddress, RpcRequest request, RpcProtocolEnum messageProtocol, RpcCompressEnum compres

src/main/java/cn/ppphuang/rpcspringstarter/client/net/NettyNetPoolClientPool.java:81

↓ 1 callersMethodsendSyncRequest

(RpcRequest request, RpcProtocolEnum messageProtocol, RpcCompressEnum compresser)

src/main/java/cn/ppphuang/rpcspringstarter/client/net/handler/SendHandlerV2.java:46

↓ 1 callersMethodsetAsync

(boolean async)

src/main/java/cn/ppphuang/rpcspringstarter/common/model/RpcRequest.java:45

↓ 1 callersMethodsetClientProxyFactory

(ClientProxyFactory clientProxyFactory)

src/main/java/cn/ppphuang/rpcspringstarter/server/register/DefaultRpcBaseProcessor.java:111

↓ 1 callersMethodsetCompress

(String compress)

src/main/java/cn/ppphuang/rpcspringstarter/common/model/Service.java:71

↓ 1 callersMethodsetCompresser

(RpcCompressEnum compresser)

src/main/java/cn/ppphuang/rpcspringstarter/server/handler/RequestBaseHandler.java:87

↓ 1 callersMethodsetGroup

(String group)

src/main/java/cn/ppphuang/rpcspringstarter/common/model/RpcRequest.java:69

↓ 1 callersMethodsetLoadBalance

(LoadBalance loadBalance)

src/main/java/cn/ppphuang/rpcspringstarter/client/net/ClientProxyFactory.java:182

↓ 1 callersMethodsetMethod

(String method)

src/main/java/cn/ppphuang/rpcspringstarter/common/model/RpcRequest.java:61

↓ 1 callersMethodsetName

(String name)

src/main/java/cn/ppphuang/rpcspringstarter/common/model/Service.java:39

↓ 1 callersMethodsetNetClient

(NetClient netClient)

src/main/java/cn/ppphuang/rpcspringstarter/client/net/ClientProxyFactory.java:166

↓ 1 callersMethodsetParameters

(Object[] parameters)

src/main/java/cn/ppphuang/rpcspringstarter/common/model/RpcRequest.java:101

↓ 1 callersMethodsetParametersTypes

(Class<?>[] parametersTypes)

src/main/java/cn/ppphuang/rpcspringstarter/common/model/RpcRequest.java:93

↓ 1 callersMethodsetProtocol

(RpcProtocolEnum protocol)

src/main/java/cn/ppphuang/rpcspringstarter/server/handler/RequestBaseHandler.java:71

↓ 1 callersMethodsetProtocol

(String protocol)

src/main/java/cn/ppphuang/rpcspringstarter/common/model/Service.java:47

↓ 1 callersMethodsetRequestId

(String requestId)

src/main/java/cn/ppphuang/rpcspringstarter/common/model/RpcRequest.java:37

↓ 1 callersMethodsetResponse

(T response)

src/main/java/cn/ppphuang/rpcspringstarter/client/net/RpcFuture.java:70

↓ 1 callersMethodsetRpcServer

(RpcServer rpcServer)

src/main/java/cn/ppphuang/rpcspringstarter/server/register/DefaultRpcBaseProcessor.java:119

↓ 1 callersMethodsetServerRegister

(ServerRegister serverRegister)

src/main/java/cn/ppphuang/rpcspringstarter/server/register/DefaultRpcBaseProcessor.java:115

↓ 1 callersMethodsetServerRegister

(ServerRegister serverRegister)

src/main/java/cn/ppphuang/rpcspringstarter/server/handler/RequestBaseHandler.java:79

↓ 1 callersMethodsetServiceDiscoverer

(ServiceDiscoverer serviceDiscoverer)

src/main/java/cn/ppphuang/rpcspringstarter/client/net/ClientProxyFactory.java:158

↓ 1 callersMethodsetServiceName

(String serviceName)

src/main/java/cn/ppphuang/rpcspringstarter/common/model/RpcRequest.java:53

↓ 1 callersMethodsetSupportCompressers

(Map<String, Compresser> supportCompressers)

src/main/java/cn/ppphuang/rpcspringstarter/common/extension/ExtensionLoaderV1.java:23

↓ 1 callersMethodsetSupportMessageProtocols

(Map<String, MessageProtocol> supportMessageProtocols)

src/main/java/cn/ppphuang/rpcspringstarter/common/extension/ExtensionLoaderV1.java:19

↓ 1 callersMethodsetVersion

(String version)

src/main/java/cn/ppphuang/rpcspringstarter/common/model/RpcRequest.java:77

↓ 1 callersMethodstartBaseServer

(ApplicationContext context)

src/main/java/cn/ppphuang/rpcspringstarter/server/register/DefaultRpcBaseProcessor.java:104

↓ 1 callersMethodstartServer

(ApplicationContext context)

src/main/java/cn/ppphuang/rpcspringstarter/server/register/DefaultRpcProcessor.java:102

↓ 1 callersMethodstartServer

(ApplicationContext context)

src/main/java/cn/ppphuang/rpcspringstarter/server/register/DefaultRpcBaseProcessor.java:109

↓ 1 callersMethodstop

停止

src/main/java/cn/ppphuang/rpcspringstarter/server/RpcServer.java:36

↓ 1 callersMethodsuccess

客户端接收到响应之后，调用此方法 @throws Exception

src/main/java/cn/ppphuang/rpcspringstarter/client/async/AsyncReceiveHandler.java:20

↓ 1 callersMethodthenAccept

⛔️ 已禁用提示 请确认回调逻辑是否包含 IO 操作： - 有 IO 操作：请改用 {@link #thenAcceptAsync(Consumer, Executor)}。 - 无 IO 操作（仅对象组装）：请改用 {@link #thenAcceptNonBlocking(

src/main/java/cn/ppphuang/rpcspringstarter/client/async/RpcCompletableFuture.java:80

↓ 1 callersMethodthenApply

⛔️ 已禁用提示 请确认回调逻辑是否包含 IO 操作： - 有 IO 操作：请改用 {@link #thenApplyAsync(Function, Executor)}。 - 无 IO 操作（仅对象组装）：请改用 {@link #thenApplyNonBlocking(Fu

src/main/java/cn/ppphuang/rpcspringstarter/client/async/RpcCompletableFuture.java:51

↓ 1 callersMethodthenRun

⛔️ 已禁用提示 请确认回调逻辑是否包含 IO 操作： - 有 IO 操作：请改用 {@link #thenRunAsync(Runnable, Executor)}。 - 无 IO 操作（仅对象组装）：请改用 {@link #thenRunNonBlocking(Runnab

src/main/java/cn/ppphuang/rpcspringstarter/client/async/RpcCompletableFuture.java:107

↓ 1 callersMethodunmarshallingResponse

解组响应 @param data @return @throws Exception

src/main/java/cn/ppphuang/rpcspringstarter/common/protocol/MessageProtocol.java:46

↓ 1 callersMethodwhenCompleteNonBlocking

✅ 无阻塞安全调用 仅当确信回调逻辑为纯内存操作且执行极快时使用。

src/main/java/cn/ppphuang/rpcspringstarter/client/async/RpcCompletableFuture.java:175

↓ 1 callersMethodwithExtensionAnnotation

(Class<T> type)

src/main/java/cn/ppphuang/rpcspringstarter/common/extension/ExtensionLoader.java:42

MethodAbstractLogAction

(String methodName, Object... args)

src/main/java/cn/ppphuang/rpcspringstarter/client/async/AbstractLogAction.java:16

MethodAsyncExecutor

(ClientProxyFactory clientProxyFactory, Class<C> clazz, String group, String version)

src/main/java/cn/ppphuang/rpcspringstarter/client/async/AsyncExecutor.java:17

MethodChannelRequestHandler

(RequestBaseHandler requestHandler)

src/main/java/cn/ppphuang/rpcspringstarter/server/ChannelRequestHandler.java:32

MethodClientInvocationHandler

(Class<?> clazz, String group, String version, boolean async)

src/main/java/cn/ppphuang/rpcspringstarter/client/net/ClientProxyFactory.java:77

MethodCompletableFutureAsyncCallBack

()

src/main/java/cn/ppphuang/rpcspringstarter/client/async/CompletableFutureAsyncCallBack.java:17

MethodDefaultRpcBaseProcessor

(ClientProxyFactory clientProxyFactory, ServerRegister serverRegister, RpcServer rpcServer)

src/main/java/cn/ppphuang/rpcspringstarter/server/register/DefaultRpcBaseProcessor.java:37

MethodDefaultRpcJavassistProcessor

(ClientProxyFactory clientProxyFactory, ServerRegister serverRegister, RpcServer rpcServer)

src/main/java/cn/ppphuang/rpcspringstarter/server/register/DefaultRpcJavassistProcessor.java:25

MethodDefaultRpcProcessor

(ClientProxyFactory clientProxyFactory, ServerRegister serverRegister, RpcServer rpcServer)

src/main/java/cn/ppphuang/rpcspringstarter/server/register/DefaultRpcProcessor.java:38

MethodDefaultRpcReflectProcessor

(ClientProxyFactory clientProxyFactory, ServerRegister serverRegister, RpcServer rpcServer)

src/main/java/cn/ppphuang/rpcspringstarter/server/register/DefaultRpcReflectProcessor.java:23

MethodDefaultValueHandle

@param methodName 方法名称 @param defaultValue 当异常发生时自定义返回的默认值 @param args 方法入参

src/main/java/cn/ppphuang/rpcspringstarter/client/async/DefaultValueHandle.java:24

MethodDefaultValueHandleBuilder

()

src/main/java/cn/ppphuang/rpcspringstarter/client/async/DefaultValueHandle.java:64

MethodExtensionLoader

(Class<?> type)

src/main/java/cn/ppphuang/rpcspringstarter/common/extension/ExtensionLoader.java:38

MethodLogErrorAction

(String methodName, Object... args)

src/main/java/cn/ppphuang/rpcspringstarter/client/async/LogErrorAction.java:12

MethodMessageDecoder

()

src/main/java/cn/ppphuang/rpcspringstarter/common/codec/MessageDecoder.java:27

MethodNettyNetPoolClientPool

(Integer maxConnections, boolean newOnAcquireTimeoutAction)

src/main/java/cn/ppphuang/rpcspringstarter/client/net/NettyNetPoolClientPool.java:40

MethodNettyRpcServer

(int port, String protocol, RequestBaseHandler requestHandler)

src/main/java/cn/ppphuang/rpcspringstarter/server/NettyRpcServer.java:32

MethodPerson

(int age, String name)

src/main/java/cn/ppphuang/rpcspringstarter/service/Person.java:13

MethodRequestBaseHandler

(RpcProtocolEnum protocol, ServerRegister serverRegister)

src/main/java/cn/ppphuang/rpcspringstarter/server/handler/RequestBaseHandler.java:27

MethodRequestHandler

(MessageProtocol protocol, ServerRegister serverRegister)

src/main/java/cn/ppphuang/rpcspringstarter/server/RequestHandler.java:24

MethodRequestJavassistHandler

(RpcProtocolEnum protocol, ServerRegister serverRegister)

src/main/java/cn/ppphuang/rpcspringstarter/server/handler/RequestJavassistHandler.java:22

MethodRequestReflectHandler

(RpcProtocolEnum protocol, ServerRegister serverRegister)

src/main/java/cn/ppphuang/rpcspringstarter/server/handler/RequestReflectHandler.java:23

MethodResult

(Integer code, String message, T data)

src/main/java/cn/ppphuang/rpcspringstarter/service/Result.java:14

MethodRpcCompressEnum

(byte code, String compress)

src/main/java/cn/ppphuang/rpcspringstarter/common/constants/RpcCompressEnum.java:25

← previous next →101–200 of 403, ranked by callers