zl程序教程

您现在的位置是:首页 >  工具

当前栏目

Akka学习笔记(六):消息传递可靠性

笔记学习 可靠性 Akka 消息传递
2023-09-14 08:58:00 时间
上面每一条都有不同的挑战和成本。为什么不需要那么可靠?查看这篇文章

Akka拥抱分布式计算和分布式网络,并通过消息传递来明确实现它,因此它不说谎,而是模拟一个有漏洞的抽象方式。这是在Erlang中取得了重大成功的模型,并要求用户基于此为应用建模。你可以阅读Erlang 文档(10.9, 10.10)了解更多。Akka与它非常相似。

底线:你是一个开发者,知道你的应用中需要提供哪些保证,那么你可以飞快又可靠地使用专门的ACK和RETRY来实现(如果你真的需要,大多数情况你并不需要)。使用Akka的Durable邮箱会有帮助。

Actor A1 发送消息 M1, M2, M3 给 A2 Actor A3 发送消息 M4, M5, M6 给 A2

意味着:

如果 M1 被投递了,那么它一定在 M2 和 M3之前被投递 如果 M2 被投递了,那么它一定在 M3之前被投递 如果 M4 被投递了,那么它一定在 M5 and M6之前被投递 如果 M5 被投递了,那么它一定在 M6之前被投递 A2 收到 A1 的消息会与收到的 A3的消息交织在一起 因为没有投递保证,所以可能会“没有”,或有“一些”,或“全部”消息到达 A2
剖析nsq消息队列(一) 简介及去中心化实现原理 分布式消息队列nsq,简单易用,去中心化的设计使nsq更健壮,nsq充分利用了go语言的goroutine和channel来实现的消息处理,代码量也不大,读不了多久就没了。后期的文章我会把nsq的源码分析给大家看。
组队学架构之高并发架构系列:详解RPC远程调用和消息队列MQ的区别 RPC(Remote Procedure Call)远程过程调用,主要解决远程通信间的问题,不需要了解底层网络的通信机制。 RPC框架 知名度较高的有Thrift(FB的)、dubbo(阿里的)。
分布式系列二: 分布式系统的通信 通信是分布式架构的一个基本问题, 通信是基于通信协议, 通过网络IO来实现的, 基本的通信协议有TCP,HTTP,UDP等, Java的IO分为BIO,NIO,AIO等, java领域有很多支持通信的技术, 如RMI,MINA,JMS等.
分布式系统消息通信技术简介 分布式系统消息通信技术主要包括:RPC(Remote Procedure Call Protocol) 一般是C/S方式,同步的,跨语言跨平台,面向过程CORBA(Common Object Request Broker Architecture) 从概念上扩展了RPC,面向对象的,企业级的 面向对象中间件还有分布式组件对象模型DCOMRMI(Remote Method Invocation) 面向对象方式的 Java RPCWebService 基于Web,C/S或B/S,跨系统跨平台跨网络。