首页 文章
  • 1 votes
     answers
     views

    测量代码单元的内存使用情况

    我有一个函数 memory ,它接受一个函数并测量它的内存使用情况: import java.lang.management.ManagementFactory def memory[T]( f: ⇒ T )( mu: Long ⇒ Unit ): T = { val memoryMXBean = ManagementFactory.getMemoryMXBean ...
  • 0 votes
     answers
     views

    Neo4j:节点上的MissingIndexException

    我正在尝试在Scala中设置Spring-Data-Neo4j项目的框架 . 当我运行JUnit测试时,我得到一个MissingIndexException,我真的没有任何线索的原因 . 我之前使用纯Java而不是scala实体/测试中的相同配置(和依赖项)成功运行了相同的测试 . 任何帮助都可以 . (scala)持久化实体: @NodeEntity class User extends Ide...
  • 6 votes
     answers
     views

    持久性的唯一性在akka-persistence中

    我正在使用scala api for akka-persistence来持久化一组组织成树的actor实例 . 树中的每个节点都是持久性actor,并根据“根”节点到该节点的路径命名 . persistenceId设置为名称 . 例如,根节点actor具有persistenceId'root' . 下一个节点有persistenceId'root-europe' . 另一个演员可能有persis...
  • 1 votes
     answers
     views

    如何坚持高消息率的演员状态

    我想开始使用带有重率信息的演员 . 演员的最后一个状态非常重要我是按照这里显示的持久性示例http://doc.akka.io/docs/akka/2.3.9/scala/persistence.html#event-sourcing我试图发送大量的消息 for (i <-0 to 100000){ persistentActor ! Cmd("foo"+i) } ...
  • 1 votes
     answers
     views

    PersistentFSM不会保留到日志中

    我正在尝试使用下面的简单示例测试Akka 2.4的新功能 - PersistentFSM (http://doc.akka.io/docs/akka/2.4.0/scala/persistence.html#Persistent_FSM) . 此示例生成5个随机整数并将其广告到序列中 . 我希望它能够持久保存数据,并在下一次运行应用程序时继续追加现有的数字序列 . 关于 PersistentF...
  • 3 votes
     answers
     views

    了解AKKA持久性以及ES和CQRS原则

    我最近观看了几个关于ES和CQRS模型的视频以及我几乎没有关于AKKA持久性的讨论 . 我知道它们是什么,但我在编写将要执行的实际代码时遇到问题 . 我有几个问题 . 我应该如何进行视图和事件堆栈通信?是否会在视图和相同持久性ID的持久actor之间传递事件?什么是持久的演员和视图负责根据模型? 编辑:我应该在哪里放置我的业务逻辑?根据模型我应该写在写,但如果我需要检查读取的东西,以验证cmd怎么...
  • 0 votes
     answers
     views

    轻量级的普通期货或Akka

    有一些用例如下 . 1) createUser API调用是通过前端进行的 . 一旦此调用成功,意味着数据成功保存到db,将成功返回到前端 . API Contract 在前端和后端之间结束 . 2)现在后端需要生成并触发 CreateUser 事件,该事件将用户创建到第三方应用程序中(为了示例,我们可以说它成功或失败 . 但是所有对此 CreateUser 事件的调用都必须记录,因为它的失败...
  • 0 votes
     answers
     views

    在测试时清除Akka-persistance中的源事件

    我正在编写一个具有Akka-persistance的模块,并且在单元测试中遇到了一个问题:所有事件都是在测试期间获得的,因此状态发生了变化 . 当我再次运行hte测试套件时,事件会被重放,因此演员不会以它应该具有的初始状态开始 . 原始解决方案是每次都删除本地事件存储,或者每次都更改persistenceId . 两者都太粗糙了 . 有没有办法将其纳入测试套件?
  • 2 votes
     answers
     views

    持续演员的Akka Sharding背压

    是否有Akka流背压模型或使用持久演员的akka分片? 因为我有问题,我有一个持久演员的akka分片集群 . (使用cassandra作为日志插件) .有时候应该同时创建很多演员 . (例如,当我们想要向所有用户发送广播消息时 . )成千上万的持久性演员试图在短时间内恢复(例如3.秒)并且在重负荷下cassandra无法在一段时间内做出响应并且许多演员多次无法恢复并且永远不会再次恢复 .
  • 0 votes
     answers
     views

    Akka Persistence:ReadJournal.runFold永远不会返回

    我是第一次尝试Akka,更具体地说是Akka Persistence . 我最终试图实现一个小玩具程序来复制Akka在事件源应用程序中的使用 . 我已经取得了成功,直到我尝试使用 ReadJournal 将我的事件流投射到我的域中 . def main(args: Array[String]): Unit = { val commands: EmployeeCommandStream = ...
  • 9 votes
     answers
     views

    使用akka-persistance进行事件采购:将状态增长为列表?

    我正在使用Akka Scala设计使用CQRS事件采购的后端 . 我不确定如何应对不断增长的状态 . 例如,我将有越来越多的用户 . 据我了解,每个用户都将在UserCreated事件之后创建,这些事件将由PersistentActor重播,用户将存储在一个集合中 . 就像是: class UsersActor extends PersistentActor { override def...
  • 0 votes
     answers
     views

    将案例类(事件)传递给Akka Stream的Source()

    我正在尝试实施CQRS解决方案 . 在我执行一些操作(执行一个命令)后,我将生成的事件(例如案例类(例如:AccountCreated))传递给另一个actor,然后使用akka流将事件通过线路推送到某个外部Sink . 假设事件类型是 Events ,我的发布actor的receive函数看起来像这样 override def receive = { case event: Events ...
  • 2 votes
     answers
     views

    akka-persistence(cqrs?)的事件来源和副作用

    我试图弄清楚如何使用持久性actor来模拟远程“IoT”设备的状态,例如: 用户想打开灯,这样我们才能做到最合乎逻辑 . 用户发送 OnCommand 持久化actor接收命令,生成 LightTurnedOnEvent 并将其状态更新为 on 所以这是有道理的,但这里的问题是灯光实际上从未打开过 . 好的,那么我们 Build 一个知道低级硬件控制伏都教的 LightControlA...
  • 4 votes
     answers
     views

    使用Akka Persistence在每个Actor的基础上指定存储插件

    是否有可能提供手动实例化为持久性actor的存储插件(用于日记和快照)? (而不是引用那些通过配置硬编码的那些 . )换句话说,而不是override journal and snapshot plugin ids. as described by Multiple persistence plugin configurations from the manual,我想这样做: trait Act...
  • 2 votes
     answers
     views

    如何以及在何处处理AkkaPersistence持久化事件以使信息对响应式UI有 Value 且有意义?

    我非常熟悉 PersistentActor 和 PersistentView 在实现 Akka Persistence 时如何工作 . 根据我的理解,请考虑以下示例 . Scala案例类 Contact . case class Contact(id: String, version: Int, fName: String, lName: String, age: Int) 期刊中的Persi...
  • 4 votes
     answers
     views

    在Akka集群中同步数据的简单方法?

    我有一些运行时数据我希望存在于我的Akka集群中每个节点上的指定actor上,可以通过内部事件或API调用更新到单个节点 . 我可以将这些数据存储在共享数据库中以使其永久化,但我宁愿将其存储在内存中以提高速度,因为它不需要持久化 . Akka Cluster Singleton,Distributed Pub Sub以及可能的其他内置模块使用八卦协议来保持分布式状态同步 . 是否有一种现成的方法...
  • 10 votes
     answers
     views

    Akka cluster-sharding:Entry actor可以拥有动态道具

    Akka Cluster-Sharding看起来与用例匹配得很好我必须在Akka节点上创建有状态持久性actor的单个实例 . 我不清楚是否有可能有一个Entry actor类型需要参数来构造它 . 或者我可能需要重新考虑Entry actor如何获取此信息 . Object Account { def apply(region: String, accountId: String): Pro...
  • 0 votes
     answers
     views

    Akka群集分片不起作用

    我在Scala 2.11.8上使用akka 2.4.7 . 事件来自extractShardId和extractEntityId,但它们没有被传播到actor的receive方法 . 有什么想法可能是什么? https://bitbucket.org/kuzelac/apt-billing/overview分支价格碎片 定义了一个集群分片: val dailyPriceAggregateActor...
  • 2 votes
     answers
     views

    Akka集群分片的Cassandra性能问题

    My application: akka cluster 2.5.x; akka分片具有均匀分布的功能; cassandra插件"com.typesafe.akka" %% "akka-persistence-cassandra"(默认配置); 专用单节点Cassandra 3.3; 我的应用程序模拟了一种支持以下操作的帐户的财务应用程序...
  • 0 votes
     answers
     views

    IntelliJ中的Scala编译错误:找不到输出目录

    IntelliJ IDEA(最新的社区版本)无法编译带有错误的dotty编译器: scala.reflect.internal.FatalError: Could not find an output directory for /src/contrib/dotty/scala-backend/src/compiler/scala/tools/nsc/backend/ScalaPrimitives...
  • 2 votes
     answers
     views

    如何在cassandra中保存火花流数据

    build.sbt 以下是build.sbt文件中包含的内容 val sparkVersion = "1.6.3" scalaVersion := "2.10.5" resolvers += "Spark Packages Repo" at "https://dl.bintray.com/spark-packages/ma...
  • 1 votes
     answers
     views

    读取16位灰度tiff

    我正在编写一个scala程序,需要能够读取16位灰度tiff图像并对各个像素进行一些复杂的计算 . 具体来说,我希望一个库能够从tiff文件中获取所有像素强度值的Array [Int],并且能够从这样的数据结构中写入图像 . 我的问题是库能够做到这一点吗? 感谢您的任何帮助,您可以提供 .
  • 1 votes
     answers
     views

    @karate如何将参数传递给gatling模拟类中的特征文件?

    让我们考虑一个场景,我们必须运行“创建帐户api”的性能测试,该测试将输入作为头/路径参数“Auth token”并输入数据,如用户帐户名 . 所以对于上面的场景我们有2个特征文件, 为POST运行性能测试 http://baseUrl/auth_param/create/input_data 1.一个功能(例如:generateAuth.feature)文件将具有身份验证令牌2.第二个功能(c...
  • 0 votes
     answers
     views

    在Scala中使用casbah对MongoDB进行ISODate查询

    我使用Casbah for Scala插入/更新MongoDB文档 . 我面临的挑战之一是按日期或ObjectId查询MongoDB文档 . 我的MongoDB文档看起来像 {“_ id”:ObjectId(“58d2cfe5fbb1bb15209d3b02”),“name”:“Joe”,“db_date”:ISODate(“2017-01-26T07:00:00.000Z”)} 我通过obj...
  • 0 votes
     answers
     views

    使用Couchbase 4.5 Play Framework 2.5

    我目前正在使用Play Framework,作为数据库,我想使用Couchbase 4.5(目前处于测试阶段,但不应该是一个问题) . 这是我的问题:在Couchbase文档中,他们建议只使用一个CoucbaseCluster实例和一个Bucket实例 . 但是如何在启动时 Build 这些实例并在所有控制器中全局使用它们 . 我已经知道我必须使用依赖注入,但我不知道如何实现这一点 . 现在等一下...
  • 3 votes
     answers
     views

    如何使用scala play sbt复制资源

    我正在使用sbt [0.13]使用scala [2.10.3]编译play [2.2]项目 . 我有用于数据库迁移的.sql文件和scala文件 . 目录结构如下所示: app |-> db |-> migration |-> V1__init.scala |-> V2__newTable.sql 当我从播放控制台(R...
  • 0 votes
     answers
     views

    玩框架应用程序,如何导入scala项目

    我是Play框架的新手,看起来一切都很简单,我只有一个问题:处理多项目依赖的方法有哪些? 我试过按照这个但我不能使用导入http://www.playframework.com/documentation/2.2.1/SBTSubProjects 像这样的东西How to import custom package in JAVA in PLAY framework 但是我必须导入开发代码,有没有...
  • 0 votes
     answers
     views

    确认eclipse正在运行Scala for Play的正确版本

    这应该很容易 . 我已经使用类型安全激活器安装了游戏2.3.7,然后在https://www.playframework.com/documentation/2.3.x/IDE之后为eclipse(eclipse Kepler)设置了它的演示项目 . 虽然演示项目按预期运行,但在Eclipse中看起来有点古怪,我怀疑我的eclipse使用Scala 2.10,而Play jar是2.11 . 我如...
  • 6 votes
     answers
     views

    如何在Play framework 2.3.x(Scala)中将POJO转换为JSON?

    任何人都可以告诉我如何使用Scala将POJO或类实例转换为Play框架中的JSON(特别是Play v2.3.x)? 例如,我有这样的代码: case class Foo(name: String, address: String) def index = Action { request => { val foo = Foo("John Derp&...
  • 2 votes
     answers
     views

    在scala应用程序中找不到对象播放

    我正在使用Eclipse并创建一个新的Scala对象,想要使用json解析功能并导入这个包,但是找不到错误对象播放 . 想知道如何在Scala对象中使用play库? 这是我导入的方式, import play.api.libs.json._ 发布图片我是如何创建项目的 . 问候,林

热门问题