程序员经验分享-hwhale

Akka：如何查找集群中的当前节点？

2023-11-23

从 Akka actor 内部，如何找到集群的节点？ 即本节点认为当前可以访问的节点。

谢谢， - 丹尼尔


您实际上不需要订阅ClusterDomainEvent or MemberEvent。您只需访问state集群扩展的成员，例如

val cluster = akka.cluster.Cluster(context.system)

val members = cluster.state.members.filter(_.status == MemberStatus.Up)
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

Java

scala

clustercomputing

akka

distributedcomputing

Akka：如何查找集群中的当前节点？ 的相关文章

  • ElasticBeanstalk Java，Spring 活动配置文件

    我正在尝试通过 AWS ElasticBeanstalk 启动 spring boot jar 一切正常 配置文件为 默认 有谁知道如何为 java ElasticBeanstalk 应用程序 不是 tomcat 设置活动配置文件 spri

  • Java程序中的数组奇怪的行为[重复]

    这个问题在这里已经有答案了 我遇到了这个 Java 程序及其以意想不到的方式运行 以下程序计算 int 数组中元素对之间的差异 import java util public class SetTest public static void

  • JNI 不满意链接错误

    我想创建一个简单的 JNI 层 我使用Visual studio 2008创建了一个dll Win 32控制台应用程序项目类型 带有DLL作为选项 当我调用本机方法时 出现此异常 Exception occurred during even

  • ExceptionConverter：java.io.IOException：文档没有页面。我正在使用 iText

    当我执行下面的代码时 File f new File c sample pdf PdfWriter getInstance document new FileOutputStream f document open System out p

  • 如何查找 Android 设备中的所有文件并将它们放入列表中？

    我正在寻求帮助来列出 Android 外部存储设备中的所有文件 我想查找所有文件夹 包括主文件夹的子文件夹 有办法吗 我已经做了一个基本的工作 但我仍然没有得到想要的结果 这不起作用 这是我的代码 File files array file

  • 在浏览器中点击应用程序时播放框架挂起

    我正在 Play 中运行一个应用程序activator run 也许 5 次中有 3 次 它会挂起 当我去http localhost 9000 它就永远坐在那里旋转 我看到很多promise timed out错误也 我应该去哪里寻找这个

  • HDFS：使用 Java / Scala API 移动多个文件

    我需要使用 Java Scala 程序移动 HDFS 中对应于给定正则表达式的多个文件 例如 我必须移动所有名称为 xml从文件夹a到文件夹b 使用 shell 命令我可以使用以下命令 bin hdfs dfs mv a xml b 我可以

  • 解决 sbt 中 jar 加载冲突的问题

    当两个特定的 sbt 插件启动时 我在 sbt 启动时收到以下错误加在一起到其构建定义中的项目 这些 sbt 插件之一是规模化jdbc https github com scalikejdbc scalikejdbc另一个是my own h

  • 在具有相同属性名称的不同数据类型上使用 ModelMapper

    我有两节课说Animal AnimalDto我想用ModelMapper将 Entity 转换为 DTO 反之亦然 但是对于具有相似名称的一些属性 这些类应该具有不同的数据类型 我该如何实现这一目标 动物 java public class

  • Java中接口作为方法参数

    前几天去面试 被问到了这样的问题 问 反转链表 给出以下代码 public class ReverseList interface NodeList int getItem NodeList nextNode void reverse No

  • 检查 Android 手机上的方向

    如何查看Android手机是横屏还是竖屏 当前配置用于确定要检索的资源 可从资源中获取Configuration object getResources getConfiguration orientation 您可以通过查看其值来检查方向

  • 反思 Groovy 脚本中声明的函数

    有没有一种方法可以获取 Groovy 脚本中声明的函数的反射数据 该脚本已通过GroovyShell目的 具体来说 我想枚举脚本中的函数并访问附加到它们的注释 Put this到 Groovy 脚本的最后一行 它将作为脚本的返回值 a la

  • 应用程序关闭时的倒计时问题

    我制作了一个 CountDownTimer 代码 我希望 CountDownTimer 在完成时重新启动 即使应用程序已关闭 但它仅在应用程序正在运行或重新启动应用程序时重新启动 因此 如果我在倒计时为 00 10 分钟 秒 时关闭应用程序

  • 将 JSON 参数从 java 发布到 sinatra 服务

    我有一个 Android 应用程序发布到我的 sinatra 服务 早些时候 我无法读取 sinatra 服务上的参数 但是 在我将内容类型设置为 x www form urlencoded 之后 我能够看到参数 但不完全是我想要的 我在

  • 当单元格内的 JComboBox 中有 ItemEvent 时，如何获取 CellRow

    我有一个 JTable 其中有一列包含 JComboBox 我有一个附加到 JComboBox 的 ItemListener 它会根据任何更改进行操作 但是 ItemListener 没有获取更改的 ComboBox 所在行的方法 当组合框

  • 数量重新分配逻辑 - 具有外部数据集的 MapGroups

    我正在研究一种复杂的逻辑 需要将数量从一个数据集重新分配到另一个数据集 在例子中我们有Owner and Invoice 我们需要从数量中减去Invoice准确地Owner匹配 在给定汽车的给定邮政编码处 减去的数量需要重新分配回同一辆车出

  • 如何测试 spring-security-oauth2 资源服务器安全性？

    随着 Spring Security 4 的发布改进了对测试的支持 http docs spring io spring security site docs 4 0 x reference htmlsingle test我想更新我当前的

  • com.jcraft.jsch.JSchException：身份验证失败

    当我从本地磁盘上传文件到远程服务器时 出现这样的异常 com jcraft jsch JSchException Auth fail at org apache tools ant taskdefs optional ssh Scp exe

  • Jackson 将单个项目反序列化到列表中

    我正在尝试使用一项服务 该服务为我提供了一个带有数组字段的实体 id 23233 items name item 1 name item 2 但是 当数组包含单个项目时 将返回该项目本身 而不是包含一个元素的数组 id 43567 item

  • Swagger/Openapi-Annotations：如何使用 $ref 生成 allOf？

    我正在生成 Rest 端点 包括添加OpenAPI Swagger对生成的代码进行注释 虽然它对于基本类型运行得很好 但我在自定义类方面遇到了一些问题 现在我有很多自定义类的重复架构条目 使用 Schema 实现 MyClass class

