java - 是否有一种设计模式支持注入(inject)多个抽象类实现并有条件地使用注入(inject)的bean之一

Question

我正在进行一个使用 Java 和 Spring Boot 的项目，该项目处理来自同一队列的几种不同的消息类型。每条消息都会根据消息类型有条件地进行处理，并为每种消息类型使用 MessageProcessingService 抽象类的实现。

到目前为止，我们有 5 种不同的消息类型进入同一个消费者。我们使用相同的队列，因为我们利用 JMS 中的组策略，并且每种消息类型都具有与组策略相同的业务 key 。

因此，我们最终得到的是，每次需求需要接收新的消息类型时，我们都会添加 MessageProcessingService 的新实现以及对消费者对象的另一个依赖项。我想找到一个更好的策略来选择性地选择消息处理

这是一个与我们正在做的类似的示例。我不保证语法是可编译的或语法上完美的，只是演示问题。请注意，所有消息都围绕一个人解析

消费者:

@Component
public class PersonMessageConsumer {
  private MessageProcessingService<HeightUpdate> heightUpdateMessageProcessingService;
  private MessageProcessingService<WeightUpdate> weightUpdateMessageProcessingService;
  private MessageProcessingService<NameUpdate>   nameUpdateMessageProcessingService;
  private MessageProcessingService<ShowSizeUpdate> shoeSizeUpdateMessageProcessingService;

  public PersonMessageConsumer(
         MessageProcessingService<HeightUpdate> heightUpdateMessageProcessingService,
         MessageProcessingService<WeightUpdate> weightUpdateMessageProcessingService,
         MessageProcessingService<NameUpdate>   nameUpdateMessageProcessingService,
         MessageProcessingService<ShowSizeUpdate> shoeSizeUpdateMessageProcessingService) {

    this.heightUpdateMessageProcessingService = heightUpdateMessageProcessingService;
    this.weightUpdateMessageProcessingService = weightUpdateMessageProcessingService;
    this.nameUpdateMessageProcessingService = nameUpdateMessageProcessingService;
    this.shoeSizeUpdateMessageProcessingService = shoeSizeUpdateMessageProcessingService;
  }

  @JmsListener(destination = "${queueName}")
  public void receiveMessage(TextMessage message) {
    String messageType = message.getHeader("MessageType");
    switch (messageType) {
      case "HeightUpdate":
        heightUpdateMessageProcessingService.processMessage(message.getText());
        return;
      case "WeightUpdate":
        weightUpdateMessageProcessingServivce.processMessage(message.getText());
        return;
      // And other message types
      default: 
        throw new UnknownMessageTypeException(messageType);
  }
}

消息 POJO 示例

public class HeightUpdate implements PersonMessage {
  @Getter
  @Setter
  private int height;
}

PersonMessage接口(interface)

public interface PersonMessage {
  int getPersonId();
}

消息处理服务

public abstract class MessageProcessingService<T extends PersonMessage> {

  public void processMessage(String messageText) {
    //Common message processing, we do some more involved work here but just as a simple example
    T message = new ObjectMapper.readValue(messageText, getClassType());

    Person person = personRepository.load(message.getPersonId());
    Person originalPerson = person.deepCopy();
    processMessageLogic(person, message);

    if (originalPerson.isDifferentFrom(person)) { 
      personRespository.update(person);
    } 
  }

  protected abstract void processMessageLogic(Person person, T message);

  protected abstract Class getClassType();
}

抽象类实现示例

@Service("heightUpdateMessageProcessingService")
public class HeightUpdateMessageProcessingService extends MessageProcessingService<HeightUpdate> {
  @Override
  protected void processMessageLogic(Person person, HeightUpdate update) {
    person.setHeight(update.getHeight());
  }

  @Override
  protected Class getMessageType() {
    return HeightUpdate.getClass();
  }
}

所以我的问题是是否有更好的设计模式或在 java 和 spring 中编码的方法，它更容易清理和维护，并牢记 SOLID 原则

Answer 1

1. 在MessageProcessingService中添加一个抽象方法返回 messageType每个具体实现都可以处理。
2. 而不是将每个单独的服务连接到 PersonMessageConsumer ，接线 List<MessageProcessingService>这样您就可以一次获得所有这些。
3. 改变 List进入Map<String, MessageProcessingService> ，使用messageType作为 key 。
4. 替换switch通过在Map中查找适当的服务来声明然后调用它的processMessage方法。

将来您可以添加 MessageProcessingService 的新实例无需编辑PersonMessageConsumer因为 Spring 会自动将这些新实例添加到 List<MessageProcessingService>您输入的内容。