当执行元返回未来时引发异常[Option[None]] Akka Http
当执行元返回未来时引发异常[Option[None]] Akka Http。
Akka Http是一种基于Akka框架的高性能、异步、可扩展的HTTP服务器和客户端库。它提供了一种简单而强大的方式来构建和处理HTTP服务和请求。在使用Akka Http时，有时可能会遇到"当执行元返回未来时引发异常[Option[None]]"的情况。
这个异常通常发生在使用Akka Http的路由处理过程中，当处理请求时，可能会返回一个Future[Option[T]]类型的结果。这个Future表示一个异步操作，而Option表示可能存在或不存在的值。当执行这个Future时，如果返回的是None，即表示没有找到对应的值，这时就会抛出"当执行元返回未来时引发异常[Option[None]]"的异常。
这个异常的原因可能是由于路由处理逻辑中的某些错误导致的，比如在数据库查询中没有找到对应的记录。为了解决这个异常，可以通过在路由处理逻辑中添加错误处理机制来处理这种情况，例如返回一个合适的错误响应或者进行重试操作。
在使用Akka Http时，可以结合腾讯云的相关产品来构建和部署高性能的HTTP服务。腾讯云提供了一系列云计算产品，包括云服务器、云数据库、云存储等，可以满足不同场景下的需求。
推荐的腾讯云相关产品：
- 云服务器（CVM）：提供高性能、可扩展的云服务器实例，可以用于部署和运行Akka Http应用程序。了解更多：腾讯云云服务器
- 云数据库MySQL版（CDB）：提供稳定可靠的云数据库服务，可以用于存储和管理应用程序的数据。了解更多：腾讯云云数据库MySQL版
- 云对象存储（COS）：提供安全可靠的云存储服务，可以用于存储和管理应用程序的静态资源和文件。了解更多：腾讯云云对象存储
通过结合使用这些腾讯云产品，可以构建一个完善的、高性能的Akka Http应用程序，并且能够处理"当执行元返回未来时引发异常[Option[None]]"这样的异常情况。
相关·内容
在akka.cluster.sharding.ClusterSharding.shardRegion(ClusterSharding.scala:512) ~akka-cluster-sharding_2.11-2.5.13.jar:2.5.13
在akka集群环境中启动服务器时发生异常。
浏览 0提问于2020-06-30得票数 0
在另一个Actor的上下文中查找对子Actor的引用非常简单，使用如下代码：
val foo = context.child("foo") match {
case None => createFoo
case Some(c) => c
}
我遇到的问题是我正在使用Akka.system从我的控制器中创建我的第一个Actor，它看起来像这样：
val myActor = Akka.system.actorOf(Props(new MyActor(anId)), s"id-${anId}")
现在，当我的控制器被多次调用
浏览 2提问于2013-10-17得票数 1
我正在学习Akka库，我使用Play框架在我的系统中安装了一个本地服务器，我正在使用Akka库编写客户机应用程序。
implicit val system = ActorSystem("testing")
implicit val materializer = ActorMaterializer()
import system.dispatcher
val serverHttpRequests = files.map { file =>
(
HttpRequest (
HttpMethods.POST,
uri = Uri(U
浏览 4提问于2020-07-09得票数 0
回答已采纳
我试图分析一个来自阿克卡的HttpResponse。理想的行为是，如果响应成功返回，则传递HttpEntity的HttpEntity表示以进行处理。但是，如果状态返回为失败，则传递一个带有异常的Future.failed，其中包含状态代码和HttpEntity的JSON树表示。传递JSON树的原因是，这个抽象请求方法击中了不同的服务器，它们的响应格式也不同，所以我想在其他类中处理响应的解析。
我尝试过对这个工作流进行各种操作。直接抛出异常，而不是返回Future.failed，将返回一个None值，代替异常中的JSON树。其他方法也产生了类似的结果。当我println(MAPPER.readT
浏览 0提问于2019-02-12得票数 0
回答已采纳
1回答
我有一个rest控制器，它调用一个服务，然后调用一个参与者从一个模拟数据库中获取一个查询。消息到达了参与者，但是应用程序在参与者能够响应之前就崩溃了，并且有一个空指针异常来自于参与者。我使用akka http作为控制器和路由指令来组成响应。这些是我的依赖：
"com.typesafe.akka" %% "akka-http" % "10.1.8",
"com.typesafe.akka" %% "akka-actor" % "2.5.22",
"com.typesafe.akka
浏览 0提问于2019-05-12得票数 0
回答已采纳
我使用的是akka http，我的其中一个路由是通过akka http客户端api与外部服务交互，而httpRequest仍在持续运行。我的用例是->。我正在与janus服务器交互，并在服务器返回'keepAlive‘或我再次请求的事件时立即执行长轮询get请求，依此类推，服务器将继续响应
所有这些都发生在参与者内部，我有一个akka htttp路由，它初始化第一个请求
以下是我的代码
final case class CreateLongPollRequest(sessionId:BigInt)
class LongPollRequestActor (config: Confi
浏览 3提问于2021-07-30得票数 0
当出现一些意外的异常时，如何避免Akka终止JVM进程？我认为这是一个大问题。
Akka永远不会杀死我的webapp的jvm进程。
我使用的是play framework 2.3。
使用案例：
Uncaught error from thread [SuperActorSystem-akka.actor.default-dispatcher-5] shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled
java.lang.ExceptionInInitializerError
at actors
浏览 4提问于2014-11-12得票数 4
1回答
我尝试使用akka.http.scaladsl.testkit.responseAs来测试一些端点，但是我不知道如何处理org.joda.time.DateTime对象的编组/解组过程。例如，考虑下面的case类：
case class ConfigEntity(id: Option[Int] = None, description: String, key: String, value: String, expirationDate: Option[DateTime] = None)
另外，请考虑以下路由测试：
"retrieve config by id" in new C
浏览 4提问于2017-06-20得票数 1
1回答
我正在尝试使用akka http来生成一个PUT请求，我的rest服务端点在使用curl时可以正常工作，但当我通过创建Http连接来生成它时，会显示超时错误。
import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.model._
import akka.stream.ActorMaterializer
import de.heikoseeberger.akkahttpcirce.CirceSupport
import io.circe.Json
import org.joda
浏览 2提问于2017-05-25得票数 0
我正在使用替罪羊进行静态代码分析，我收到了一条警告消息
fruitless type test: a value of type Option[akka.actor.ActorSystem] cannot also be a akka.actor.ActorSystem
以下是我的代码
object ActorSystemSetting extends ActorSystemSettingTrait{
val config = ConfigFactory.load()
val log = LoggerFactory.getLogger(this.getClass)
var act
浏览 3提问于2018-07-26得票数 1
回答已采纳
1回答
默认情况下，akka-http将json(即{"some_key":""})中的空字符串反序列化为Some("")。
如何使akka-http反序列化应用程序的所有模型中所有Option[String]类型中的空字符串到None
浏览 1提问于2017-12-06得票数 1
回答已采纳
我在Akka 2.5.0上使用了下面的TLS类，但是AkkaSSLConfig在Akk2.6.0和更高版本上被弃用了。
case class TlsContext(
sslContext: SSLContext,
sslConfig: Option[AkkaSSLConfig] = None,
enabledCipherSuites: Option[immutable.Seq[String]] = None,
e
浏览 13提问于2020-02-16得票数 1
在我的存储库函数中，我正在读取一个用户，然后更新该用户：
def update(u: User): Future[Int] = {
this.read(u.id).flatMap {
case Some(existingUser) =>
db.run(
userTable
.filter(_.id === user.id)
.update(user.copy(createdDate = existingUser.createdDate)))
//case None =>
浏览 5提问于2017-07-25得票数 0
回答已采纳
我用akka http创建了一个http服务器，如下所示：
import akka.actor.typed.{ActorRef, ActorSystem}
import akka.http.scaladsl.Http
import akka.http.scaladsl.server.Route
import com.sweetsoft.LoggerActor.Log
import akka.actor.typed.scaladsl.adapter._
import akka.http.scaladsl.Http.ServerBinding
import akka.http.scaladsl.m
浏览 0提问于2019-07-28得票数 0
我有一个简单的Akka http服务器，但我必须设置https支持。我有三个证书文件: Akka中的.crt、.key和..ca包，只有PKCS12示例。我如何处理我拥有的文件？
def initializeWebServer(interface: String,
port: Int) = {
val route : Route =
pathPrefix("secured") {
authenticateOAuth2(realm = "secure site
浏览 3提问于2019-12-30得票数 1
回答已采纳
我试图在intellij ide的sbt- https://github.com/theiterators/akka-http-microservice#akka-http-microservice-example中为这个Akka https://github.com/theiterators/akka-http-microservice#akka-http-microservice-example项目运行一个测试命令，但它显示->版本冲突。如何解决？ 这是build.sbt enablePlugins(JavaAppPackaging , GatlingPlugin)
name
浏览 35提问于2021-04-22得票数 0
我使用的是Play-Framework2.6，我得到的错误/myproject/app/controllers/Application.scala:151:不够
arguments for method apply: (data: akka.stream.scaladsl.Source[akka.util.ByteString, _], contentLength: Option[Long], contentType: Option[String])play.api.http.HttpEntity.Streamed in object Streamed.
[error] Unspecified
浏览 1提问于2019-02-08得票数 0
我试图实现提供的akka-http rest示例，但我坚持使用
[ERROR] [08/28/2016 10:35:34.091] [default-akka.actor.default-dispatcher-8] [akka.actor.ActorSystemImpl(default)] Error during processing of request HttpRequest(HttpMethod(POST),http://127.0.0.1:9000/v1/auth/signIn,List(Host: 127.0.0.1:9000, Connection: keep-alive
浏览 2提问于2016-08-28得票数 0
回答已采纳
2回答
这可能是一个新手的问题，因为我只是从游戏开始。我们可以在akka-http中找到的认证路由的等价物是什么？以下是使用akka-http进行身份验证的路由示例
def oauth2Authenticator(credentials: Credentials): Future[Option[ScalaFirebaseToken]] = {
credentials match {
case p @ Credentials.Provided(token) =>
ImportFirebaseCredentials.decodeToken(token).fla
浏览 41提问于2018-06-04得票数 2
回答已采纳
为什么会抛出“结果为空”异常？难道没有人不应该通过和设置"a“等于零吗？
public void test()
{
Option<string> a = match(
from b in ReturnNull()
select b,
x => x,
() => null
);
}
private Option<string> ReturnNull()
{
return None;
}
浏览 0提问于2018-01-31得票数 1
回答已采纳
在Akka 2.10下，我的日志配置在关机期间被重置...导致潜在重要的消息被写入标准输出，而不是日志记录机制。
例如，下面的代码：
String settings =
"akka.event-handlers = [\"akka.event.slf4j.Slf4jEventHandler\"]\n" +
"akka.actor.provider = \"akka.cluster.ClusterActorRefProvider\"";
Config config = ConfigFactory.pa
浏览 1提问于2013-04-13得票数 0
回答已采纳
当我试图从aka-http返回一个选项结果时遇到了一个问题。
基本上它是一个get，可能有一个404。
pathPrefix("contacts" / Segment) { id =>
get {
contactService.getById(id).map {
case Some(c: ContactDto) => complete(OK -> toResource(c))
case None => complete(HttpResponse(NotFound))
}
}
}
浏览 15提问于2016-08-19得票数 1
我有问题关于演员选择/接待员在新的Akka类型. 在Akka输入之前，我没有使用ActorSelection，因为我在某个地方读到它不是表演性的，所以我通过HashMaps保持对演员的引用，现在我正在阅读Akka输入的文档，我看到另一个机制接待员存在，所以对我来说问题是，它是否也遭受同样的问题ActorSelection和我应该坚持我的旧模式，保持引用演员而不是HashMap，或者现在接待员是去的方式…… 我的特定场景，我的Actor衍生了几个子Actor创建了几个子Actor，如果父Actor钝化或恢复Akka持久性，它应该再次找到对这些子Actor的引用。 你怎么看，如果我换成接待员，我
浏览 20提问于2020-01-10得票数 1
3回答
Xml模板：
@(product: models.Product, productComponents: List[models.ProductComponent])
<product>
<name>@product.name</name>
<tomcatLocation>@product.tomcatLocation</tomcatLocation>
<productComponents>
@for(productComponent <- productComponents) {
&l
浏览 7提问于2012-04-25得票数 2
1回答
请帮助我对元组多参数进行排序。
Tuple = (Option[String],Option[String],Option[String])
示例：
val lst:List[(Option[String],Option[String],Option[String])] = List(
(Some("a"),None,None),
(Some("b"),None,None),
(Some("a"),Some("a"),None),
(Some("a"),Some("b"),None)
浏览 4提问于2016-03-14得票数 1
回答已采纳
我正在编写一个以Option[Credentials]作为参数的身份验证客户端。这个Credentials对象上有一个.token方法，然后我将使用它来构造一个post到端点的HTTP请求。这将返回一个Future[HttpResponse]，然后我需要对其进行验证、解组，然后将其转换回我的返回类型，即Option[String]。
我的第一个想法是使用a来理解，如下所示：
val resp = for {
c <- creds
req <- buildRequest(c.token)
resp <- Http().singleRequest(req)
} yie
浏览 3提问于2018-04-13得票数 0
我正在从代码喷雾(版本：1.3.4)迁移到akka-http (版本：10.0.13)。
我们有一个现有的客户端，他们像Content-Type一样发送application/vnd.awesome.value; mykey="custom/custom"
下面的代码在spray中运行良好，但在akka-http参数(mykey)中被去掉
request.header[`Content-Type`].map { header =>
// HERE PARAMS IS EMPTY MAP
val myKeyValue = header.contentType.med
浏览 5提问于2019-11-28得票数 0
2回答
我正在尝试使用akka http实现一个简单的文件上传。我的尝试如下：
import akka.actor.ActorSystem
import akka.event.{LoggingAdapter, Logging}
import akka.http.scaladsl.Http
import akka.http.scaladsl.model.{HttpResponse, HttpRequest}
import akka.http.scaladsl.model.StatusCodes._
import akka.http.scaladsl.ser
浏览 1提问于2015-10-03得票数 6
回答已采纳
1回答
我正在调用一个web服务，该服务在Akka演员中返回一个Option[Future[String]]。现在，我需要旋转一个新的子演员，并传递这个Option[Future[String]]并停止actor.In，这是我想要等待未来完成的子演员，这样我就可以对结果做一些事情。在阿克卡演员周围传递“期货”可以吗？
浏览 3提问于2014-07-16得票数 2
回答已采纳
为什么火花抛出NotSerializableException org.apache.hadoop.io.NullWritable与序列文件？我的代码(非常简单)：
import org.apache.hadoop.io.{BytesWritable, NullWritable}
sc.sequenceFile[NullWritable, BytesWritable](in).repartition(1000).saveAsSequenceFile(out, None)
例外
org.apache.spark.SparkException: Job aborted: Task 1.0:66 h
浏览 3提问于2014-06-14得票数 3
回答已采纳
package models
import play.api.libs.json.{Json, OFormat}
import reactivemongo.bson.{BSONLong, BSONObjectID}
case class SavedPostOrBlog(
_id:Option[BSONObjectID],
postOrBlogId:BSONObjectID,
discussGroupId:Option[BSONObjec
浏览 9提问于2020-04-02得票数 0
回答已采纳
因此，我使用ActiveRecord模型验证来验证RESTful应用程序中的表单。
我有一个create操作，它执行以下操作：
@association = Association.new
并且表单的接收端使用以下命令创建来自表单参数的属性的数据散列以保存到数据库中：
@association = user.associations.create(data)
如果验证失败，我想简单地呈现create操作。问题是.create (不是!)方法在模型验证失败的情况下引发异常。示例：
validates_format_of :url, :with => /(^$)|(^(htt
浏览 1提问于2010-06-14得票数 7
回答已采纳
1回答
在向我无法控制的第三方服务发出请求时，我在日志中遇到了以下异常：
2017-10-25 17:08:45 [main-actor-system-akka.actor.default-dispatcher-16] ERROR akka.actor.RepointableActorRef - Error in stage [akka.http.impl.engine.client.OutgoingConnectionBlueprint$PrepareResponse@7feef72e]: Illegal response status code: 920
akka.http.scaladsl.mo
浏览 1提问于2017-10-25得票数 0
回答已采纳
Akka版本
Akka特征
语言: Scala
我正在使用Akka2.4.7的HTTPS特性在不同端口上提供几个HTTPS服务连接。在这个阶段，参与者系统的这个组件需要在一个JVM中托管几个HTTPS服务--它是连接和集成其他服务的后端。
问题
我想使用库来配置每个HTTPS服务器。我该怎么做(我的尝试失败了)
我试过的是：
对于每个服务，我都在application.conf中定义了ssl配置块。下一个配置的例子是：
my-service {
ssl-config = {
debug {
all = true
}
ss
浏览 1提问于2016-06-11得票数 6
回答已采纳
2回答
我笨手笨脚地在akka-http中摸索；我有一条编译如下的路径：
val route = get {
pathPrefix("compass") {
path("route") {
parameters(('srclat.as[Double], 'srclon.as[Double],
'destlat.as[Double], 'destlon.as[Double])) {
(srclat, srclon, destlat, destlon) =&
浏览 0提问于2017-09-05得票数 1
了解所有AKKA演员都是从/user守护演员派生出来的。为了处理异常，我想定义MyAppParent执行元，并将我的所有执行元置于此执行元之下。有没有可能用AKKA做到这一点。在实时中，我需要直接发送消息到MyAppParentActor下的子Actor邮箱，而不是通过父Actor。任何关于如何做到这一点的指针，如果它可以与AKKA。
谢谢，卡熊
浏览 2提问于2015-06-25得票数 1
2回答
我正在尝试通过以下方式运行AKKA远程示例
1. Running the remote actor in a machine with IP 192.168.1.7
2. Running the local from my machine
远程执行元在机器中启动( ip地址为192.168.1.7)；但是当我从我的机器启动本地执行元时，它无法连接到远程执行元。请查找本地和远程执行元系统配置：
本地：
akka {
//loglevel = "INFO"
actor {
provider = "akka.remote.RemoteActorRefProvi
浏览 5提问于2016-02-15得票数 2
2回答
我正在尝试获取akka Actors中的容错行为。我正在编写一些代码，这些代码依赖于系统中的Actor可用于长时间的处理。我发现我的处理过程在几个小时后停止(应该需要大约10个小时)，并且没有太多事情发生。我相信我的演员并没有从异常中恢复过来。
我需要做什么才能让Actors在一对一的基础上永久重启？我希望这可以通过这个文档来完成。
我正在使用akka 1.1.3和scala 2.9
import akka.actor.Actor
import akka.actor.Actor._
import akka.actor.ActorRef
import akka.actor.MaximumNumb
浏览 2提问于2011-08-16得票数 8
回答已采纳
1回答
我用的是Http Akka和Scala。我有一条路线：
object Route {
val route =
path("items" / "card" / """\w+""".r) {
get {
complete {
EntitiesData.someEntity
}
}
}
}
由于某些原因，它没有使用此错误进行编译：
Error:(18, 11) type mismatch;
found : akka.h
浏览 7提问于2016-07-14得票数 1
回答已采纳
我正在尝试使用Akka TypedActors (1.1.2)。我有一个像这样的界面
trait Namespace {
def cellCount: Int
def isEmpty: Boolean
def cell(key: String): Option[CellOperations[_]]
def cellsLike(key: String): List[CellOperations[_]]
def updateOrCreateCell[T](n: String, v: Option[T]=None, d:List[DataOps[T]]=List.empty[D
浏览 0提问于2011-08-11得票数 2
1回答
我有一个websocket客户端，如下所示： object Main extends App {
private val sapServer = "127.0.0.1:8080"
implicit val system = ActorSystem("WsSystem")
implicit val materializer = ActorMaterializer()
implicit val dispatcher = system.dispatcher
RestartSource.withBackoff(
minBackoff
浏览 19提问于2019-06-09得票数 2
回答已采纳
我有很多的网址，我想得到使用Akka HTTP，并使用流。
URL的格式可能不正确，或者DNS可能无法解析主机名。在这些情况下，我希望superPool()流作为TryHTTPResponse简单地返回一个失败，而不是抛出异常并终止整个流。
我该怎么做呢？我已经搜索过了，但什么也没有找到，也找不到一种方法来处理文档本身中的esceptions。
编辑:在摆弄了一下之后，我发现唯一的问题是HTTPS urls，即使这样流也没有关闭，但我在控制台上打印了错误，这是不应该发生的。下面是一个复制的小示例：
import akka.stream.scaladsl.{Sink, Source}
i
浏览 8提问于2020-05-07得票数 0
回答已采纳
我们有以下架构 SQS (源) SQS轮询器->我们的业务逻辑->接收器，它从SQS中删除消息。 这是一个akka流(我们的业务逻辑有多个阶段)。 现在，我们希望通过添加HTTP服务器(而不是Akka HTTP)来扩展此体系结构。 现在我们的服务也有了一条路径 HTTP服务器->我们的业务逻辑->接收器，它完成了一个未来，表明HTTP响应已经完成。 现在，每当HTTP请求到来时，我都需要一种机制来调用流。 现在，SQS源代码本质上是一个长时间运行的线程，它调用服务并将消息推送到akka流的其余部分。 我本质上是在尝试创建一个“可调用的”akka源代码，这样只有当我们收
浏览 14提问于2019-01-09得票数 0
回答已采纳
1回答
我通过websocket客户端将来自Kafka的传入消息转发到via服务器。以下代码显示了我是如何做到这一点的： import akka.Done
import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.model.StatusCodes
import akka.http.scaladsl.model.ws._
import akka.kafka.scaladsl.Consumer
import akka.kafka.{ConsumerSettings, Subscripti
浏览 30提问于2019-04-17得票数 0
回答已采纳
1回答
我是Akka/Scala的新手，正在尝试调试下面的代码。当resultSetParser有异常时，它不会抛出它。相反，使用此代码的服务将永远处于空闲状态。
我怎样才能让我的服务抛出异常，而不是永远在流上等待？在Akka中有没有类似watchException()函数的东西，我可以在watchTermination()之后立即调用它，让它抛出在处理流时看到的异常？
val chunkSource: Source[ChunkStreamPart, NotUsed] =
Source
.fromIterator(() => resultSetParser(resultSet) ma
浏览 3提问于2017-11-04得票数 4
我正在尝试在我的独立Spark集群上提交一个流媒体应用，这是我的代码：
import akka.actor.{Props, ActorSystem, Actor}
import akka.http.scaladsl.Http
import akka.http.scaladsl.model.HttpRequest
import akka.http.scaladsl.model.Uri
import akka.stream.ActorMaterializer
import org.apache.spark.streaming.{Seconds, StreamingContext}
im
浏览 3提问于2016-01-04得票数 0
1回答
使用加载静态内容时出错
、、、、
我第一次在Java中试用AKKA-Http (akka-http_2.12 v10.1.5，akka-stream_2.12 v2.5.17)，但似乎无法为swagger UI加载静态内容。我已经添加了下面的路由，并且能够通过和到达json和yaml端点，然而，swagger端点，即返回‘’有一个内部服务器错误.‘，尽管我在src/main/resources文件夹下有swagger-ui目录。我检查了日志，不太明白happening..seems是getFromResource和getFromResourceDirectory函数中的一个bug。
Route createRoute() {
浏览 0提问于2018-10-06得票数 1
1回答
我在努力实现非常简单的事情。
比如说，我有一个REST。当我打电话的时候
/api/recipe/1
我想要一个资源作为一个json被归还。
当我撞到
/api/recipe/2
应该返回404未找到的HTTP响应。就这么简单。
显然，我忽略了路由指令是如何工作的，因为我无法组合它们来尊重上面提到的逻辑。
不幸的是，我找不到任何具体的例子，官方文档也没有什么特别的帮助。
我正在尝试这样的方法，但是代码会产生编译错误：
class RecipeResource(recipeService: RecipeService)(implicit executionContext: ExecutionCo
浏览 3提问于2016-08-19得票数 4
回答已采纳
我想在我的Akka ActorSystem中混入一个自定义特征来修改它现有方法的行为。但是，由于ActorSystem是通过调用ActorSystem伴生对象上的apply方法创建的，而实际的构造函数是包私有的，所以我不能简单地将特征与构造函数混合在一起。因此，我决定在akka.actor包中(基于原始伴生对象的代码)编写一个新工厂：
package akka.actor
import akka.actor.setup.ActorSystemSetup
import akka.util.Reflect
import com.typesafe.config.{ Config, ConfigF
浏览 0提问于2018-05-20得票数 1
考虑下面的代码示例。在这里，父参与者(ActorA)向子参与者(ActorB)发送消息，然后停止self。子演员接收消息，然后抛出异常。我希望参与者系统会记录一些异常，但是没有异常日志记录(参见示例输出1)。
我知道这是由于父角色的停止而发生的，如果我不停止父程序，那么异常就会被记录下来(参见示例输出2)。
import akka.actor.Actor
import akka.actor.ActorSystem
import akka.actor.Props
import akka.actor.OneForOneStrategy
import akka.actor.SupervisorStr
浏览 1提问于2014-09-09得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
