- 综合排序
- 最热优先
- 最新优先
- 来自专栏维C果糖
Akka 指南 之「集群中的分布式发布订阅」
文章目录 集群中的分布式发布订阅 依赖 简介 发布 主题组 发送 DistributedPubSub 扩展 传递保证 集群中的分布式发布订阅 依赖 为了使用分布式发布订阅（Distributed Publish 中介程序可以以DistributedPubSub扩展启动，也可以作为普通的 Actor 启动。 注册表最终是一致的，即更改在其他节点上不立即可见，但通常在几秒钟后将其完全复制到所有其他节点。 DistributedPubSub 扩展 在上面的示例中，使用akka.cluster.pubsub.DistributedPubSub扩展启动和访问中介。 可以使用以下属性配置DistributedPubSub扩展： # Settings for the DistributedPubSub extension akka.cluster.pub-sub { akka.extensions = ["akka.cluster.pubsub.DistributedPubSub"] 传递保证 与 Akka 中的「 Message Delivery Reliability
1.7K20发布于 2019-05-26 - 来自专栏函数式编程语言及工具
Akka-CQRS（6）- read-side
pub/sub模式把reader放在订阅subscriber端，如下： //写端 import DistributedPubSubMediator.Publish val mediator = DistributedPubSub Publish(persistentId, event，sendOneMessageToEachGroup = true) } } //读端 val mediator = DistributedPubSub
77930发布于 2019-05-25 - 来自专栏函数式编程语言及工具
Akka-Cluster（2）- distributed pub/sub mechanism 分布式发布/订阅机制
extends Actor { import DistributedPubSubMediator.Publish // activate the extension val mediator = DistributedPubSub String, ref: ActorRef) = new Subscribe(topic, ref) } 订阅操作即向本地Mediator发送Subscribe消息： val mediator = DistributedPubSub 同样：Send和Put都是消息类型，Put代表订阅： val mediator = DistributedPubSub(context.system).mediator // register to extends Actor { import DistributedPubSubMediator.Send // activate the extension val mediator = DistributedPubSub extends Actor { import DistributedPubSubMediator.Send // activate the extension val mediator = DistributedPubSub
1.5K40发布于 2018-12-10 - 来自专栏自我记录
实习培训考核内容--Akka+Netty编写聊天室系统
channelGroup: ChannelGroup = DefaultChannelGroup(GlobalEventExecutor.INSTANCE) private val mediator = DistributedPubSub.get
31020编辑于 2024-08-19 - 来自专栏维C果糖
Akka 指南 之「集群客户端」
注意，「ClusterClientReceptionist」使用「DistributedPubSub」扩展，这在「集群中的分布式发布订阅」中进行了描述。
2K30发布于 2019-05-26 - 来自专栏函数式编程语言及工具
Akka-Cluster（3）- ClusterClient, 集群客户端
假设它们会提供不同的叫声作为服务吧： class Cat extends Actor with ActorLogging { //使用pub/sub方式设置 val mediator = DistributedPubSub MIAOM ...******") } } class Dog extends Actor with ActorLogging { //使用pub/sub方式设置 val mediator = DistributedPubSub ) system } } class Cat extends Actor with ActorLogging { //使用pub/sub方式设置 val mediator = DistributedPubSub MIAOM ...******") } } class Dog extends Actor with ActorLogging { //使用pub/sub方式设置 val mediator = DistributedPubSub
2.2K20发布于 2018-12-25
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号