Akka 消息传递机制示例
我有相当多的 Apache Camel(路由/中介/编排引擎；轻量级 ESB)经验，我正在绞尽脑汁试图了解 Akka 之间的区别: 调度器(Dispatcher、PinnedDispatcher、CallingThreadDispatcher) 路由器 池 群组 事件总线 根据文档: 调度员是: ...是什么让 Akka Actors“滴答作响"，可以说它是机器的引
..
akka相关内容
如何为多个(10k - 100k)请求正确调用 Akka HTTP 客户端?
我正在尝试使用 Akka HTTP 2.0-M2 编写用于批量数据上传的工具.但我面临 akka.stream.OverflowStrategy$Fail$BufferOverflowException: Exceeded configured max-open-requests value of [32] 错误. 我试图隔离一个问题，这里是同样失败的示例代码: 公共类 TestMaxRe
..
Akka SLF4J logback 配置和使用
我已完成以下步骤来尝试为我的 akka 应用程序配置日志记录: 创建了一个 application.conf 文件并将其放置在 src/main/resources 中.看起来像: 阿卡{事件处理程序 = ["akka.event.slf4j.Slf4jEventHandler"]日志级别 = "信息"} 创建了一个 logback.xml 文件并将其放置在 src/main/res
..
Scala 中的并行文件处理
假设我需要并行处理给定文件夹中的文件.在 Java 中，我会创建一个 FolderReader 线程来从文件夹和一个 FileProcessor 线程池中读取文件名.FolderReader 读取文件名并将文件处理函数(Runnable)提交给池执行器. 在 Scala 中，我看到两个选项: 创建一个 FileProcessor 演员池，并使用 Actors.Scheduler 安排文
..
Akka Streams:Mat 在 Source[out, Mat] 中代表什么
在 Akka 流中，Source[Out, Mat] 或 Sink[In, Mat] 中的 Mat 代表什么.什么时候会实际使用? 解决方案 Mat 类型参数表示该流的物化值的类型. 请记住，在 Akka Source、Flow、Sink(好吧，所有图)只是蓝图——它们不做任何处理他们自己，他们只描述了应该如何构造流.将这些蓝图转换为带有实时数据的工作流的过程称为物化. 实现流
..
在 Scala 中使用 Future 和 Promise 取消
这是对我之前的问题的跟进. 假设我有一个任务，它执行一个 interruptible 阻塞调用.我想将它作为 Future 运行，并使用 Promise 的 failure 方法取消它. 我希望 cancel 按如下方式工作: 如果在任务完成之前取消我希望任务“立即"完成，如果它已经开始并且我中断阻塞调用希望 Future 调用 onFailure. 如果一个取消任务在任务
..
是否可以自动缩放 Akka
我需要一个 Akka 集群来运行多个 CPU 密集型作业.我无法预测我需要多少 CPU 能力.有时负载很高，而在其他时候，负载并不多.我想自动缩放是一个不错的选择，这意味着，例如:我应该能够指定我需要最少 2 个和最多 10 个 Actor.随着负载的上升或下降，集群应该随着冷却期而扩大或缩小.有没有办法做到这一点?我猜，也许可以制作代码库的 Docker 映像，并使用 Kubernetes 对其
..
找不到密钥“akka.version"的配置设置
我正在学习 akka-remoting，这就是我的项目的样子 项目结构看起来像 project/pom.xml项目/mymodule/pom.xml项目/mymodule/src/main/resources/application.conf项目/mymodule/src/main/scala/com.harit.akkaio.remote.RemoteApp.scala项目/mymodu
..
如何在 Play 2.0.4 中每天安排任务 + onStart()?
当我尝试使用类 extends GlobalSettings 时，我需要每天在 playframework2.0.4 中执行一段代码.但它适用于每个请求的实例.我希望它在服务器启动时工作并每天执行 1 次. 包控制器；导入 java.util.concurrent.TimeUnit;导入 akka.util.Duration;导入 play.Application;导入 play.GlobalS
..
访问由 Source.actorRef 创建的 akka 流源的底层 ActorRef
我正在尝试使用 Source.actorRef 方法来创建一个 akka.stream.scaladsl.Source 对象.形式的东西 import akka.stream.OverflowStrategy.fail导入 akka.stream.scaladsl.Sourcecase class Weather(zip : String, temp : Double,raining : Boo
..
如何创建一个可以稍后通过方法调用接收元素的源?
我想创建一个 Source 并稍后在其上推送元素，例如: val src = ...//在此处创建源//然后，做这样的事情推元素(x1，src)推元素(x2，src) 推荐的方法是什么? 谢谢！ 解决方案 可以通过三种方式实现: 1.使用 SourceQueue 后期实现 您可以使用 Source.queue 将 Flow 实体化为 SourceQueue: cas
..
未来的发件人
我有一个角色，它在接收到消息时，在文件系统中搜索文件并返回文件的完整路径. 为了保持异步，我做了: def 接收 = {案例 s:String =>{val f = 未来{val ans = 搜索println("输入请求:"+s+" 输出:"+ans+" "+sender.path)}f.onComplete{案例成功(x) =>发件人！Xcase 失败(y) =>println("无法
..
基于编号的线程配置.CPU 核数
场景:我有一个示例应用程序，我有 3 个不同的系统配置 - - 2 核处理器，2 GB RAM，60 GB HHD，- 4 核处理器，4 GB RAM，80 GB HHD，- 8 核处理器，8 GB RAM，120 GB HHD 为了有效地利用我的应用程序的 H/W 功能，我希望配置 no.应用程序级别的线程数.但是，我希望只有在彻底了解系统功能后才能这样做. 是否有某种方法(系统/模式
..
Akka 框架的最佳用例是什么
我听说过很多关于 Akka 框架(Java/Scala 服务平台)的狂言，但到目前为止还没有看到许多用例的实际示例将是有益的.所以我很想知道开发人员成功使用它的事情. 只有一个限制:请不要包括编写聊天服务器的情况.(为什么?因为这已被过度用作许多类似事物的示例) 解决方案 到目前为止，我已经在两个实际项目中非常成功地使用了它.两者都在近实时交通信息领域(如高速公路上的汽车中的交通)，
..
SourceQueueWithComplete 的 Akka 流协方差
我有一个从 SupervisorActor 内部创建的 Actor，这个 Actor 负责将它获取的消息推送到流中.这是演员: class KafkaPublisher[T log.info(s"Activated stream for Kafka Producer with ActorName >> ${self.path.name} > ${self.path}
..
Kafka重启时如何让Kafka Source重新连接
我使用 Reactive Kafka 创建了一个 Source 消费者记录，如下所示: val settings = ConsumerSettings(system, keyDeserializer, valueDeserializer).withBootstrapServers(bootstrapServers).withGroupId(groupName)//如果该组没有偏移，则从哪个偏移开
..
如何将 akka 流 kafka(reactive-kafka)集成到 akka http 应用程序中?
我有一个基本的 scala akka http CRUD 应用程序.相关课程见下文. 我只想在例如创建/更新实体时将实体 ID 和一些数据(作为 json)写入 Kafka 主题. 我正在查看 http://doc.akka.io/docs/akka-stream-kafka/current/producer.html，但我是 scala 和 akka 的新手，不确定如何将它集成到我的
..
从代码中取消 Apache Flink 作业
我想从代码中停止/取消 flink 作业.这是在我的集成测试中，我向我的 flink 作业提交任务并检查结果.当作业异步运行时，即使测试失败/通过，它也不会停止.我想在测试结束后停止工作. 我尝试了一些我在下面列出的东西: 获取 jobmanager 演员 获取正在运行的作业 对于每个正在运行的作业，向作业管理器发送取消请求 这当然没有运行，但我不确定 jobmanager
..
使用 Akka、SQS 和 Camel 的消费者投票率
我正在做的一个项目需要从 SQS 读取消息，我决定使用 Akka 来分发这些消息的处理. 由于 Camel 支持 SQS，并且在 Consumer 类中内置了供 Akka 使用的功能，因此我认为最好以这种方式实现端点和读取消息，尽管我没有看到很多人的例子这样做. 我的问题是我无法足够快地轮询我的队列以保持我的队列为空或接近空.我最初的想法是我可以让消费者以 X/s 的速度通过 Came
..
Akka 会淘汰 Camel 吗?
我对 Akka 的理解是，它提供了一个模型，多个独立线程可以通过该模型以高度并发的方式相互通信.它使用“演员模型"，其中每个线程都是一个“演员"，有特定的工作要做.您可以编排在什么条件下将哪些消息传递给哪些参与者. 我以前使用过 Camel，对我来说，现在 Akka 如此成熟且文档齐全，我觉得它有点失去光泽/实用性.据我了解，Camel 是关于企业集成的，即将多个不同的系统集成在一起，通常以
..