首页
学习
活动
专区
圈层
工具
发布
    • 综合排序
    • 最热优先
    • 最新优先
    时间不限
  • 来自专栏函数式编程语言及工具

    Akka-CQRS(2)- 安装部署cassandra cluster,ubuntu-16.04.1-LTS and MacOS mojave

    前面的例子里示范akka-persistence时已经使用了cassandra作为journal和snapshot-store。

    1.2K20发布于 2019-05-25
  • 来自专栏函数式编程语言及工具

    SDP(0):Streaming-Data-Processor - Data Processing with Akka-Stream

    这部分我会在完成SDP项目后以akka-persistence为核心,通过akka-http,AMQP如RabitMQ等技术来实现。  

    65810编辑于 2022-05-10
  • 来自专栏函数式编程语言及工具

    Akka-CQRS(1)- Write-side, Persisting event sources:CQRS存写端操作方式

    也可以这样理解:event-sourcing(事件源)是一种特殊数据录入模式,akka-persistence是这种模式的具体实现方式。事件源的核心思想是把某写发生的事件写入log(journal)。 } ... akka-persistence代表CQRS模式中以事件源方式存写数据的具体实现。

    56010发布于 2019-05-25
  • 来自专栏函数式编程语言及工具

    Akka-CQRS(10)- gRPC on SSL/TLS 安全连接

    akkaversion, "com.typesafe.akka" %% "akka-cluster-sharding" % akkaversion, "com.typesafe.akka" %% "akka-persistence

    1.6K40发布于 2019-06-24
  • 来自专栏函数式编程语言及工具

    Akka-CQRS(3)- 再想多点,全面点

    上篇我介绍了CQRS模式存写部分的具体实现和akka-persistence一些函数和消息的用法。在这篇本来是准备直接用一个具体的例子来示范CQRS模式编程,主要是写端,或者是数据采集端。

    79110发布于 2019-05-25
  • 来自专栏函数式编程语言及工具

    Akka-CQRS(7)- CQRS Reader Actor 示范

    我们在这篇通过一个具体CQRS-Reader-Actor的例子来示范akka-persistence的query端编程和应用。 libraryDependencies := Seq( "com.typesafe.akka" %% "akka-cluster-sharding" % "2.5.19", "com.typesafe.akka" %% "akka-persistence

    1.1K20发布于 2019-05-25
  • 来自专栏HelloGitHub

    哇咔咔干货来啦!PowerJob 原理剖析之 Akka Toolkit

    akka-persistence:持久化组件,提供“至少投递一次”的能力来保证消息的可靠送达。

    1.7K20发布于 2021-05-14
  • 来自专栏函数式编程语言及工具

    Akka(12): 分布式运算:Cluster-Singleton-让运算在集群节点中自动转移

    akkaversion, "com.typesafe.akka" %% "akka-cluster-sharding" % akkaversion, "com.typesafe.akka" %% "akka-persistence

    1.6K70发布于 2018-01-05
  • 来自专栏维C果糖

    Akka 指南 之「配置」

    akka-actor akka-agent akka-camel akka-cluster akka-multi-node-testkit akka-persistence akka-remote akka-remote

    2.5K20发布于 2019-05-26
  • 来自专栏函数式编程语言及工具

    Akka-CQRS(16)- gRPC用JWT进行权限管理

    akkaversion, "com.typesafe.akka" %% "akka-cluster-sharding" % akkaversion, "com.typesafe.akka" %% "akka-persistence

    1.8K30发布于 2019-07-19
  • 来自专栏函数式编程语言及工具

    Akka(13): 分布式运算:Cluster-Sharding-运算的集群分片

    akkaversion, "com.typesafe.akka" %% "akka-cluster-sharding" % akkaversion, "com.typesafe.akka" %% "akka-persistence

    1.8K80发布于 2018-01-05
  • 来自专栏函数式编程语言及工具

    Akka-CQRS(5)- CQRS Writer Actor 部署和测试

    libraryDependencies := Seq( "com.typesafe.akka" %% "akka-cluster-sharding" % "2.5.19", "com.typesafe.akka" %% "akka-persistence

    1.1K30发布于 2019-05-25
  • 来自专栏函数式编程语言及工具

    Akka-CQRS(9)- gRPC,实现前端设备与平台系统的高效集成

    akkaVersion, "com.typesafe.akka" %% "akka-cluster-sharding" % akkaVersion, "com.typesafe.akka" %% "akka-persistence

    1.4K20发布于 2019-06-24
  • 来自专栏函数式编程语言及工具

    Akka-Cluster(6)- Cluster-Sharding:集群分片,分布式交互程序核心方式

    libraryDependencies := Seq( "com.typesafe.akka" %% "akka-cluster-sharding" % "2.5.19", "com.typesafe.akka" %% "akka-persistence

    1.7K20发布于 2019-05-25
  • 来自专栏函数式编程语言及工具

    Akka(15): 持久化模式:AtLeastOnceDelivery-消息保证送达模式

    "com.typesafe.akka" %% "akka-actor" % "2.5.3", "com.typesafe.akka" %% "akka-persistence

    1.7K50发布于 2018-01-05
  • 来自专栏函数式编程语言及工具

    Akka(14): 持久化模式:PersistentActor

    "com.typesafe.akka" %% "akka-actor" % "2.5.3", "com.typesafe.akka" %% "akka-persistence

    1.8K80发布于 2018-01-05
  • 来自专栏函数式编程语言及工具

    Akka(16): 持久化模式:PersistentFSM-可以自动修复的状态机器

    "com.typesafe.akka" %% "akka-actor" % "2.5.3", "com.typesafe.akka" %% "akka-persistence

    1.2K50发布于 2018-01-05
  • 来自专栏全栈程序员必看

    CQRS架构简介_公司架构图

    多个消息同时发送给actor时,全部会先放入该actor的mailbox里排队; 然后actor单线程从mailbox顺序消费消息; 消费一个后产生事件; 持久化事件,akka-persistence也是采用了

    1.2K20编辑于 2022-11-17
  • 来自专栏用户2442861的专栏

    CQRS架构简介

    多个消息同时发送给actor时,全部会先放入该actor的mailbox里排队; 然后actor单线程从mailbox顺序消费消息; 消费一个后产生事件; 持久化事件,akka-persistence也是采用了

    1.9K20发布于 2018-09-19
  • 来自专栏维C果糖

    Akka 指南 之「持久化」

    -- sbt --> libraryDependencies += "com.typesafe.akka" %% "akka-persistence" % "2.5.20" Akka 持久性扩展附带了一些内置持久性插件

    4K30发布于 2019-05-29
领券