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

简介: <div style="margin:0px; padding:0px; border:0px; line-height:1.6; font-family:'Helvetica Neue',Arial,'Hiragino Sans GB',STHeiti,'Microsoft YaHei','WenQuanYi Micro Hei',SimSun,Song,sans-serif; font


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

一般规则

关于消息发送,有两条基本规则:

  • 最多一次,即不保证消息传递可靠性
  • message ordering per sender–receiver pair

消息传递机制

  • 最多一次,意味消息有可能丢失
  • 最少一次,保证消息传递可靠,但可能冗余
  • 保证只成功一次,性能最差,消息成功传递,不冗余

为什么不保证传递可靠性

问题是,我们要保证消息传递在什么环节可靠:

  1. 消息已经发到网络上了?
  2. 消息被远程主机接收到了?
  3. 消息已经在接收者actor的邮箱里了?
  4. 目标actor是否能处理这个消息?
  5. 消息在目标actor上开始处理了?
  6. 消息在目标actor上已经处理完毕了?

上面每一条都有不同的挑战和成本。为什么不需要那么可靠?查看这篇文章

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

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

消息次序

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

意味着:

  1. 如果 M1 被投递了,那么它一定在 M2 和 M3之前被投递
  2. 如果 M2 被投递了,那么它一定在 M3之前被投递
  3. 如果 M4 被投递了,那么它一定在 M5 and M6之前被投递
  4. 如果 M5 被投递了,那么它一定在 M6之前被投递
  5. A2 收到 A1 的消息会与收到的 A3的消息交织在一起
  6. 因为没有投递保证,所以可能会“没有”,或有“一些”,或“全部”消息到达 A2
目录
相关文章
|
1月前
|
消息中间件 存储 监控
RabbitMQ:分布式系统中的高效消息队列
RabbitMQ:分布式系统中的高效消息队列
|
3月前
|
消息中间件 存储 Cloud Native
揭秘发布订阅模式:让消息传递更高效
揭秘发布订阅模式:让消息传递更高效
揭秘发布订阅模式:让消息传递更高效
|
2月前
|
消息中间件 网络协议 Ubuntu
实现高效消息传递:使用RabbitMQ构建可复用的企业级消息系统
RabbitMQ是一个在 AMQP(高级消息队列协议)基础上完成的,可复用的企业消息系统,是当前最主流的消息中间件之一。
|
3月前
|
Dubbo Java 应用服务中间件
【分布式技术专题】「探索高性能远程通信」基于Netty的分布式通信框架实现(附通信协议和代码)(上)
今天,我要向大家实现一个基于Netty实现的高性能远程通信框架!这个框架利用了 Netty 的强大功能,提供了快速、可靠的远程通信能力。 无论是构建大规模微服务架构还是实现分布式计算,这个分布式通信框架都是一个不可或缺的利器。
61 2
【分布式技术专题】「探索高性能远程通信」基于Netty的分布式通信框架实现(附通信协议和代码)(上)
|
3月前
|
消息中间件 Kafka
消息队列 MQ:构建高效、可扩展的分布式系统
消息队列 MQ:构建高效、可扩展的分布式系统
|
7月前
|
消息中间件 存储 人工智能
构建高可用的消息队列系统:保障消息传递的稳定性
构建高可用的消息队列系统:保障消息传递的稳定性
56 0
|
8月前
|
消息中间件 存储 监控
消息队列设计:构建高效可靠的分布式系统
在现代分布式系统中,消息队列被广泛应用于解耦和异步处理。它提供了高可靠性、高性能的消息传递机制,使得系统组件之间可以松耦合地协作。在本文中,我们将探讨如何设计一个高效可靠的消息队列系统。 架构设计原则
79 0
|
8月前
|
消息中间件 Java API
可靠消息传递的选择:深入了解 Apache ActiveMQ 消息队列
在分布式系统中,可靠的消息传递是实现异步通信、解耦和数据同步的关键。Apache ActiveMQ,作为一款开源的消息队列系统,为开发者提供了一个强大的工具来实现可靠的消息传递。本文将为您详细介绍 Apache ActiveMQ 的核心概念、特性以及在分布式架构中的应用。
105 0
|
9月前
|
消息中间件 大数据 Kafka
MQ 学习日志(二) 为什么使用消息队列,mq有什么优点和缺点
为什么使用消息队列,mq有什么优点和缺点
87 0
MQ 学习日志(二) 为什么使用消息队列,mq有什么优点和缺点
|
9月前
|
消息中间件 JavaScript Java
基于WebSocket的实时消息传递设计
web管理系统中可以对业务数据执行新增和删除,现在需要当业务数据发生新增或删除操作后,尽可能实时的反应到WPF客户端上面。
157 0
基于WebSocket的实时消息传递设计