com.fr.cluster.message

接口 ClusterClient<Request,Response>

类型参数:

Request - 请求类型

Response - 结果类型，允许Void

所有已知子接口:

ClusterChannel<Request,Response>

public interface ClusterClient<Request,Response>

Created by juhaoyu on 2017/12/1. 通信 这里只提供最基础的通信功能,其他特殊的通信场景都会有上层接口 保证多个Channel的消息互不影响（并行）

嵌套类概要

嵌套类

限定符和类型	接口和说明
static class	ClusterClient.MessageTag 消息标签

方法概要

方法

限定符和类型	方法和说明
java.util.Map<ClusterNode,Response>	cast(Request request) 广播
void	cast(Request request, MessageCastHandler<Response> castHandler) 异步广播
Response	send(ClusterNode address, Request request) 发送
void	send(ClusterNode address, Request request, MessageResultHandler<Response> resultHandler) 异步发送

方法详细资料

send

Response send(ClusterNode address,
            Request request)
              throws java.lang.Exception

发送

抛出:

java.lang.Exception

cast

java.util.Map<ClusterNode,Response> cast(Request request)
                                         throws java.lang.Exception

广播

抛出:

java.lang.Exception

send

void send(ClusterNode address,
        Request request,
        MessageResultHandler<Response> resultHandler)
          throws java.lang.Exception

异步发送

抛出:

java.lang.Exception

cast

void cast(Request request,
        MessageCastHandler<Response> castHandler)
          throws java.lang.Exception

异步广播

抛出:

java.lang.Exception