java - 如何在 Spring 中使用 Autowiring 的 bean 创建简单工厂模式？

Question

我有一个具有 4 个非常相似方法的 Controller ，调用远程服务器上的 API 以对不同类型的用户执行不同的操作。这些 API 调用之间的变化只是端点和一些参数。

因此，这 4 个方法都使用非常相似的代码调用服务:它们从服务器获取 token 、设置参数、返回 API 的响应。由于稍后会添加更多操作，我决定使用工厂方法模式创建一个 ServiceFactory，并在服务上使用模板模式以避免代码重复。

我的问题是，为了让工厂 Autowiring 服务，它需要耦合到它们，我必须 @Autowire 每个实现。有更好的解决方案吗？

这是我目前的代码:

休息 Controller

@RestController
public class ActionController {
  @Autowired
  private SsoService ssoService;

  // this is the factory
  @Autowired
  private ServiceFactory factory;

  @PostMapping("/action")
  public MyResponse performAction(@RequestBody MyRequest request, HttpServletRequest req) {
    // template code (error treatment not included)
    request.setOperator(ssoService.getOperator(req));
    request.setDate(LocalDateTime.now());
    return serviceFactory.getService(request).do();
  }
}

服务工厂

@Component
public class ServiceFactory {

  @Autowired private ActivateUserService activateUserService;
  @Autowired private Action2UserType2Service anotherService;
  //etc

  public MyService getService(request) {
    if (Action.ACTIVATE.equals(request.getAction()) && UserType.USER.equals(request.getUserType()) {
      return activateUserService;
    }
    // etc
    return anotherService;
  }
}

Service Base，实现MyService接口(interface)

public abstract class ServiceBase implements MyService {

  @Autowired private ApiService apiService;
  @Autowired private ActionRepository actionRepository;
  @Value("${api.path}") private String path;

  @Override
  public MyResponse do(MyRequest request) {
    String url = path + getEndpoint();
    String token = apiService.getToken();

    Map<String, String> params = getParams(request);
    // adds the common params to the hashmap

    HttpResult result = apiService.post(url, params); 
    if (result.getStatusCode() == 200) {
      // saves the performed action
      actionRepository.save(getAction());
    }
    // extracts the response from the HttpResult
    return response;
  }
}

服务实现(有4个)

@Service
public class ActivateUserService extends ServiceBase {
  @Value("${api.user.activate}")
  private String endpoint;

  @Override
  public String getEndpoint() {
    return endpoint;
  }

  @Override
  public Map<String,String> getParams(MyRequest request) {
    Map<String, String> params = new HashMap<>();
    // adds custom params
    return params;
  }

  @Override
  public Action getAction() {
    return new Action().type(ActionType.ACTIVATED).userType(UserType.USER);
  }
}

Answer 1

您可以@Autowired MyService 的List，这将创建一个包含所有实现的bean 的List MyService 接口(interface)。然后，您可以向 MyService 添加一个方法，该方法接受一个 MyRequest 对象并决定它是否可以处理该请求。然后，您可以过滤 MyService 的 List 以找到可以处理请求的第一个 MyService 对象。

例如:

public interface MyService {

    public boolean canHandle(MyRequest request);

    // ...existing methods...
}

@Service
public class ActivateUserService extends ServiceBase {

    @Override
    public boolean canHandle(MyRequest request) {
        return Action.ACTIVATE.equals(request.getAction()) && UserType.USER.equals(request.getUserType());
    }

    // ...existing methods...
}

@Component
public class ServiceFactory {

    @Autowired
    private List<MyService> myServices;

    public Optional<MyService> getService(MyRequest request) {
        return myServices.stream()
            .filter(service -> service.canHandle(request))
            .findFirst();
    }
}

请注意，上面的 ServiceFactory 实现使用 Java 8+。如果无法使用 Java 8 或更高版本，您可以按以下方式实现 ServiceFactory 类:

@Component
public class ServiceFactory {

    @Autowired
    private List<MyService> myServices;

    public Optional<MyService> getService(MyRequest request) {

        for (MyService service: myServices) {
            if (service.canHandle(request)) {
                return Optional.of(service);
            }
        }

        return Optional.empty();
}

有关将 @Autowired 与 List 一起使用的更多信息，请参阅 Autowire reference beans into list by type .

---

此解决方案的核心是移动决定 MyService 实现是否可以处理来自 ServiceFactory(外部客户端)的 MyRequest 的逻辑) 到 MyService 实现本身。