在分布式系统中终止会话的正确方法

Question

我正在开发一个分布式 java 项目，该项目使用 AKKA 框架并在 dropwizard 服务器上运行。我在应用程序启动时创建一个会话，并通过以下方式在我的所有演员中使用这个会话

MyApplication.java

    public void run() {
      final Session actorSession = hibernate.getSessionFactory()
            .openSession();
     // pass this session to various actors
      final ActorSystem system = ActorSystem.create("myActorSystem");
      environment.lifecycle().manage(new ActorSystemGuardian(system));

      system.registerOnTermination(new Runnable() {
            public void run() {
            //Clean all resources after actor termination
            actorSession.close();
        }

ActorSystemGuardan.java

  public class ActorSystemGuardian implements Managed {
    private ActorSystem system;
    public ActorSystemManager(ActorSystem system) {
      this.system = system;
    }

    public void start() throws Exception {

    }

    public void stop() throws Exception {
      system.shutdown();

   }

}

这是否确保正确清理所有资源？ actorSession 会关闭吗？在应用程序的整个生命周期中，所有参与者都需要使用相同的会话。有没有办法让这个会话持久化？

Answer 1

我通过以下方式传递 sessionFactory 而不是会话来解决问题

final SessionFactory actorSessionFactory = hibernate.getSessionFactory()

然后可以使用该工厂生成临时会话，这些会话可以（应该）在使用后关闭。

system.registerOnTermination(new Runnable() {
        public void run() {
        //Clean all resources after actor termination

    }

system.registerOnTermination(new Runnable) 仅在 actor 系统关闭时调用，不应与会话绑定。

在分布式系统中终止会话的正确方法

Correct way to kill a session in a distributed system

mysql

session

shutdown

broken-pipe

dropwizard