接口 com.fr.cluster.engine.transport.context.ClusterMessageReceiver
的使用

使用ClusterMessageReceiver的程序包

程序包	说明
com.fr.cluster.engine.transport.context
com.fr.cluster.engine.transport.context.components	Created by juhaoyu on 2017/12/13.
com.fr.cluster.engine.transport.context.impl

com.fr.cluster.engine.transport.context中ClusterMessageReceiver的使用

com.fr.cluster.engine.transport.context中ClusterMessageReceiver的子接口

限定符和类型	接口和说明
interface	ClusterChannel<Request,Response> Created by juhaoyu on 2017/12/13. 1、从上往下：处理范型对象到ClusterMessage的转化，并交给下层sender发送到其他集群节点 2、从下往上：接收其他节点发来的ClusterMessage请求，并转化为范型对象，传给上层处理器

返回ClusterMessageReceiver的com.fr.cluster.engine.transport.context中的方法

限定符和类型	方法和说明
ClusterMessageReceiver	ClusterMessageReceiverRepo.get(java.lang.String name) 根据名字获取Channel

参数类型为ClusterMessageReceiver的com.fr.cluster.engine.transport.context中的方法

限定符和类型	方法和说明
java.util.Map<ClusterNode,ClusterMessage>	ClusterMessageSender.cast(ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options) 对特定接受者广播消息
void	ClusterMessageSender.cast(ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options, ClusterMessageSender.CastCallback castCallback) 异步广播
void	ClusterMessageReceiverRepo.save(ClusterMessageReceiver receiver) 保存
ClusterMessage	ClusterMessageSender.send(ClusterNode node, ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options) 指定节点和接收者发送消息
void	ClusterMessageSender.send(ClusterNode address, ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options, ClusterMessageSender.Callback callback) 异步发送

com.fr.cluster.engine.transport.context.components中ClusterMessageReceiver的使用

返回ClusterMessageReceiver的com.fr.cluster.engine.transport.context.components中的方法

限定符和类型	方法和说明
ClusterMessageReceiver	ClusterMessageDispatcher.chooseReceiver(T message, ClusterMessageReceiverRepo receiverRepo) 选择出正确的Receiver

参数类型为ClusterMessageReceiver的com.fr.cluster.engine.transport.context.components中的方法

限定符和类型	方法和说明
T	MessageWrapper.wrapMessage(ClusterMessageReceiver receiver, ClusterMessage message) 在发送是处理数据

com.fr.cluster.engine.transport.context.impl中ClusterMessageReceiver的使用

返回ClusterMessageReceiver的com.fr.cluster.engine.transport.context.impl中的方法

限定符和类型	方法和说明
ClusterMessageReceiver	DefaultMessageDispatcher.chooseReceiver(com.fr.cluster.engine.transport.context.impl.DefaultMessageDispatcher.DistributableMessage message, ClusterMessageReceiverRepo receiverRepo)
ClusterMessageReceiver	FineClusterReceiverRepo.get(java.lang.String name)

参数类型为ClusterMessageReceiver的com.fr.cluster.engine.transport.context.impl中的方法

限定符和类型	方法和说明
java.util.Map<ClusterNode,ClusterMessage>	FineClusterMessageSender.cast(ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options)
void	FineClusterMessageSender.cast(ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options, ClusterMessageSender.CastCallback castCallback)
void	FineClusterReceiverRepo.save(ClusterMessageReceiver receiver)
ClusterMessage	FineClusterMessageSender.send(ClusterNode node, ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options)
void	FineClusterMessageSender.send(ClusterNode address, ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options, ClusterMessageSender.Callback callback)
com.fr.cluster.engine.transport.context.impl.DefaultMessageDispatcher.DistributableMessage	DefaultMessageDispatcher.wrapMessage(ClusterMessageReceiver receiver, ClusterMessage message)