使用Play 2.5 scala、死栓2.5和MongoDB/Mor体的死锁

Question

基本上，我想要做的就是从我的数据库中获取所有用户，直到我想要使用死栓的那一刻，数据库才正常工作：

我认为分叉连接执行器的4个线程(处理器数目)已经全部被使用了，然后出现了某种死锁。我试过的事情：

• 提高执行程序的线程数，但是play/akka忽略我的设置
• 为控制器中的未来定义另一个执行上下文，但这并不能防止死锁，因为超过四个线程仍在彼此等待。
• 使用线程池执行器，但我的设置被忽略。

这里有一个混合scala/java代码：

class UserController {
     def getUserList = deadbolt.Restrict(List(Array("Admin")))(){ implicit request =>
        Future {
          val users = userModel.list
          val json = Json.toJson(users)
          Ok(json.toString)
        }(
      }
}

用户模型本质上不过是：

public class UserModel {
  private MongoClient client  = new MongoClient();
    private Morphia morphia = new Morphia();
    protected Datastore datastore = morphia.createDatastore(client, "timetracking");
    public List<User> list(){
       return  datastore.find(User.class).asList();
    }
  public User findUserByName(String name){
    User found = datastore.createQuery(User.class).field("username").equal(name).get();
    return found;
    }
}

授权处理程序：

class AuthorizationHandler extends DeadboltHandler {
  val model = new UserModel

  override def getSubject[A](request: AuthenticatedRequest[A]): Future[Option[Subject]] =
    Future {
      blocking {
        request.subject match {
          case Some(user) =>
            request.subject
          case None =>
            val username = request.session.get("username")
            if (username.isDefined) {
              val user = model.findUserByName(username.get)
              if (user == null) {
                  None
              } else {
                val subject = new ScalaSubject(user.getUsername, user.getRole)
                Some(subject)
              }
            } else {
              None
            }
        }
      }
    }

定义单独的死栓上下文无助于：

package deadbolt.scala
import be.objectify.deadbolt.scala.DeadboltExecutionContextProvider
import be.objectify.deadbolt.scala.cache.HandlerCache
import play.api.inject.{Binding, Module}
import play.api.{Configuration, Environment}

class DeadBoldModule extends Module {
  override def bindings(environment: Environment,
                        configuration: Configuration): Seq[Binding[_]] = Seq(
      bind[HandlerCache].to[TimeTrackerHandelCache],
      bind[DeadboltExecutionContextProvider].to[ThreadPoolProvider]
  )
}

自定义上下文提供程序：

package deadbolt.scala
import java.io.InvalidObjectException
import java.util.concurrent.Executors
import be.objectify.deadbolt.scala.DeadboltExecutionContextProvider
import scala.concurrent.ExecutionContext

class ThreadPoolProvider  extends DeadboltExecutionContextProvider {
  override def get(): ExecutionContext =  ExecutionContext.fromExecutor(Executors.newFixedThreadPool(100))
}

当我尝试这样做时，抛出一些随机异常，它就不会被抛出：

package deadbolt.scala
import java.io.InvalidObjectException
import java.util.concurrent.Executors
import be.objectify.deadbolt.scala.DeadboltExecutionContextProvider
import scala.concurrent.ExecutionContext

class ThreadPoolProvider  extends DeadboltExecutionContextProvider {
  override def get(): ExecutionContext = throw new IllegalAccessError("asd");ExecutionContext.fromExecutor(Executors.newFixedThreadPool(100))
}

Answer 1

这不是死螺栓故障，但是MongoClient在我们的项目中经常发生instantiated.Which时打开了一个新线程，但是没有正确关闭，从而阻塞了线程池。我们用的是单子，一切都很好。