使用状态模式设计在Java中实现通信协议

如果在别处得到回答,请道歉; 找不到足够的信息来说服自己最好的方法来做到这一点。 我也意识到这是一个冗长的解释,没有代码,但请告诉我是否应该提供一些示例代码来帮助演示我正在做的事情。

基本上:

  • 使用System.in/out在Java中实现通信协议
  • 当前方法正在实现一种状态模式,其中Scanner在上下文类中的System.in上实例化
  • 具体状态调用上下文方法从扫描程序读取,然后根据扫描程序返回的值适当地执行操作/转换状态

我最初使用状态模式的意图是在从System.in解析这样的序列时简化代码(不要问语法,这是我必须使用的东西):

  • 命令名称= X.
  • HEADER
  • 标题信息行
  • 内容
  • 命令行内容
  • ENDCONTENTS
  • ENDCOMMAND

我通常为我期望接收的每种命令定义一个具体的状态。 以上面的序列为例,我的状态集看起来像{WAITING_FOR_COMMAND,COM​​MAND_RECEIVED,PARSING_HEADER,PARSING_CONTENTS,PARSING_DONE,COMMAND_PROCESSED}。 我最初在WAITING_FOR_COMMAND,然后当收到“COMMAND NAME = X”时我转换到COMMAND_RECEIVED,然后当“HEADER”进入时我会转换到PARSING_HEADER等等。这个设计使遍历所有边缘情况协议变得更容易,并且在协议被调整时也使代码易于更新/维护。 显然比大规模切换语句和重复边界检查要好得多。

我遇到的问题是,我发现自己在上下文类中声明了越来越多的状态变量,因为我充实了我的具体状态行为,并且知道这可能很糟糕,因为我正在创建非常暴露的接口和非常高的联系上下文和具体的状态类。 该协议中的命令序列可以任意长,并且我需要保存命令序列中每个项所赋予的信息,直到命令序列完成。

以上面的命令序列为例,在“COMMAND ID = X”之后,我希望在收到“ENDCOMMAND”后保存值X以备将来使用并完全处理命令。 在“HEADER”之后,我希望保存标题信息,以便在我实际处理命令时收到“ENDCOMMAND”后将来使用。 等等等等。 简单地将commandId和头状态变量添加到上下文类现在可以工作,但看起来并不干净或完全封装在我身上。

有没有人对他们如何解决这个问题有任何高层建议? 为此更好地使用状态设计模式吗?

只是要注意我一直在玩的一些想法:

  • 为每种类型的命令序列定义状态上下文,并在从System.in接收相关命令时调用适当的上下文; 这看起来几乎像拥有巨大的开关块一样凌乱,似乎过度curl了设计
  • 设计一个支持复合FSM的全面FSM架构,其中每个命令序列在一个总体FSM中占用自己的FSM; 这对我来说似乎有些过分
  • 为每个命令序列类型创建一个具有各种子类的ProtocolCommand对象; 我可以在转换时将它们传递到每个状态,然后逐渐构建它们……但是这会使状态界面变得混乱并强制所有状态摄取它们不一定会使用的参数

非常感谢! 对不起,这太冗长了,如果我能说清楚的话,请告诉我。

我使用枚举来进行这种解析,每个状态都有一个枚举。 这里有一个例子http://vanillajava.blogspot.co.uk/2011/06/java-secret-using-enum-as-state-machine.html

interface Context { ByteBuffer buffer(); State state(); void state(State state); } interface State { /** * @return true to keep processing, false to read more data. */ boolean process(Context context); } enum States implements State { XML { public boolean process(Context context) { if (context.buffer().remaining() < 16) return false; // read header if(headerComplete) context.state(States.ROOT); return true; } }, ROOT { public boolean process(Context context) { if (context.buffer().remaining() < 8) return false; // read root tag if(rootComplete) context.state(States.IN_ROOT); return true; } } } public void process(Context context) { socket.read(context.buffer()); while(context.state().process(context)); } 

我首先考虑以下几点:

  1. 您的状态组件(WAITING_FOR_COMMAND,COM​​MAND_RECEIVED等)是否是应用程序逻辑的核心? 也就是说,解析器处于什么状态以及它转换到什么状态真的很重要,以便应用程序正常工作? 每个州将持有的价值是多少? 这些值是否因州而异? 如果你的答案是肯定的,那么你可能有一个状态模式的有效案例。但我经常看到状态机在某些地方使用它只是一种矫枉过正。

  2. 你的用例似乎更像是需要Command模式和一个Interpreter模式(因为你似乎在编写一个语法)。