在使用Websocket的Play框架中使用Try/Catch时出错

Question

我在Scala中使用web套接字和Play框架。我想在我的项目中使用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)
  }   
}

What I tried:

我已经使用了这个由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无法解析，它会在到达你的代码之前抛出异常，解决方案可以在这里找到:

我如何捕获json解析错误时使用acceptWithActor?