开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

Akka集群:为什么我没有收到可到达的事件？

Akka集群是一个用于构建分布式、高可用、可伸缩的应用程序的工具包。它基于Actor模型，提供了一种并发编程模型，可以轻松处理分布式系统中的并发和容错性。

当你没有收到可到达的事件时，可能有以下几个原因：

配置错误：首先，你需要确保Akka集群的配置正确。检查配置文件中的集群节点地址、端口号等信息是否正确配置。
网络问题：确保集群中的节点之间可以互相通信。检查网络连接是否正常，防火墙是否阻止了节点之间的通信。
节点状态：检查集群中的节点是否处于正常状态。如果某个节点处于故障状态或者已经下线，可能会导致事件无法到达。
负载均衡：如果你的集群中有多个节点，确保负载均衡策略正确配置。负载均衡可以确保事件在集群中的各个节点之间均匀分布，避免某个节点负载过重而导致事件无法到达。
消息丢失：在分布式系统中，消息丢失是一个常见的问题。如果你没有收到可到达的事件，可能是由于消息在传递过程中丢失了。在Akka集群中，你可以使用可靠传输协议（如Akka Persistence）来确保消息的可靠传递。

推荐的腾讯云相关产品和产品介绍链接地址：

腾讯云容器服务（TKE）：https://cloud.tencent.com/product/tke
腾讯云云服务器（CVM）：https://cloud.tencent.com/product/cvm
腾讯云云数据库MySQL版：https://cloud.tencent.com/product/cdb_mysql
腾讯云对象存储（COS）：https://cloud.tencent.com/product/cos
腾讯云区块链服务（BCS）：https://cloud.tencent.com/product/bcs

请注意，以上链接仅供参考，具体的产品选择应根据实际需求进行评估和决策。

相关搜索:keyUp :为什么我的InputAdapter没有收到libgdx事件？为什么我收到一个` `AttributeError：'NoneType‘对象没有’send‘属性的错误为什么我最新的cloudrun版本没有收到流量？为什么我没有从我的复合聚合查询中收到after_key？为什么我没有收到任何关于Firebase崩溃的报告？为什么我没有收到新socket用户已连接的console.log？为什么我没有收到来自sendgrid的任何邮件？为什么我的discord.py事件没有被调用？为什么我的Google Analytics callto事件跟踪代码没有跟踪？为什么我的OnSelect事件没有相应地触发

相关搜索:

页面内容是否对你有帮助？

有帮助

没帮助

相关·内容

Akka 指南之「集群客户端」

文章目录集群客户端依赖简介一个示例 ClusterClientReceptionist 扩展事件配置故障处理当无法到达群集时集群客户端依赖为了使用集群客户端（Cluster Client...此外，由于 Akka 远程处理（Remoting）主要设计为 Akka 群集的协议，因此没有明确的资源管理，当使用了ClusterClient时，它将导致与群集的连接，直到ActorSystem停止（与其他类型的网络客户端不同...ClusterClient和ClusterClientReceptionist都会发出可订阅的事件。..."] 事件如前所述，ClusterClient和ClusterClientReceptionist都会发出可订阅的事件。...当无法到达群集时如果集群客户端找不到可以在可配置的时间间隔内与之连接的接待员，则可以完全停止集群客户机。这是通过reconnect-timeout配置的，默认为off。

1.7K3 0

Akka 指南之「消息传递可靠性」

高级抽象消息模式事件源带明确确认的邮箱死信应该用死信做什么？如何收到死信？...同样的道理是，「没有人需要可靠的消息传递」。发送方了解交互是否成功的唯一有意义的方法是接收业务的确认消息，这不是 Akka 可以自己完成的（我们既不编写“按我的意思做”的框架，也不希望我们这样做）。...A2可以看到A1的消息与A3的消息交织在一起。由于没有保证的传递，任何信息都可能被丢弃，即不能到达A2。在此，需要注意的是，Akka 的保证适用于邮件进入收件人邮箱的顺序。...可能的非详尽的指示清单是：在接收到顶级 Actor 的第一个回复之前，存在一个保护内部临时队列的锁，而这个锁是不公平的；这意味着，根据低级线程调度，来自不同发送方的排队请求在 Actor 的构造过程中到达...Actor 可以订阅事件流上的类akka.actor.DeadLetter，请参阅「事件流」了解如何执行该操作。然后，订阅的 Actor 将收到（本地）系统中从那时起发布的所有死信。

