com.alipay.remoting.rpc

类 RpcServerRemoting

java.lang.Object

com.alipay.remoting.BaseRemoting

com.alipay.remoting.rpc.RpcRemoting

com.alipay.remoting.rpc.RpcServerRemoting

public class RpcServerRemoting
extends RpcRemoting

Rpc server remoting

字段概要

从类继承的字段 com.alipay.remoting.rpc.RpcRemoting

addressParser, connectionManager

从类继承的字段 com.alipay.remoting.BaseRemoting

commandFactory

构造器概要

构造器

构造器和说明
RpcServerRemoting(CommandFactory commandFactory) default constructor
RpcServerRemoting(CommandFactory commandFactory, RemotingAddressParser addressParser, DefaultConnectionManager connectionManager)

方法概要

方法

限定符和类型	方法和说明
Object	invokeSync(Url url, Object request, InvokeContext invokeContext, int timeoutMillis) Synchronous rpc invocation.
void	invokeWithCallback(Url url, Object request, InvokeContext invokeContext, InvokeCallback invokeCallback, int timeoutMillis) Rpc invocation with callback.
RpcResponseFuture	invokeWithFuture(Url url, Object request, InvokeContext invokeContext, int timeoutMillis) Rpc invocation with future returned.
void	oneway(Url url, Object request, InvokeContext invokeContext) Oneway rpc invocation.
protected void	preProcessInvokeContext(InvokeContext invokeContext, RemotingCommand cmd, Connection connection)

从类继承的方法 com.alipay.remoting.rpc.RpcRemoting

createInvokeFuture, createInvokeFuture, invokeSync, invokeSync, invokeWithCallback, invokeWithCallback, invokeWithFuture, invokeWithFuture, oneway, oneway, toRemotingCommand

从类继承的方法 com.alipay.remoting.BaseRemoting

getCommandFactory, invokeSync, invokeWithCallback, invokeWithFuture, oneway

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

RpcServerRemoting

public RpcServerRemoting(CommandFactory commandFactory)

default constructor

RpcServerRemoting

public RpcServerRemoting(CommandFactory commandFactory,
                 RemotingAddressParser addressParser,
                 DefaultConnectionManager connectionManager)

参数:

addressParser -

connectionManager -

方法详细资料

invokeSync

public Object invokeSync(Url url,
                Object request,
                InvokeContext invokeContext,
                int timeoutMillis)
                  throws RemotingException,
                         InterruptedException

从类复制的说明: RpcRemoting

Synchronous rpc invocation.
Notice! DO NOT modify the request object concurrently when this method is called.

指定者:

invokeSync 在类中 RpcRemoting

返回:

抛出:

RemotingException

InterruptedException

另请参阅:

RpcRemoting.invokeSync(com.alipay.remoting.Url, java.lang.Object, InvokeContext, int)

oneway

public void oneway(Url url,
          Object request,
          InvokeContext invokeContext)
            throws RemotingException

从类复制的说明: RpcRemoting

Oneway rpc invocation.
Notice! DO NOT modify the request object concurrently when this method is called.

指定者:

oneway 在类中 RpcRemoting

抛出:

RemotingException

另请参阅:

RpcRemoting.oneway(com.alipay.remoting.Url, java.lang.Object, InvokeContext)

invokeWithFuture

public RpcResponseFuture invokeWithFuture(Url url,
                                 Object request,
                                 InvokeContext invokeContext,
                                 int timeoutMillis)
                                   throws RemotingException

从类复制的说明: RpcRemoting

Rpc invocation with future returned.
Notice! DO NOT modify the request object concurrently when this method is called.

指定者:

invokeWithFuture 在类中 RpcRemoting

返回:

抛出:

RemotingException

另请参阅:

RpcRemoting.invokeWithFuture(com.alipay.remoting.Url, java.lang.Object, InvokeContext, int)

invokeWithCallback

public void invokeWithCallback(Url url,
                      Object request,
                      InvokeContext invokeContext,
                      InvokeCallback invokeCallback,
                      int timeoutMillis)
                        throws RemotingException

从类复制的说明: RpcRemoting

Rpc invocation with callback.
Notice! DO NOT modify the request object concurrently when this method is called.

指定者:

invokeWithCallback 在类中 RpcRemoting

抛出:

RemotingException

另请参阅:

RpcRemoting.invokeWithCallback(com.alipay.remoting.Url, java.lang.Object, InvokeContext, com.alipay.remoting.InvokeCallback, int)

preProcessInvokeContext

protected void preProcessInvokeContext(InvokeContext invokeContext,
                           RemotingCommand cmd,
                           Connection connection)

指定者:

preProcessInvokeContext 在类中 RpcRemoting