0

我正在尝试重构一些遗留代码。这里的任务是基于一些看起来像这样的预定义模板构造冗长的消息/字符串：

field1,8,String
filed2,5,Integer
field3,12,String
......

然后我收到了一个包含所有这些字段的 java 对象。这里需要做的只是从对象字段中获取数据，并使用它们基于模板构造一个长消息/字符串。其中一些字段也可以根据一些简单的规则进行转换。例如：

abc => a
def => d
ghi => g

因此，我们需要不时检查这些字段的值。还有关于填充的规则（主要是在右侧添加空格）。因此，构造的消息/字符串可能如下所示：

uater   4751 enterprise  ......

目前我们只是在使用残酷的武力来完成这项工作。首先，我们将模板输入到 ArrayList 中，每个元素都是一行，例如“field1,8,String”。在实际的消息构造过程中，我们循环遍历这个 ArrayList，然后将数据填充到一个 StringBuffer 中。这是一些示例片段

StringBuffer message = new StringBuffer(1000);
for (String field : templateFields) {
    String[] fieldArray = field.split(Constants.SEPARATOR);
    if (fieldArray[0].equalsIgnoreCase(Constants.WORKFLOW)) {
        message.append(rightPad(object.getFieldOne(), Integer.parseInt(fieldArray[1])));
    } else if (fieldArray[0].equalsIgnoreCase(Constants.WORKVOLUME)) {
        message.append(rightPad(object.getFieldTwo(), Integer.parseInt(fieldArray[1]));
    } else if (fieldArray[0].equalsIgnoreCase(Constants.WORKTYPE)) {
        if (object.getFieldThree().equalsIgnoreCase("abc")) {
             message.append(rightPad("a", Integer.parseInt(fieldArray[1]));
        } else if (object.getFieldThree().equalsIgnoreCase("def")) {
             message.append(rightPad("d", Integer.parseInt(fieldArray[1]));
        } else {
            message.append(rightPad("g", Integer.parseInt(fieldArray[1]));
        }
    } else if ......
}

如您所见，尽管它很可怕，但它可以完成工作。但是这样的代码容易出错，并且难以维护。我想知道你们是否有任何工具或库或一些优雅的解决方案可以推荐。
非常感谢！华

4

1 回答 1

1

如果我正确理解您的问题，那么您有一种方法可以循环遍历 possible templateFields。那没有必要。

由于 everyfieldArray[0]与某些Constants值进行比较，并且如果匹配被进一步处理，我们可以将 for 循环替换为 a Map。它的键是可能的Constants值，它的值是映射器。映射器是一个BiFunction，它接受object和 的值，fieldArray[1]并为这些返回一个类型的消息String。

让我们从映射器开始：

public class FieldToMessageMapper {

    private static final Map<String, Function<String, String>> WORKINGTYPE_MESSAGE_MAPPER = new HashMap<>();
    static {
      WORKINGTYPE_MESSAGE_MAPPER.put("abc", fieldArray1 -> rightPad("a", Integer.parseInt(fieldArray1)));
      WORKINGTYPE_MESSAGE_MAPPER.put("def", fieldArray1 -> rightPad("d", Integer.parseInt(fieldArray1)));
      WORKINGTYPE_MESSAGE_MAPPER.put("DEFAULT", fieldArray1 -> rightPad("g", Integer.parseInt(fieldArray1)));
    }

    private static Map<String, BiFunction<MyObject, String, String>> MESSAGE_MAPPER = new HashMap<>();
    static {
      MESSAGE_MAPPER.put(Constants.WORKFLOW, (o, fieldArray1) -> rightPad(o.getFieldOne(), Integer.parseInt(fieldArray1)));
      MESSAGE_MAPPER.put(Constants.WORKVOLUME, (o, fieldArray1) -> rightPad(o.getFieldTwo(), Integer.parseInt(fieldArray1)));
      MESSAGE_MAPPER.put(Constants.WORKTYPE,
        (o, fieldArray1) -> WORKINGTYPE_MESSAGE_MAPPER.getOrDefault(o.getFieldThree().toLowerCase(), WORKINGTYPE_MESSAGE_MAPPER.get("DEFAULT")).apply(fieldArray1));
    }

    public static Optional<String> map(MyObject o, String fieldArray0, String fieldArray1) {
      return Optional.ofNullable(MESSAGE_MAPPER.get(fieldArray0.toLowerCase()))
        .map(mapper -> mapper.apply(o, fieldArray1));
    }

    private static String rightPad(String string, int pad) {
        // TODO right pad
        return string;
    }
  }

我们不返回映射器本身。FieldToMessageMapper提供map进行映射的方法。Optional<String>如果输入没有映射，它会返回一个显示结果可能为空的结果。
为了确保获得独立于字符大小写的映射器，所有键都是String..toLowerCase().

让我们继续整体处理：

  protected StringBuffer process(Collection<String> templateFields, MyObject object) {
    StringBuffer message = new StringBuffer(1000);
    for (String field : templateFields) {
      String[] fieldArray = field.split(Constants.SEPARATOR);
      String msg = FieldToMessageMapper.map(object, fieldArray[0], fieldArray[1])
        .orElseThrow(() -> new IllegalArgumentException(String.format("Unsupported field %s", field)));
      message.append(msg);
    }
    return message;
  }

我不知道您需要如何处理丢失的映射。我选择通过抛出异常快速失败。

请注意：StringBuffer是

一个线程安全的、可变的字符序列。字符串缓冲区类似于String，但可以修改。

如果您的处理不是多线程的，您可以使用StringBuilder. 如果结果没有进一步修改，您可以使用String.

让我展示另一个使用Streamwhich 返回 a的替代方法String：

  protected String process(Collection<String> templateFields, MyObject object) {
    return templateFields.stream()
      .map(field -> field.split(Constants.SEPARATOR))
      .map(fieldArray -> FieldToMessageMapper.map(object, fieldArray[0], fieldArray[1])
        .orElseThrow(() -> new IllegalArgumentException(String.format("Unsupported field %s", Arrays.toString(fieldArray)))))
      .collect(Collectors.joining());
  }

如果我从问题中得到了正确的代码，则应该有以下实现Constants：

  public class Constants {
    public static final String SEPARATOR = ",";
    public static final String WORKFLOW = "field1";
    public static final String WORKVOLUME = "filed2";
    public static final String WORKTYPE = "field3";
  }

编辑：

如果您想要一种配置方法，您可以进一步详细说明此代码以使用 Spring 配置：

  1. 定义一个接口MessageMapper，它有两个方法：String getKey()和String map(MyObject o, String fieldArray1)。getKey()返回Constants映射器为其提供映射的值。
  2. MESSAGE_MAPPER使用此接口实现上述每个。
  3. 添加一个CommonMessageMapper具有构造函数的CommonMessageMapper(MessageMapper... messageMappers)。messageMappers必须放在一个Map<String, BiFunction<MyObject, String, String>> mapperslike:中mappers.put(messageMapper.getKey(), messageMapper)。定义一个使用:String map(MyObject o, String fieldArray0, String fieldArray1)查找适当的方法。然后调用。（当没有合适的映射器存在时，您也可以在此处使用 an来处理这种情况。）MessageMapper mmfieldArray0MessageMapper mm = mappers.get(fieldArray0)mm.map(o, feldArray1)Optional
  4. 要使用 Spring 配置 allMessageMapper并且CommonMessageMapper必须将其注释为Bean或Component。的构造函数CommonMessageMapper必须用 注释@Autowired。
  5. 定义一个 Spring 配置（使用 XML 或 as @Configuration），它将将所需的内容注入MessageMapper到 aCommonMessageMapper中，并为此类 a 提供工厂方法CommonMessageMapper。
  6. 使用CommonMessageMapper而不是FieldToMessageMapper上面。
于 2018-11-08T20:56:41.290 回答