程序包 | 说明 |
---|---|
com.fr.cluster.engine.transport.context | |
com.fr.cluster.engine.transport.context.impl | |
com.fr.cluster.message |
限定符和类型 | 接口和说明 |
---|---|
interface |
ClusterChannel<Request,Response>
Created by juhaoyu on 2017/12/13.
1、从上往下:处理范型对象到ClusterMessage的转化,并交给下层sender发送到其他集群节点
2、从下往上:接收其他节点发来的ClusterMessage请求,并转化为范型对象,传给上层处理器
|
限定符和类型 | 方法和说明 |
---|---|
<Request,Response> |
FineClusterContext.build(ClusterServer<Request,Response> server) |
限定符和类型 | 方法和说明 |
---|---|
ClusterClient<Request,Response> |
ClusterConnectionFactory.Builder.build()
构建
|
<Request,Response> |
ClusterConnectionFactory.build(ClusterServer<Request,Response> server)
构建通信组件
在集群中,获取客户端组件时,必须提供对应的服务端组件,用于接收其他节点的对应请求
|