随机推荐

  • MySQL 事务与会计应用程序

    我有一个如下表 transaction id user id other user id trans type amount 该表用于维护金融类型应用程序的帐户交易 它采用复式记账法 因此从用户 A 到 B 的转账将在表中插入两行 如下所示

  • 地理坐标到街道名称

    是任何方式 与restAPI会很棒 来获取与地理坐标对应的街道名称 我认为这个名字是geocoding google有这个API吗 我是 PHP 开发人员 Ex 因此该函数的输出是街道名称 邮政编码和城市 感谢您提供任何帮助和脚本示例 是的

  • 函数侦听器无法启动。 Azure函数应用程序时间触发

    当我在本地环境中从 Visual Studio 运行 azure 函数时 出现以下错误 函数 Function1 的侦听器无法启动 Microsoft WindowsAzure Storage 错误请求 这是我的代码 using Syste

  • Vim - 如何使您自己的映射可重复？

    我的 vimrc 中有以下映射 nmap

  • 将自定义上下文菜单项添加到 Windows 窗体标题栏

    I found a threadMSDN 上展示了如何将项目添加到 Windows 窗体标题栏的上下文菜单 不幸的是 它没有显示如何使用自定义菜单项注册事件 我一直无法弄清楚如何做到这一点 下面是一个示例应用程序 可以将其复制并粘贴到新的

  • django - 如何交叉检查 ModelAdmin 及其内联？

    我有两个模型 ModelParent 和 ModelChild 在主题模型上具有相同的 m2m 字段 ModelChild 在 ModelParent 上有一个外键 并且 ModelChild 在管理页面上被定义为 ModelParent

  • 发布请求 Axios：网络错误

    我使用 NodeJS 作为后端 使用 ReactJS 作为前端 我请求 Axios 网络时遇到问题 我所有的 Get 请求都有效 但是Post请求不起作用 我只是遇到这个错误 网络错误 我创建了一个简单的网络服务来向您展示我的问题 Serv

  • jquery .click 函数的基本延迟

    我有最基本的 jquery 函数 但我无法在文档中找到一种方法来在 1500 毫秒后触发此单击函数的内容 masonryRecall click function mainContent masonry 附 刚刚注意到 delay 函数 j

  • python 中的站点包是什么？如果您不是 root，您可以安装/使用它们吗？

    我正在尝试安装lldb在 Linux 中到我系统上的主目录 我没有 root 访问权限 并且我在尝试创建子目录的步骤中遇到了问题 usr lib python2 6 site packages 我在 Makefile 中找到了设置此变量的行

  • 创建一个粘在 UITableView 底部的 UIView

    我有一个grouped UITableView我想在我的最底部添加一个 UIButtonUITableView 我正在使用 Storyboard 和 UITableViewController 我不太确定需要在哪里添加代码或拖 放 UI 元

  • 如何使用 json.net 设置 json 路径的值

    我正在尝试在 JSON 结构中设置任意路径 但我很难弄清楚如何执行简单的设置值 我想要的是像 SetValue path value 这样的方法 其操作类似于 SelectToken 但如果路径不存在则创建路径并设置值 public voi

  • Perl - 从输入字符串中获取第一个“单词”

    我正在尝试编写一个 Perl 程序 该程序从文本文件中读取行 并且对于每一行 从该行中提取第一个 单词 并根据返回的字符串执行不同的操作 主循环如下所示 while

  • 如何从特定版本的 Google Sheet 读取数据？

    我在互联网上找到了从最新版本的Google Sheet读取数据的代码示例 如下所示 SpreadsheetService service new SpreadsheetService Print Google Spreadsheet Dem

  • 将“new-row”的 DataGridViewImageColumn 中的“red-cross”替换为自定义图像

    如果您指定AllowUserToAddRows在winforms中DataGridView用户可以在网格中手动添加新行 现在我想在一列中添加一个图像按钮 该按钮也应该显示在新行中 但我无法让它显示图像 只显示红十字图像 就像没有找到一样 这

  • Spring自定义注解多字段验证

    这里有一个有点贪心的问题 希望这个问题也能帮助其他想了解更多注释验证的人 我目前正在学习Spring 目前 我计划尝试一下自定义注释验证 我查了很多 现在知道主要有两种验证 一种是用于控制器的 另一种是使用 Valid的注解方法 这是我的场

  • PHP 在所有请求中保留变量

    在某些语言 C 或 NET 中 这将是静态变量 但在 PHP 中 每次请求后都会清除内存 我希望该值在所有请求中持续存在 我不想 SESSION 因为每个用户的情况都不同 为了帮助解释这里有一个例子 我想要一个像这样的可以计数的脚本 无论哪

  • 在 File.Create 之后关闭文件[重复]

    这个问题在这里已经有答案了 我检查文件是否存在 if File Exists myPath File Create myPath 但是 当我去创建一个StreamReader使用这个新创建的文件 我收到一条错误消息 该进程无法访问文件 此处

  • 摆脱停用词和标点符号

    我正在与 NLTK 停用词作斗争 这是我的代码 有人可以告诉我出了什么问题吗 from nltk corpus import stopwords def removeStopwords palabras return word for wo

  • 为什么在 HTC Desire 上发送短信时出现 NullPointerException，或者什么是 SubmitPdu？

    所以我得到这个堆栈跟踪 java lang NullPointerException at android telephony SmsMessage SubmitPdu

  • Akka：如何查找集群中的当前节点？

    从 Akka actor 内部 如何找到集群的节点 即本节点认为当前可以访问的节点 谢谢 丹尼尔 您实际上不需要订阅ClusterDomainEvent or MemberEvent 您只需访问state集群扩展的成员 例如 val clu

热门标签