1.7K1 0

Akka 指南之「集群的使用方法」

它在订阅开始时接收与集群当前状态对应的事件，然后接收集群中发生更改的事件。你自己运行这个例子最简单的方法是下载准备好的「Akka Cluster Sample with Java」和教程。...请注意，如果在完成初始联接过程之前启动订阅，则可能会收到一个空的CurrentClusterState，其中不包含成员，后面是已联接的其他节点的MemberUp事件。...当节点在集群中被接受后，你将收到该节点和其他节点的MemberUp。...，你可以像下例所示这样使用它，将订阅推迟到接收到自己节点的MemberUp事件为止： Cluster cluster = Cluster.get(getContext().getSystem());...这意味着，你将收到与当前状态相对应的事件，以模拟在过去发生事件时，如果正在监听这些事件，你将看到的情况，而不是作为第一条消息接收CurrentClusterState。

4.6K6 0

Akka 指南之「集群规范」

集群规范注释：本文描述了 Akka 集群的设计概念。...集群成员是通过「Gossip Protocol」进行通信的，其中集群的当前状态是通过集群随机传播的，优先于没有看到最新版本的成员。...Vector Clocks 「向量时钟」是一种数据结构和算法，用于生成分布式系统中事件的部分排序和检测因果关系冲突。...当监视不可访问节点的所有节点再次检测到它是可访问的时，在散播流言之后，集群将认为它是可访问的。如果系统消息无法传递到节点，那么它将被隔离，然后它将无法从无法访问的状态返回。...如果节点要再次加入集群，那么必须重新启动 Actor 系统，并再次执行加入过程。集群还可以在配置的不可到达时间之后，通过leader自动关闭节点。

1.2K2 0

分布式系统模式11-HeartBeat

如果在此间隔内没有接收到心跳，则将发送服务器视为故障。在决定心跳间隔和超时值时，了解数据中心内部和数据中心之间的网络往返时间非常有用。...每次接收到心跳时，记录心跳到达的时间戳 class TimeoutBasedFailureDetector… @Override void heartBeatReceived(T serverId...System.nanoTime(); heartbeatReceivedTimes.put(serverId, currentTime); markUp(serverId); } 如果在固定时间窗口内没有接收到心跳...参考[raft]， [log-cabin]的实现。有时，一些特定运行时的事件(如垃圾回收)导致的[本地暂停]会延迟心跳的处理。需要一种机制来检查处理是否在可能的本地暂停之后发生。...例子 • 像ZAB或RAFT这样的统一实现，它们使用3到5个节点的小型集群，实现了基于固定时间窗口的故障检测。• Akka Actors和Cassandra使用 Phi Accrual故障检测器。

9982 0

Akka 指南之「集群分片」

「集群分片」项目，以了解 Akka 集群分片的实际使用情况。...决定分片位置的逻辑在可插拔分片分配策略中定义。...除此之外，使用一种模式而不使用另一种模式没有主要原因。在集群中的所有节点上使用相同的模式很重要，即不可能执行滚动升级来更改此设置。...协调器的状态不持久，它没有存储到磁盘。当集群中的所有节点都已停止时，状态将丢失，也不再需要了。记忆实体（Remembering Entities）的状态也是持久的，即存储在磁盘上。...Automatic Passivation 如果实体使用akka.cluster.sharding.passivate-idle-entity-after设置一段时间没有收到消息，或者通过将ClusterShardingSettings.passivateIdleEntityAfter

2.2K6 1

Akka 指南之「持久化」

Akka 持久性背后的关键概念是，只有 Actor 接收到的事件才被持久化，而不是 Actor 的实际状态（尽管也提供了 Actor 状态快照支持）。...事件通过附加到存储（没有任何变化）来持久化，这允许非常高的事务速率和高效的复制。有状态的 Actor 通过将存储的事件重放给 Actor 来恢复，从而允许它重建其状态。...建议将它们用于读取操作，在域模型中没有相应事件的操作。使用这些方法与持久化方法非常相似，但它们不会持久化传入事件。它将保存在内存中，并在调用处理程序时使用。...下面的示例强调了消息如何到达 Actor 的邮箱，以及在使用persist()时它们如何与其内部存储机制交互。...「集群分片」非常适合将持久性 Actor 通过他们的id分散到集群和地址上。

