어떻게 서 비 스 를 빠르게 시작 합 니까?

， 。 를 되 돌려 주 는 과정 이다.반복 적 으로 불 러 오 는 과정 을 피하 기 위해 서, 실제로 우 리 는 이러한 서 비 스 를 하나의 서비스 용기 에 넣 을 것 이다. 서비스의 불 러 오 는 것 은 용기 처리 가 있 을 것 이다. 우리 가 해 야 할 일 은 단지 하나의 용기 에서 그것들 을 찾 는 것 이다.예 를 들 어 위의 그림 에서 C, E 는 모두 B 에 의존 했다.
대부분의 응용 서 비 스 는 필요 에 따라 불 러 오 는 모델 을 선택 합 니 다. 여러 서 비 스 를 동시에 불 러 오지 못 하 는 문 제 를 피 할 수 있 을 뿐만 아니 라 필요 에 따라 불 러 오 는 것 은 실제 적 으로 방문 하지 않 은 서 비 스 를 불 러 오지 않 기 때문에 일부 자원 을 효과적으로 절약 할 수 있 습 니 다.
하지만 이것 이 궁 극적인 방안 인가?분명히 아니 야!다음은 세 번 째 모델 을 알 아 보 겠 습 니 다.
그룹 로 딩
그룹 로 딩 은 서 비 스 를 의존 하 는 등급 에 따라 서로 다른 것 으로 나 누 는 것 이다 ServiceGroup.ServiceGroup 사 이 는 순서대로 불 러 오지 만 ServiceGroup 내의 서 비 스 는 병렬 로 불 러 옵 니 다.이런 방식 은 모든 서 비 스 를 한꺼번에 불 러 올 수 있다.필요 에 따라 불 러 오 는 것 과 달리 그룹 로 딩 은 시작 이 성공 할 때 바로 서 비 스 를 할 수 있 습 니 다.동시에 순서대로 불 러 오 면 서 비 스 를 더욱 빠르게 시작 할 수 있 습 니 다.다음 그림 에서 ServiceGroup 1 중의 A, B, 'C' 는 병렬 로 로드 되 었 고 ServiceGroup 2 는 ServiceGroup 1 로드 가 완 료 된 후에 야 로드 되 기 시작 했다.
서비스 A, B, D 사이 에 의존 하지 않 기 때문에 로 딩 은 무질서 할 수 있 습 니 다.ServiceGroup 1 로드 가 완료 되면 ServiceGroup 2 로드 하기 전에 필요 한 서 비 스 를 불 러 왔 습 니 다.이 럴 때 는 문제 가 없 을 것 이다 ServiceNotFound.다음 코드 는 DSL 을 사용 하여 전체 로 딩 과정 을 설명 합 니 다.

GroupedServiceBus serviceBus = ...
serviceBus.start(serviceA, serviceB, serviceD)
          .then(serviceC, serviceE)
          .awaitStarted();

import com.google.common.util.concurrent.Service;

public interface GroupedServiceBus {
    void awaitStarted();

    void awaitStopped();

    GroupedServiceBus start(Service... services);

    GroupedServiceBus then(Service... services);

    GroupedServiceBus awaitServiceGroupStarted(Service... services);

}

public interface KernelService {

}

public class GroupedServiceBusImpl implements GroupedServiceBus {

    private final List serviceCluster = new ArrayList<>();
    private final ServiceManager.Listener listener = new ServiceManager.Listener() {
        @Override
        public void failure(Service service) {
            if (service instanceof KernelService) {
                logger.error("KernelService [{}] start failure, system will be exit 1.", service.getClass());
                System.exit(1);
            } else {
                logger.error("Service [{}] start failure.", service.getClass());
            }
        }
    };

    @Override
    public void awaitStarted() {
        if (!serviceCluster.isEmpty()) {
            for (final ServiceManager serviceManager : serviceCluster) {
                awaitStartedServiceManager(serviceManager);
            }
        }
    }

    @Override
    public void awaitStopped() {
        if (!serviceCluster.isEmpty()) {
            for (int i = serviceCluster.size() - 1; i > -1; i--) {
                final ServiceManager serviceManager = serviceCluster.get(i);
                serviceManager.stopAsync();
                serviceManager.awaitStopped();
            }
            serviceCluster.clear();
        }
    }

    @Override
    public GroupedServiceBus start(final Service... services) {
        then(services);
        return this;
    }

    @Override
    public GroupedServiceBus then(Service... services) {
        final ServiceManager serviceManager = new ServiceManager(ImmutableList.copyOf(services));
        serviceManager.addListener(listener);
        serviceCluster.add(serviceManager);
        return this;
    }

    private void awaitStartedServiceManager(final ServiceManager serviceManager) {
        if (!serviceManager.isHealthy()) {
            serviceManager.startAsync();
            serviceManager.awaitHealthy();
        }
    }
}