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

MethodRpcConstant

()

src/main/java/cn/ppphuang/rpcspringstarter/common/constants/RpcConstant.java:14

MethodRpcException

(String message)

src/main/java/cn/ppphuang/rpcspringstarter/exception/RpcException.java:10

MethodRpcFuture

()

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

MethodRpcProtocolEnum

(byte code, String protocol)

src/main/java/cn/ppphuang/rpcspringstarter/common/constants/RpcProtocolEnum.java:30

MethodRpcResponse

()

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

MethodRpcServer

(int port, String protocol, RequestBaseHandler requestHandler)

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

MethodRpcStatusEnum

(int code, String desc)

src/main/java/cn/ppphuang/rpcspringstarter/common/constants/RpcStatusEnum.java:29

MethodSendHandler

(byte[] data)

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

MethodServiceObject

(String name, Class<?> clazz, Object obj, String group, String version)

src/main/java/cn/ppphuang/rpcspringstarter/server/register/ServiceObject.java:35

MethodZookeeperServerDiscovery

(String zkAddress)

src/main/java/cn/ppphuang/rpcspringstarter/client/discovery/ZookeeperServerDiscovery.java:27

MethodZookeeperServerRegister

(String zkAddress, Integer port, String protocol, String compress, Integer weight)

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

Methodaccept

(R result, Throwable throwable)

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

Methodargs

(final Object... args)

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

Methodbuild

()

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

Methodbuilder

()

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

MethodcallBack

(Object context, Object result)

src/main/java/cn/ppphuang/rpcspringstarter/client/async/TestCallBackHandler.java:10

MethodcallBack

(Object context, Object result)

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

Methodcancel

(boolean mayInterruptIfRunning)

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

MethodchannelAcquired

(Channel channel)

src/main/java/cn/ppphuang/rpcspringstarter/client/net/handler/ClientChannelPoolHandler.java:28

MethodchannelActive

(ChannelHandlerContext ctx)

src/main/java/cn/ppphuang/rpcspringstarter/client/net/handler/SendBaseHandler.java:37

MethodchannelActive

连接服务后立即发送数据 @param ctx @throws Exception

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

MethodchannelActive

(ChannelHandlerContext ctx)

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

MethodchannelActive

(ChannelHandlerContext ctx)

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

MethodchannelCreated

(Channel channel)

src/main/java/cn/ppphuang/rpcspringstarter/client/net/handler/ClientChannelPoolHandler.java:33

MethodchannelInactive

(ChannelHandlerContext ctx)

src/main/java/cn/ppphuang/rpcspringstarter/client/net/handler/SendBaseHandler.java:92

MethodchannelRead

(ChannelHandlerContext ctx, Object msg)

src/main/java/cn/ppphuang/rpcspringstarter/client/net/handler/SendBaseHandler.java:43

MethodchannelRead

读取数据，之后释放cd锁 @param ctx @param msg @throws Exception

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

MethodchannelRead

(ChannelHandlerContext ctx, Object msg)

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

MethodchannelReadComplete

(ChannelHandlerContext ctx)

src/main/java/cn/ppphuang/rpcspringstarter/client/net/handler/SendBaseHandler.java:80

MethodchannelReadComplete

(ChannelHandlerContext ctx)

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

MethodchannelReadComplete

(ChannelHandlerContext ctx)

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

MethodchannelReleased

(Channel channel)

src/main/java/cn/ppphuang/rpcspringstarter/client/net/handler/ClientChannelPoolHandler.java:23

Methodcompress

(byte[] bytes)

src/main/java/cn/ppphuang/rpcspringstarter/common/compresser/GzipCompresser.java:22

MethodcontextLoads

()

src/test/java/cn/ppphuang/rpcspringstarter/RpcSpringStarterApplicationTests.java:20

MethodconvertToBoolean

(Object obj)

src/main/java/cn/ppphuang/rpcspringstarter/util/ConvertUtil.java:65

MethodconvertToByte

(Object obj)

src/main/java/cn/ppphuang/rpcspringstarter/util/ConvertUtil.java:87

MethodconvertToCharacter

(Object obj)

src/main/java/cn/ppphuang/rpcspringstarter/util/ConvertUtil.java:105

MethodconvertToDouble

(Object obj)

src/main/java/cn/ppphuang/rpcspringstarter/util/ConvertUtil.java:76

MethodconvertToFloat

(Object obj)

src/main/java/cn/ppphuang/rpcspringstarter/util/ConvertUtil.java:54

MethodconvertToInteger

(Object obj)

src/main/java/cn/ppphuang/rpcspringstarter/util/ConvertUtil.java:21

MethodconvertToLong

(Object obj)

src/main/java/cn/ppphuang/rpcspringstarter/util/ConvertUtil.java:32

MethodconvertToShort

(Object obj)

src/main/java/cn/ppphuang/rpcspringstarter/util/ConvertUtil.java:43

MethodconvertToString

(Object obj)

src/main/java/cn/ppphuang/rpcspringstarter/util/ConvertUtil.java:10

MethodconvertToT

(Object obj, String clazz)

src/main/java/cn/ppphuang/rpcspringstarter/util/ConvertUtil.java:119