3.3K3 0

PowerJob 原理剖析之 Akka Toolkit

行为：Actor 中的计算逻辑，通过 Actor 接收到的消息来改变 Actor 的状态。...前面说了一大堆晦涩难懂的概念，相信大家看的也都云里雾里的。这里结合我自己的理解用白话文讲一下：其实 Actor 模型的设计思想就是事件驱动，可以简单理解为线程级的消息中间件。...Akka 本身提供了完整的 Actor 模型支持，包括对并发/并行程序的简单的、高级别的抽象、异步、非阻塞、高性能的事件驱动编程模型和非常轻量的事件驱动处理。...akka-http：HTTP 组件，现代、快速、异步、流媒体优先的 HTTP 服务器和客户端。 akka-cluster：集群组件，包括集群成员管理、弹性路由等。...从刚刚 Actor 的代码中可以看出，match 方法后面跟的是一个具体的类，也就是说 Akka 自动帮你完成了反序列化，作为消息的接收方，是真正的拿到就能用，没有任何多余代码。

1.3K2 0

Akka 指南之「Actors」

如果当前的 Actor 行为与接收到的消息不匹配，则调用unhandled，默认情况下，它在Actor 系统的事件流上发布akka.actor.UnhandledMessage(message, sender...此外，它还提供： getSelf()，对 Actor 的ActorRef的引用 getSender()，前一次接收到的消息的发送方 Actor 的引用 supervisorStrategy()，用户可重写定义用于监视子...这提供了最佳的并发性和可伸缩性的特性。...要启用硬System.exit作为最终操作，可以配置： akka.coordinated-shutdown.exit-jvm = on 当使用「Akka 集群」时，当集群节点将自己视为Exiting时，...当使用 Akka 集群时，会自动添加集群的优雅离开任务，包括集群单例的优雅关闭和集群分片，即运行关闭过程也会触发尚未进行的优雅离开。

4K3 0

Akka-CQRS（3）- 再想多点，全面点

上篇我介绍了CQRS模式存写部分的具体实现和akka-persistence一些函数和消息的用法。在这篇本来是准备直接用一个具体的例子来示范CQRS模式编程，主要是写端，或者是数据采集端。...目标entity在收到消息后可以自行停止。ShardRegion会保留收到Passivate消息到目标entity停止之间收到的消息，还给再启动的entity。...在本例子里passivation的应用场景如下：每单支付后如果一段时间没有收到新的开单指令，这个shard-entity可以通过向ShardRegion发送Passivate消息或按空转时间段设定自动passivate...：在配置文件中设置 akka.cluster.sharding.passivate-idle-entity-after = 2m，代表两分钟内没有接收从ShardRegion发来的POS指令即启动passivation...11、设计一套POS前端的命名规则：因为有关POS过程的事件持久化是以persistenceId辨别的，所以一个POS编号应该有一个对应的persistenceId，所有这个POS编号的事件都以对应的

6381 0

Akka FSM 源代码分析

各种语言对状态机模式都有非常多种实现的方式。我自己以前用C++和java实现过，也以前把 apache mina 源代码中的一个状态机实现抠出来单独使用。但Akka的状态机是我见过的最简洁美丽实现。...事件处理函数为值创建的可改变的Map，初始值为空Map。这一个数据结构就保存了全部的状态名和事件处理函数。每一个状态名相应一个可选的超时时间，保存在 stateTimeouts 映射中。...超时设置会用新的取代旧的，新的没有指定就用旧的。 when 语法有两个參数列表，第一个列表两个參数，状态名和可选超时，第二个列表是该状态的事件处理函数（记住。...Akka FSM 的状态超时指的是“进入某个状态后一定时间内没有收到不论什么事件”。...receive函数收到 Timer 消息后，取出Timer中的业务事件，调用状态机的事件处理函数。

4742 0

Aloha：一个分布式任务调度框架

Master 则会定期检查所有 Worker 的心跳情况，一旦发现太久没有接收到某一个 Worker 的心跳消息，则认为该 Worker 已经下线。...容错机制由于 Master 负责对整个集群的应用的调度情况进行管理，一旦 Master 出现异常，则整个集群就处于瘫痪的状态，因而必须要考虑为 Master 提供异常恢复机制。...当接收到新事件时，会将事件分派给事件监听器处理。每当 Master 接收到 Application 状态发生变更的消息时，就会将对应的事件放入事件总线，因而监听器可以及时获取到任务状态的变更事件。...RpcEnv 通过工厂模式来创建，底层具体的实现方案是可替换的，目前使用的是基于 Netty 实现的 NettyRpcEnv。...此外，Dispatcher 内部启动了一个 MessageLoop，这个 MessaLoop 不断从阻塞队列中获取有新消息到达的 Endpoint，不断地消化新到达的这些消息。

1.2K2 0

基于Scala的并发编程模型Akka

对并发模型进行了更高的抽象异步、非阻塞、高性能的事件驱动编程模型轻量级事件处理(1GB内存可容纳百万级别个Actor) 为什么 Actor 模型是一种处理并发问题的解决方案呢？...处理并发问题就是如何保证共享数据的一致性和正确性，为什么会有保持共享数据正确性这个问题呢？答：无非是我们的程序是多线程的，多个线程对同一个数据进行修改，若不加同步条件，势必会造成数据污染。...，当然你也可等待它的回复。..."a is ready" } } 四、基于Akka实现智能聊天客服假设智能聊天客服能回答如下问题 1、在吗 2、你叫什么名字 3、你是男的还是女的 4、你在哪对于其他问题直接返回：我听不懂你的问题...ServerToClientMessage("我是中国电信语音客服") case "你是男的还是女的" => sender() !

