根据配置文件来切换不一样服务的实现

在MicroService开发中常常会遇到一个问题,本身的服务须要调用其它小组的服务,可是其余小组的服务尚未完成。为了避免耽误进度,咱们就须要先实现一个Mock的服务,最后再切换到真正的外部服务上去。同时,一旦外部服务出现问题,为了避免阻塞本地开发,咱们须要很方便的切换到Mock服务上去。经过修改配置文件里面的内容,能够实现不修改代码来切换不一样的服务。java


通用服务接口:ide

public interface OrderAtpChecker {
    /**
     * @param order  order to be checked by ATP
     * @param tenant tenant id for client
     * @return a map whose key is the order line id and value is the validity of its apt check result
     */
    Map<OrderLineId, Boolean> atpCheck(Order order, String tenant);

    String getType();
}

不一样的服务实现:this

public class MockOrderAtpChecker implements OrderAtpChecker {
    @Override
    public Map<OrderLineId, Boolean> atpCheck(final Order order, final String tenant) {
        if (null == order) {
            throw new IllegalArgumentException("Can't atp check a null order.");
        }
        return order.getOrderLines().parallelStream()
                .collect(toMap(OrderLine::getId, o -> o.getQuantity() < 100));
    }

    @Override
    public String getType() {
        return "Mock";
    }
}
public class OrderAtpChecker implements OrderAtpChecker {
    @Override
    public Map<OrderLineId, Boolean> atpCheck(final Order order, final String tenant) {
        ............
    }

    @Override
    public String getType() {
        return "Inventory";
    }
}

Service Factory的实现:接口

@Service
public class InventoryServiceFactory {
    @Autowired
    private List<OrderAtpChecker> services;

    private static final Map<String, OrderAtpChecker> myServiceCache = new HashMap<>();

    @PostConstruct
    public void initMyServiceCache() {
        for (final OrderAtpChecker service : this.services) {
            myServiceCache.put(service.getType(), service);
        }
    }

    public static OrderAtpChecker getService(final String type) {
        final OrderAtpChecker service = myServiceCache.get(type);
        if (service == null) throw new RuntimeException("Unknown service type: " + type);
        return service;
    }
}

具体调用服务的地方:
开发

@Value("${inventory_service}")
private String serviceType;
private OrderAtpChecker orderAtpChecker;
this.orderAtpChecker = InventoryServiceFactory.getService(this.serviceType);
相关文章
相关标签/搜索