MethodconvertToboolean

(Object obj)

src/main/java/cn/ppphuang/rpcspringstarter/util/ConvertUtil.java:61

MethodconvertTobyte

(Object obj)

src/main/java/cn/ppphuang/rpcspringstarter/util/ConvertUtil.java:83

MethodconvertTochar

(Object obj)

src/main/java/cn/ppphuang/rpcspringstarter/util/ConvertUtil.java:94

MethodconvertTodouble

(Object obj)

src/main/java/cn/ppphuang/rpcspringstarter/util/ConvertUtil.java:72

MethodconvertTofloat

(Object obj)

src/main/java/cn/ppphuang/rpcspringstarter/util/ConvertUtil.java:50

MethodconvertToint

(Object obj)

src/main/java/cn/ppphuang/rpcspringstarter/util/ConvertUtil.java:17

MethodconvertTolong

(Object obj)

src/main/java/cn/ppphuang/rpcspringstarter/util/ConvertUtil.java:28

MethodconvertToshort

(Object obj)

src/main/java/cn/ppphuang/rpcspringstarter/util/ConvertUtil.java:39

Methoddecompress

(byte[] bytes)

src/main/java/cn/ppphuang/rpcspringstarter/common/compresser/GzipCompresser.java:38

MethoddefaultValue

(final R defaultValue)

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

Methoddeserialize

反序列化 @param bytes @return @throws ZkMarshallingError

src/main/java/cn/ppphuang/rpcspringstarter/common/serializer/ZookeeperSerializer.java:32

Methodencode

(ChannelHandlerContext channelHandlerContext, RpcMessage rpcMessage, ByteBuf byteBuf)

src/main/java/cn/ppphuang/rpcspringstarter/common/codec/MessageEncoder.java:40

MethodexceptionCaught

(ChannelHandlerContext ctx, Throwable cause)

src/main/java/cn/ppphuang/rpcspringstarter/client/net/handler/SendBaseHandler.java:85

MethodexceptionCaught

(ChannelHandlerContext ctx, Throwable cause)

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

MethodexceptionCaught

(ChannelHandlerContext ctx, Throwable cause)

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

MethodextensionLoader

()

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

MethodgetAge

()

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

MethodgetBeginTime

()

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

MethodgetCode

()

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

MethodgetCode

()

src/main/java/cn/ppphuang/rpcspringstarter/common/constants/RpcProtocolEnum.java:35

MethodgetCode

()

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

MethodgetCompress

()

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

MethodgetCompresser

(String name)

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

MethodgetData

()

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

MethodgetDesc

()

src/main/java/cn/ppphuang/rpcspringstarter/common/constants/RpcStatusEnum.java:38

MethodgetGroup

()

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

MethodgetHeaders

()

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

MethodgetHeaders

()

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

MethodgetLoadBalance

()

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

MethodgetLoadBalance

()

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

MethodgetMessageProtocol

(String name)

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

MethodgetName

()

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

MethodgetNetClient

()

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

MethodgetObjectCache

()

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

MethodgetProtocol

()

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

MethodgetProtocol

()

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

MethodgetProtocol

()

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

MethodgetRequestHandler

()

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

MethodgetServerRegister

()

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

MethodgetServerRegister

()

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

MethodgetServiceObject

(String name)

src/main/java/cn/ppphuang/rpcspringstarter/server/register/DefaultServerRegisrer.java:35

MethodgetServices

(String name)

src/main/java/cn/ppphuang/rpcspringstarter/client/discovery/ZookeeperServerDiscovery.java:32

MethodgetSpringContext

()

src/main/java/cn/ppphuang/rpcspringstarter/server/Container.java:15

MethodgetVersion

()

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

MethodgetWeight

()

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

MethodhandleAsync

(BiFunction<? super T, Throwable, ? extends U> fn, Executor executor)

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

MethodhandleChildChange

监听子节点的删除和新增事件 @param parentPath @param childList @throws Exception

src/main/java/cn/ppphuang/rpcspringstarter/client/discovery/ZkChildListenerImpl.java:22

MethodhandleRequest

(RpcRequest request)

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

MethodhashCode

()

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

MethodhelloBoolean

@param age Boolean @return boolean

src/main/java/cn/ppphuang/rpcspringstarter/service/HelloService.java:47

MethodhelloByte

@param age age @return byte

src/main/java/cn/ppphuang/rpcspringstarter/service/HelloService.java:41

MethodhelloInt

@param age int @return int

src/main/java/cn/ppphuang/rpcspringstarter/service/HelloService.java:35

MethodhelloInteger

@param age @return

src/main/java/cn/ppphuang/rpcspringstarter/service/HelloService.java:29

MethodhelloList

@param age Integer @return List<Integer>

src/main/java/cn/ppphuang/rpcspringstarter/service/HelloService.java:60

MethodhelloPerson

@param name String @param age Integer @return Result<Person>

src/main/java/cn/ppphuang/rpcspringstarter/service/HelloService.java:54

MethodinitChannel

(SocketChannel socketChannel)

src/main/java/cn/ppphuang/rpcspringstarter/client/net/NettyNetClient.java:54

← previous next →201–300 of 403, ranked by callers