1.2K2 0

使用Akka实现并发

此方法使线程能够朝着共同的目标一起工作。 Monitor区域当线程到达监视区域的开头时，它将被放入相关监视器的条目集中。这个集就像银行柜台的队列一样。当一个人到达线路前端时，他们就可以进行交易。...我需要的是一个为我提供并发处理的框架，我只能专注于它的业务逻辑部分。我找到了这样一个框架：Akka。Akka基于Erlang actor模型。...Akka基于actors，所以actors是什么？ Actors actors给你带来：简单和高级的并发和并行抽象。异步，非阻塞和高性能的事件驱动编程模型。...非常轻量级的事件驱动进程（每GB堆内存数百万个actor）。使用Akka非常容易。它可以作为依赖项添加到我们的project.Simple jar文件中。...Actors允许您管理服务故障（Supervisors），负载管理（退避策略，超时和处理隔离），以及水平和垂直可扩展性（添加更多内核或机器）。

1.4K2 0

Akka 指南之「集群指标扩展」

文章目录集群指标扩展依赖简介指标收集器指标事件 Hyperic Sigar 配置自适应负载平衡订阅指标事件自定义指标收集器配置集群指标扩展依赖为了使用集群指标扩展（Cluster...中： akka.extensions = [ "akka.cluster.metrics.ClusterMetricsExtension" ] 简介集群的成员节点可以收集系统健康指标，并在集群指标扩展的帮助下将其发布到其他集群节点和系统事件总线上注册的订阅者...指标事件指标扩展定期地将集群指标的当前快照发布到节点系统事件总线。...akka.cluster.metrics.ClusterMetricsChanged事件的有效负载将包含节点的最新指标，以及在收集器采样间隔期间接收到的其他群集成员节点指标流言。...它包含有关如何运行自适应负载平衡示例的说明，此示例的源代码也可以在「 Akka Samples Repository」中找到。订阅指标事件可以直接订阅指标事件来实现其他功能。

6802 0

Flink源码分析之RPC通信

