java - Guice 服务依赖关系

Question

我有三个 guava Service，它们由 guava ServiceManager 异步启动。

第一个服务是数据库连接池，需要在第二个/第三个服务成功处理传入消息之前完全启动。显然，如果这些服务是异步启动的，那么在第二个/第三个服务开始处理消息之前，数据库可能尚未完全启动，这将导致异常。

这里想要的模式是什么？

我可以将数据库服务注入(inject)到其他服务中，并在服务启动时调用 awaitRunning() 方法，但是当 ServiceManager 关闭时，我会遇到同样的问题。

Answer 1

我相信 guice 没有为此提供开箱即用的机制。 Spring 例如有一个depends-on属性可以定义一些排序。有些框架也可以通过 guice 为您提供此功能(例如 dropwizard guicey 实现订单注释)。然而，解决这个问题相当简单。

该方法是使用多重绑定(bind)来为所有依赖类定义管理器。我将其称为托管(从 jetty 采用)。该接口(interface)将实现排序。然后，我们使用一个管理器，以明确定义的顺序逐一启动所有服务(如果需要，也可以用于关闭)。

请在此处查看我的代码示例:

public class ExecutionOrder {

    public static void main(String[] args) {

        Injector createInjector = Guice.createInjector(new AbstractModule() {
            @Override
            protected void configure() {
                Multibinder<Managed> multiBinder = Multibinder.newSetBinder(binder(), Managed.class);
                multiBinder.addBinding().to(Service1.class);
                multiBinder.addBinding().to(Service2.class);

                bind(ManagedManager.class).in(Singleton.class);
            }
        });

        createInjector.getInstance(ManagedManager.class); // start it
    }

    public interface Managed extends Comparable<Managed> {

        public default void start() {}
        public default int getOrder() { return 0;}

        @Override
        default int compareTo(Managed o) {
            return Integer.compare(getOrder(), o.getOrder());
        }
    }

    public static class ManagedManager {
        @Inject
        public ManagedManager(final Set<Managed> managed) {
            managed.stream().sorted().forEach(Managed::start);
        }

    }

    public static class Service1 implements Managed {

        @Override
        public void start() {
            System.out.println("Started Service 1");
        }

        @Override
        public int getOrder() {
            return 1;
        }
    }

    public static class Service2 implements Managed {

        @Override
        public void start() {
            System.out.println("Started Service 2");
        }

        @Override
        public int getOrder() {
            return 2;
        }
    }
}

我的 - 诚然是愚蠢的命名 - ManagedManager 由 guice 注入(inject)所有托管接口(interface)，使用 guice 的多重绑定(bind)(请参阅我初始化的模块)。然后我对其进行排序并调用开始。

启动方法是您初始化服务的地方(例如数据库连接)。通过重写 getOrder() 方法，您可以定义在哪个点启动哪个服务。

通过这种方式，您可以获得明确定义的启动行为，并且可以调整界面以具有明确定义的关闭行为。

希望这对您有所帮助，

阿图尔