- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我正在尝试分析一个 CPU 使用率一直处于或接近 100% 的 Akka 应用程序。我使用 visualvm
采集了一个 CPU 样本。该示例表明有 2 个线程占 CPU 使用率的 98.9%。 79% 的 cpu 时间花在了名为 sun.misc.Unsafe
的方法上。 Other answers on SO说它只是意味着一个线程正在等待但是在 native 实现层(在 jvm 之外)。
在与我类似的问题中,人们一直在 told to look elsewhere没有给出具体细节。我应该在哪里寻找导致 cpu 峰值的原因?
该应用程序是一个服务器,主要使用 Akka IO 来监听 TCP 套接字连接。
最佳答案
如果没有看到任何源代码,甚至不知道您在谈论什么 IO channel (套接字、文件等),这里的任何人都无法提供给您的见解。
不过我确实有一些相当笼统的建议。
首先,您应该在您的应用程序中使用响应式(Reactive)技术和响应式(Reactive) IO。出现此问题的原因可能是您在紧密循环中轮询某些资源的状态,或者在以下情况下使用阻塞调用你应该使用 react 性的。这往往是一种反模式和性能消耗,因为您可以将 CPU 周期用于“积极等待”之外的任何事情。我建议仔细检查:
Future
什么时候适合 map
相反其次,您不应该在您的应用程序中使用互斥体或其他线程同步。如果是这样,那么您可能会遇到活锁。与死锁不同,活锁表现为 100% CPU 使用率等症状,因为线程不断锁定和解锁并发原语以试图“捕获所有”。 Wikipedia对活锁的外观有很好的技术描述。有了 Akka,您就不需要使用 Mutexes 或任何线程同步原语。如果是,那么您可能需要重新设计您的应用程序。
第三,您应该限制 IO(以及重新连接尝试等错误处理)。出现此问题的原因可能是您的系统缺乏有效的限制。对于数据通道,我们通常不会限制其带宽。然而,当该 channel 达到 100% 饱和并开始从系统的其他部分窃取资源时,这可能会成为一个问题。例如,如果您在没有合理限制的情况下移动大文件,就会发生这种情况。
或者,您还需要在遇到任何错误时限制连接重试,而不是立即重试。如果失去连接,许多系统将尝试重新连接到服务器。虽然通常是可取的,但如果您使用天真的重新连接策略,这可能会导致有问题的行为。例如,想象一个这样写的网络客户端:
class MyClient extends Client {
... other code...
def onDisconnect() = {
reconnect()
}
}
每次客户端因任何原因断开连接时,它都会尝试重新连接。您可以看到,如果 Wifi 中断或网络电缆被拔掉,这将如何导致错误处理代码和客户端之间的紧密循环。
第四,您的应用程序应该有明确定义的数据源和接收器。您的问题可能是由“数据循环”引起的,即一组 Akka actor 只是将消息发送到下一个链中的参与者,最后一个参与者将消息发送回链中的第一个参与者。确保您有清晰明确的方式让消息进入和退出您的系统。
第五,为您的应用程序使用适当的分析和检测。使用 Kamon 检测您的应用程序或 Coda Hale 的指标库。
找到合适的分析器将更加困难,因为我们作为一个社区还有很长的路要走才能为响应式(Reactive)应用程序开发成熟的工具。我个人找到了visualvm
有用,但对于检测受 CPU 限制的代码路径并不总是非常有用。问题是采样分析器只能在 JVM 到达安全点时收集数据。这有可能使某些代码路径产生偏差。解决方法是使用支持 AsyncGetStackTrace
的分析器.
祝你好运!如果可以,请添加更多上下文。
关于scala - Akka IO 应用占用 100% CPU,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/38022491/
我正在尝试使用 Scala 2.12.3、sbt 0.13.6 以及 build.sbt 文件中的以下库依赖项构建一个项目: libraryDependencies ++= Seq( "com.t
我根本没有任何 Akka 经验。我想知道 Akka 消息传递如何在 JVM 内以及 JVM 之间工作。 JVM 中的消息是一些类似 POJO 的对象吗? JVM之间的通信是否需要任何类型的JMS(如服
Akka的EventBus是否可以与远程 Actor 一起使用? 据我所知,它本身不支持此功能。任何人都可以确认吗? 看起来有可能对提供相似功能的Actor进行编码。例如。在订阅远程服务器上的Even
我在单个 JVM 上使用 Akka 开发了我的应用程序。现在我想在多台机器上分配工作负载。我开始阅读文档并感到困惑。 有两种方法可以通过集群和远程处理使 Akka 应用程序分发。 我不明白两者之间的区
我想使用 Akka HTTP 构建一个连接到现有接收器(带有 Kafka react 流)的 REST 服务,但我不知道如何将 HTTP 流链接到 Akka 流接收器... 我应该选择使用 Flows
我在某处听说默认情况下是一个 Actor 系统,这意味着它的 ExecutorService/Dispatcher 正在创建一个非 Deamon 线程池来运行 Actor。如果确实如此,那将解释我所经
在我的应用程序中,我有一个角色需要在等待某些操作完成时存储消息,同时它需要支持高优先级消息(控制消息)。 stash trait 需要一个 Dequeue邮箱类型,我找不到控制感知出队邮箱是否有意义。
Akka.NET 和原始 Akka 可以使用 Remoting 进行通信吗? 换句话说,Akka 可以用于连接系统中的 JVM 和 CLR 吗? 最佳答案 这个问题在 akka.net Github
Akka 新手。创建一个扩展 SupervisorStrategy 的新 Scala 类为我提供了以下模板: class MySupervisorStrategy extends Supervisor
我正在尝试为包含并行处理流的 Akka 流定义一个图(我正在使用 Akka.NET,但这应该无关紧要)。想象一个订单的数据源,每个订单由一个订单 ID 和一个产品列表(订单商品)组成。工作流程如下:
我有一个 akka actor(worker)接收请求并回复它。请求处理可能需要 3-60 分钟。来电者(也是 Actor )目前正在使用 !!!并等待 future.get,但是如果需要,可以更改
我应该如何在 Akka 持久化 (Eventsourcing/CQRS) 中构建我的 Actor? 分层 平行 我的电子商务应用程序中有这些域对象 用户 - 用户可以创建帐户 商店 - 用户可以创建商
我正在尝试构建和运行一个 akka 流(在 Java DSL 中),以 2 个 actor 作为源,然后是一个合并结点,然后是 1 个接收器: Source src1 = Source.act
我正在尝试监督 Akka Actor ,更具体地说是 Cluster Singleton创建使用 ClusterSingletonManager .我试图更好地控制异常、日志和 Actor 的生命周期
我试图了解何时何地使用不同的 built-in Akka mailboxes以及何时适合自己滚动。但是,该页面上的任何地方都没有解释“ 有界邮箱 ”实际上是什么,或者它的行为方式与无界邮箱有何不同。此
在Akka中等待多个actor的结果的正确方法是什么? Principles of Reactive Programming Coursera 类(class)有一个带有复制键值存储的练习。无需深入研
我正在为一个项目评估 Akka,我正在尝试弄清楚我是否可以通过将参与者状态保存在高可用数据存储中来使用 Akka-Persistence 实现服务的高可用性。 (我不打算使用 Akka-Cluster
我阅读了 Akka 文档并找到了这个 As mentioned before, if a node is unreachable then gossip convergence is not poss
我正在使用 akka 流,并且我有一段我需要有条件地跳过的图表,因为流程无法处理某些值。具体来说,我有一个接受字符串并发出 http 请求的流,但是当字符串为空时,服务器无法处理这种情况。但我只需要返
我们正在考虑使用 Akka 进行客户端服务器通信,并尝试对数据传输进行基准测试。目前我们正在尝试发送一百万条消息,其中每条消息都是一个具有 8 个字符串字段的案例类。 目前,我们正在努力获得可接受的性
我是一名优秀的程序员,十分优秀!