模块 org.redkale

程序包 org.redkale.cluster.spi

类 HttpLocalRpcClient

java.lang.Object

org.redkale.cluster.HttpRpcClient

org.redkale.cluster.spi.HttpLocalRpcClient

所有已实现的接口:

ClusterRpcClient<WebRequest,HttpResult<byte[]>>

public class HttpLocalRpcClient
extends HttpRpcClient

没有配置MQ且也没有ClusterAgent的情况下实现的默认HttpMessageClient实例

详情见: https://redkale.org

从以下版本开始:

2.4.0

作者:

zhangjx

嵌套类概要

嵌套类

修饰符和类型	类	说明
static class	HttpLocalRpcClient.HttpMessageLocalRequest
static class	HttpLocalRpcClient.HttpMessageLocalResponse

字段概要

字段

修饰符和类型	字段	说明
protected Application	application
protected HttpServer	currServer
protected Logger	logger
protected String	resourceName

构造器概要

构造器

构造器	说明
HttpLocalRpcClient(Application application, String resourceName)

方法概要

修饰符和类型	方法	说明
protected HttpContext	context()
protected HttpDispatcherServlet	dispatcherServlet()
HttpServlet	findHttpServlet(String topic)
HttpServlet	findHttpServlet(WebRequest request)
protected String	getNodeid()
CompletableFuture<Void>	produceMessage(String topic, Serializable userid, String groupid, WebRequest request)
<T> CompletableFuture<T>	sendMessage(Serializable userid, String groupid, WebRequest request, Type type)
<T> CompletableFuture<T>	sendMessage(Serializable userid, WebRequest request, Type type)
CompletableFuture<HttpResult<byte[]>>	sendMessage(String topic, Serializable userid, String groupid, WebRequest request)
<T> CompletableFuture<T>	sendMessage(WebRequest request, Type type)

从类继承的方法 org.redkale.cluster.HttpRpcClient

generateHttpReqTopic, generateHttpReqTopic, generateHttpReqTopic, produceMessage, produceMessage, produceMessage, produceMessage, sendMessage, sendMessage, sendMessage, sendMessage

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

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

字段详细资料

logger

protected final Logger logger

application

protected final Application application

resourceName

protected final String resourceName

currServer

protected HttpServer currServer

构造器详细资料

HttpLocalRpcClient

public HttpLocalRpcClient(Application application,
                          String resourceName)

方法详细资料

getNodeid

protected String getNodeid()

指定者:

getNodeid 在类中 HttpRpcClient

context

protected HttpContext context()

dispatcherServlet

protected HttpDispatcherServlet dispatcherServlet()

findHttpServlet

public HttpServlet findHttpServlet(String topic)

findHttpServlet

public HttpServlet findHttpServlet(WebRequest request)

sendMessage

public <T> CompletableFuture<T> sendMessage(WebRequest request,
                                            Type type)

覆盖:

sendMessage 在类中 HttpRpcClient

sendMessage

public <T> CompletableFuture<T> sendMessage(Serializable userid,
                                            WebRequest request,
                                            Type type)

覆盖:

sendMessage 在类中 HttpRpcClient

sendMessage

public <T> CompletableFuture<T> sendMessage(Serializable userid,
                                            String groupid,
                                            WebRequest request,
                                            Type type)

覆盖:

sendMessage 在类中 HttpRpcClient

sendMessage

public CompletableFuture<HttpResult<byte[]>> sendMessage(String topic,
                                                         Serializable userid,
                                                         String groupid,
                                                         WebRequest request)

指定者:

sendMessage 在类中 HttpRpcClient

produceMessage

public CompletableFuture<Void> produceMessage(String topic,
                                              Serializable userid,
                                              String groupid,
                                              WebRequest request)

指定者:

produceMessage 在类中 HttpRpcClient