在带有 Websocket 的 Play Framework 中使用 Try/Catch 时出错

Question

我在 Scala 中使用带有 Play Framework 的 Web 套接字。我想在我的项目中使用Try/Catch 功能来捕获一些Exceptions，例如Server Exception、Network Exception 等。

我做了什么：

WebSocketController.scala

object LoginWS {
  def props(out: ActorRef) = Props(new LoginWS(out))
}

class LoginWS(out: ActorRef) extends Actor {
  def receive = { 
    case json_req: JsObject =>
      var user_name = (json_req \ "user_name").as[String]
      var password = (json_req \ "password").as[String]
      var source = (json_req \ "source_type").as[String]
      var result = UserLogin.authenticateUser(user_name, password).isDefined
      var userID: Int = 0;
      if(result) {
        userID = UserLogin.getUserRole(user_name, password)
        val login_status : String = "Success"            
        out ! Json.toJson(JsObject(Seq("login_status" -> JsString(login_status), "user_id" -> JsNumber(userID))))
      }
      else {
        val login_status : String = "Failure"
        out ! Json.toJson(JsObject(Seq("login_status" -> JsString(login_status), "user_id" -> JsNumber(userID))))
      }
  }      
}  

object WebSocketController extends Controller {            
  def login = WebSocket.acceptWithActor[JsValue, JsValue] { request => 
    out => LoginWS.props(out)
  }   
}

我尝试了什么：

我使用了this answer posted by Ende Neu，但它显示not found: value APIAction。注意：我也在 routes 文件中添加了 APIAction

代码：

class LoginWS(out: ActorRef) extends Actor {
  def receive = APIAction { request
    case json_req: JsObject =>
     .....
     ....//code here
  }

}
object WebSocketController extends Controller {

  def login = WebSocket.acceptWithActor[JsValue, JsValue] { request =>
    out => LoginWS.props(out)
  } 

  def APIAction(f: Request[AnyContent] => Result): Action[AnyContent] = 
    Action { request =>
      Try(f(request))
        .getOrElse(
          InternalServerError(Json.obj("code" -> "500", "message" -> "Server error"))
        )
    }    
}

请帮助我在Web socket 中实现 Try/Catch 功能

Answer 1

登录请求在actor内部处理，我认为你应该在那里处理你的错误。如果您想捕获所有异常而不是明确处理可能出现的问题，我建议您执行以下操作

object SomeUtils {
  def catchAll[A](out: ActorRef)(f: => A): Unit = {
    val message = Try(f).getOrElse(Json.obj("code" -> "500", "message" -> "Server error"))
    out ! message
  }
}


import SomeUtils._

class LoginWS(out: ActorRef) extends Actor {
  def receive = {
    case json_req: JsObject => catchAll(out) {
      val userName = (json_req \ "user_name").as[String]
      val password = (json_req \ "password").as[String]
      val authenticated = UserLogin.authenticateUser(userName, password).isDefined
      if (authenticated) {
        val role = UserLogin.getUserRole(userName, password)
        Json.obj("login_status" -> "Success", "result" -> role)
      }
      else {
        Json.obj("login_status" -> "Failure", "result" -> 0)
      }
    }
  }
}

在处理jsonReq 时，使用catchAll 方法会期望获得结果的接收者，而这个结果可能会抛出Exception。如果是Exception，它将使用带有内部服务器错误的默认消息，并将此消息发送给接收者。

您还可以将 out 参数设为隐式，以跳过将其放在任何地方。此外，您的代码也不是真正的 scala 风格。使用vars 等...

如果发送到 WS 的 json 无法解析，它会在到达您的代码之前抛出异常，可以在此处找到解决方案：

How do I catch json parse error when using acceptWithActor?