问题导读RPC服务端创建过程RPC客户端创建过程RPC调用流程在Flink集群中整个RPC通信网络是如何一步步建立起来的，连接容错又如何保证简介Flink基于Akka来实现内部各组件(ResourceManager...有兴趣可继续往下阅读。2). 结合代码，看问题1、2、3，进一步熟悉RPC的创建与交互过程。...Actor收到ActorRef发送的消息(消息被封装为RpcInvocation对象)，会通过RpcInvocation对象中的方法、参数等信息以反射的方式调用RpcGateway接口对应的方法。...为什么是JM主动连接RM、TM主动连接RM和JM?...Flink集群中先有ResourceManager和Dispatcher，有任务需要运行时Dispatcher才创建JobMaster(Dispatcher可创建多个JobMaster，一个JobGraph

1.3K13 3

生产上的坑才是真的坑 | 盘一盘Flink那些经典线上问题

这就是为什么值得考虑做一些额外工作的原因，如声明诸如 RichMapFunction 之类的东西，这将使你能更好的控制状态的生命周期。...Please check if the requested resources are available in the YARN cluster 就是字面意思，YARN集群内没有足够的资源启动Flink...有可能是TaskManager已经失败，如果没有失败，那么有可能是因为网络不好导致JobManager没能收到心跳信号，或者TaskManager忙于GC，无法发送心跳信号。...Flink App上线之前要在一个单独的Flink集群上进行测试，否则一个不稳定、存在问题的Flink App上线，很可能影响整个Flink集群上的App。...，继续向下追溯异常栈一般就可以看到具体的出错原因，比较常见的如POJO内有空字段，或者抽取事件时间的时间戳为null等。

4.7K4 0

kakafka - 为CQRS而生

我自认为的分布式运算框架最基础条件是能够把多个集群节点当作一个完整的系统，然后程序好像是在同一台机器的内存里运行一样。当然，这种集成实现方式有赖于底层的一套消息系统。...好了，akka-cluster是通过对每个集群节点上的中介发送消息使之调动该节点上某段程序运行来实现分布式运算的。那么，kafka也可以实现消息在集群节点间的自由流通，是不是也是一个分布式运算框架呢？...与分布式运算框架像akka-cluster对比，kafka还缺了个在每个集群节点上的”运算调度中介“，所以kafka应该不算我所指的分布式运算框架，充其量是一种分布式的消息传递系统。...我想作为一种消息驱动系统，如何保证akka消息的正确产生和安全使用应该是最基本的要求。而恰恰akka是没有提供对消息遗漏和重复消息的保障机制。我想这也是造成akka用户担心的主要原因。...我觉着kafka的exactly-once能力最值得推介。因为在akka或者其它消息队列工具里不容易得到保证。而在一个消息驱动的实时交易系统里，保证事件重演能正确反映当时状态是关键。

5672 0

Flink经典的生产问题和解决方案~(建议收藏)

解决方式：将两个任务独立开来，作为不同的流程。结果：修改之前24个TaskManager(CPU) 来不及消费，改完之后20个CPU可完成任务。...这就是为什么值得考虑做一些额外工作的原因，如声明诸如RichMapFunction之类的东西，这将使你能更好的控制状态的生命周期。...Please check if the requested resources are available in the YARN cluster 就是字面意思，YARN集群内没有足够的资源启动Flink...有可能是TaskManager已经失败，如果没有失败，那么有可能是因为网络不好导致JobManager没能收到心跳信号，或者TaskManager忙于GC，无法发送心跳信号。...，继续向下追溯异常栈一般就可以看到具体的出错原因，比较常见的如POJO内有空字段，或者抽取事件时间的时间戳为null等。

3.5K1 1

Akka（12）：分布式运算：Cluster-Singleton-让运算在集群节点中自动转移

Akka的Cluster-Singleton提供对这种Singleton Actor模式的支持，能做到当这个实例所在节点出现问题需要脱离集群时自动在另一个节点上构建一个同样的Actor，并重新转交控制。...SingletonActor模拟的是一个种树场景：当收到Dig指令后产生登记树坑AddHole事件，在这个事件中更新当前状态值；当收到Plant指令后产生AddTree事件并更新状态。...我们的目的主要是去求证当前集群节点出现故障需要退出集群时，这个SingletonActor是否能够自动转移到其它在线的节点上。...，SingletonActor自动转换到其它的集群节点上继续运行。...值得再三注意的是：以此等简单的编码就可以实现那么复杂的集群式分布运算程序，说明Akka是一种具有广阔前景的实用编程工具！

1.3K7 0

点击加载更多

扫码

添加站长进交流群

领取专属 10元无门槛券

手把手带您无忧上云

扫码加入开发者社群

相关资讯

热门标签

活动推荐

运营活动

活动名称

广告关闭