Java - 消息处理器设计模式

Question

我的 Java 程序将接收具有预定义结构的消息。每个消息有多个字段，并且下一个字段可能具有特定值（并且应该以特定方式处理），具体取决于当前字段值：

For example:

 1. FIELD1-FIELD2-CUSTOMDATA-OTHERDATA
 2. FIELD1-FIELD2-FIELD3-CUSTOMDATA-OTHERDATA

这里，根据FIELD1的类型，接下来应该运行特定的解码逻辑；所以应该使用特定的解析器。

有这样的设计模式吗？

我想过为每种消息类型定义一个类，并逐步向某些实现提供输入。但这对我来说听起来不太好。

想法？

提前致谢。

Answer 1

责任链或策略 ?

Answer 2

除非您需要动态更改结构，否则我会编写一个解析器，它使用开关和侦听器来处理消息。

interface MessageListener {
    void message1(String field2, Object customData, Object otherData);
    void message2(String field2, String field3, Object customData, Object otherData);
    // other message types
}


MessageListener ml = 
String firstField = getField();
switch(firstField) {
    case messageType1: {
        String field2 = getField();
        Object customData = getData();
        Object otherData = getData();
        ml.message1(field2, customData, otherData);
        break;
    }
    case messageType2: {
        String field2 = getField();
        String field3 = getField();
        Object customData = getData();
        Object otherData = getData();
        ml.message2(field2, field3, customData, otherData);
        break;
    }
    //parse other message types

    default:
        // report unknown message type.
}

Answer 3

最好的选择是定义一些枚举以及每个字段的操作范围，然后创建一个通用消息类。处理诸如验证您是否使用有效组合之类的实用程序类也很好。

别想太多。采用最直接的路径，而不是依赖大量您可能不需要的抽象。

这种方法的优点之一是，使用 JAX-RS 和 JAX-WS，如果您需要公开消息传递，您可以以 API 会自动将其转换为 XML（也可能是 JSON？）的方式注释您的消息类到外部系统。

Answer 4

对我来说，这看起来是状态模式的一个很好的候选者。

您的解析器将有一个初始状态（抽象类或接口的实现），并要求该状态处理下一个标记。

根据令牌的值，状态会修改上下文，并返回适当的下一个 State 实例。重复此操作，直到状态因不需要下一个令牌而引发异常，或者直到处理了最后一个令牌并且最后一个状态不需要另一个令牌。最后，要么解析失败，要么解析成功并且上下文包含解析的数据。

public interface State {
    State nextState(Context context, String token) throws UnexpectedTokenException;
    boolean isFinal();
}