com.fr.cluster.engine.transport.context.impl

类 DefaultMessageDispatcher

java.lang.Object

com.fr.cluster.engine.transport.context.impl.DefaultMessageDispatcher

所有已实现的接口:

ClusterMessageDispatcher<com.fr.cluster.engine.transport.context.impl.DefaultMessageDispatcher.DistributableMessage>, MessageWrapper<com.fr.cluster.engine.transport.context.impl.DefaultMessageDispatcher.DistributableMessage>

public class DefaultMessageDispatcher
extends java.lang.Object
implements ClusterMessageDispatcher<com.fr.cluster.engine.transport.context.impl.DefaultMessageDispatcher.DistributableMessage>

Created by juhaoyu on 2017/12/12. 默认channel消息分发逻辑，适用于普通的消息 像RPC这种本身消息中就有Class名，即不需要记录channel名就能分发的应用，用这种默认的就比较浪费性能了，所以提出来接口允许自定义

方法概要

方法

限定符和类型	方法和说明
ClusterMessageReceiver	chooseReceiver(com.fr.cluster.engine.transport.context.impl.DefaultMessageDispatcher.DistributableMessage message, ClusterMessageReceiverRepo receiverRepo) 选择出正确的Receiver
static ClusterMessageDispatcher	getInstance()
ClusterMessage	unwrapMessage(com.fr.cluster.engine.transport.context.impl.DefaultMessageDispatcher.DistributableMessage message) 将处理过的数据解封
com.fr.cluster.engine.transport.context.impl.DefaultMessageDispatcher.DistributableMessage	wrapMessage(ClusterMessageReceiver receiver, ClusterMessage message) 在发送是处理数据

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

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

方法详细资料

getInstance

public static ClusterMessageDispatcher getInstance()

wrapMessage

public com.fr.cluster.engine.transport.context.impl.DefaultMessageDispatcher.DistributableMessage wrapMessage(ClusterMessageReceiver receiver,
                                                                                                     ClusterMessage message)

从接口复制的说明: MessageWrapper

在发送是处理数据

指定者:

wrapMessage 在接口中 MessageWrapper<com.fr.cluster.engine.transport.context.impl.DefaultMessageDispatcher.DistributableMessage>

unwrapMessage

public ClusterMessage unwrapMessage(com.fr.cluster.engine.transport.context.impl.DefaultMessageDispatcher.DistributableMessage message)

从接口复制的说明: MessageWrapper

将处理过的数据解封

指定者:

unwrapMessage 在接口中 MessageWrapper<com.fr.cluster.engine.transport.context.impl.DefaultMessageDispatcher.DistributableMessage>

chooseReceiver

public ClusterMessageReceiver chooseReceiver(com.fr.cluster.engine.transport.context.impl.DefaultMessageDispatcher.DistributableMessage message,
                                    ClusterMessageReceiverRepo receiverRepo)

从接口复制的说明: ClusterMessageDispatcher

选择出正确的Receiver

指定者:

chooseReceiver 在接口中 ClusterMessageDispatcher<com.fr.cluster.engine.transport.context.impl.DefaultMessageDispatcher.DistributableMessage>