tcp - HAProxy 背后的 Akka

coder 2023-09-19 原文

我有 2 个系统:系统 1 正在运行 akka 和 HAProxy，系统 2 正在运行向 akka 发出请求的 REST 组件。

Akka 在系统 1 的端口 4241 上运行。当没有 HAProxy 时，系统 2 能够连接到系统 1。我在系统 1 上安装 HAProxy 后，从系统 2 到系统 1 的请求出错，日志如下:

ERROR[deal-akka.actor.default-dispatcher-18] EndpointWriter - dropping message [class akka.actor.ActorSelectionMessage] for non-local recipient [Actor[akka.tcp://akkaSystemName@Server1IP:42431/]] arriving at [akka.tcp://akkaSystemName@Server1IP:42431] inbound addresses are [akka.tcp://akkaSystemName@Server1IP:4241]

HAProxy 在 42431 上运行。

HAProxy 配置如下:

listen akka_tcp :42431
        mode tcp
        option tcplog
        balance leastconn

        server test1 Server1IP:4241 check
        server test2 Server1IP:4241 check

akka配置是这样的:

  actor {
    provider = "akka.remote.RemoteActorRefProvider"
  }

  remote {
    netty.tcp {

      hostname = "Server1IP"

      port = 4241

      transport-protocol = tcp

      # Sets the send buffer size of the Sockets,
      # set to 0b for platform default
      send-buffer-size = 52428800b

      # Sets the receive buffer size of the Sockets,
      # set to 0b for platform default
      receive-buffer-size = 52428800b

      maximum-frame-size = 52428800b
    }
  }

如有任何建议，我们将不胜感激。

最佳答案

更新后的答案:

Akka Remoting 可能不适用于负载均衡器。看看它的这部分documentation :

Akka Remoting is a communication module for connecting actor systems in a peer-to-peer fashion, and it is the foundation for Akka Clustering. The design of remoting is driven by two (related) design decisions:

1.Communication between involved systems is symmetric: if a system A can connect to a system B then system B must also be able to connect to system A independently.

2.The role of the communicating systems are symmetric in regards to connection patterns: there is no system that only accepts connections, and there is no system that only initiates connections.

The consequence of these decisions is that it is not possible to safely create pure client-server setups with predefined roles (violates assumption 2) and using setups involving Network Address Translation or Load Balancers (violates assumption 1).

For client-server setups it is better to use HTTP or Akka I/O.

对于您的情况，在系统 1 上使用 Akka HTTP 或 Akka I/O 来接受和回答来自系统 2 的请求似乎是合理的。

旧答案:

您必须在 Akka 配置中设置 bind-port 属性。这是来自 Akka documentation 的引述:

# Use this setting to bind a network interface to a different port
# than remoting protocol expects messages at. This may be used
# when running akka nodes in a separated networks (under NATs or docker containers).
# Use 0 if you want a random available port. Examples:
#
# akka.remote.netty.tcp.port = 2552
# akka.remote.netty.tcp.bind-port = 2553
# Network interface will be bound to the 2553 port, but remoting protocol will
# expect messages sent to port 2552.

对于您的端口，它应该是这样的:

port = 42431
bind-port = 4241

关于tcp - HAProxy 背后的 Akka，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/32678139/

有关tcp - HAProxy 背后的 Akka的更多相关文章

ruby - 变量赋值后的 if 语句 - 有多常见？ - 2
我最近与一位同事讨论了以下Ruby语法:value=ifa==0"foo"elsifa>42"bar"else"fizz"end我个人并没有看到太多这种逻辑，但我的同事指出，这实际上是一种相当普遍的Rubyism。我试着用谷歌搜索这个主题，但没有找到任何文章、页面或SO问题来讨论它，这让我相信这可能是一种非常实际的技术。然而，另一位同事发现语法令人困惑，而是将上面的逻辑写成这样:ifa==0value="foo"elsifa>42value="bar"elsevalue="fizz"end缺点是value=的重复声明和隐式elsenil的丢失，如果我们想使用它的话。这也感觉它与Ruby
ruby - 无论如何要在 REPL 中重新加载修改后的 gem 文件 - 2
在尝试构建Rubygem(使用Bundler)时，我倾向于使用Bundler提供的REPL测试代码——可通过bundleconsole访问。有什么方法可以重新加载整个项目吗？我最终再次加载单个(更改的)文件以测试新更改。最佳答案以下hack适用于我的一个相对简单的gem和Ruby2.2.2。我很想看看它是否适合你。它做出以下假设:您具有传统的文件夹结构:一个名为lib/my_gem_name.rb的文件和一个文件夹lib/my_gem_name/，其中包含任何文件/文件夹结构。您要重新加载的所有类都嵌套在您的顶级模块MyGemN
ruby - 删除指定节点之后的所有节点 - 2
这个问题在这里已经有了答案:Nokogiri:SelectcontentbetweenelementAandB(3个答案)关闭2年前。我正在从url中抓取文本的div，并想删除具有backtotop类的段落下方的所有内容。我在stackoverflow上看到了一段遍历代码片段，看起来很有希望，但我不知道如何将它合并，所以@el只包含第一个p.backtotop之前的所有内容分区我的代码:@doc=Nokogiri::HTML(open(url))@el=@doc.css("div")[0]end遍历片段:doc=Nokogiri::HTML(code)stop_node=doc.css
ruby - `+` 在 `*` 之后的含义，当后者在正则表达式中用作量词时 - 2
今天我遇到了下面的正则表达式，想知道Ruby会用它做什么:>"#a"=~/^[\W].*+$/=>0>"1a"=~/^[\W].*+$/=>nil在这种情况下，Ruby似乎忽略了+字符。如果这是不正确的，我不确定它在做什么。我猜它没有被解释为量词，因为*没有转义并且被用作量词。在Perl/Ruby正则表达式中，有时当一个字符(例如，-)在不能被解释为特殊字符的上下文中使用时，它会被视为文字。但如果在这种情况下发生这种情况，我希望第一个匹配失败，因为左值字符串中没有+。这是对+字符的巧妙正确使用吗？以上行为是错误吗？我是否遗漏了一些明显的东西？最佳答案
计算机网络笔记：TCP三次握手和四次挥手过程 - 2
TCP是面向连接的协议，连接的建立和释放是每一次面向连接的通信中必不可少的过程。TCP连接的管理就是使连接的建立和释放都能正常地进行。三次握手TCP连接的建立—三次握手建立TCP连接①若主机A中运行了一个客户进程，当它需要主机B的服务时，就发起TCP连接请求，并在所发送的分段中用SYN=1表示连接请求，并产生一个随机发送序号x，如果连接成功，A将以x作为其发送序号的初始值：seq=x。主机B收到A的连接请求报文，就完成了第一次握手。客户端发送SYN=1表示连接请求客户端发送一个随机发送序号x，如果连接成功，A将以x作为其发送序号的初始值：seq=x②主机B如果同意建立连接，则向主机A发送确认报
ChatGPT教程之深入了解魔术背后的技术 - 2
解开谜团：深入探索ChatGPT的技术奇迹。ChatGpt无处不在，无论是在播客、博客、YouTube还是社交媒体上。当我注意到这项新技术如此受欢迎时，我决定试一试，我被震惊了！有很多关于ChatGpt及其魔力的博客，但在这篇博客中，我将深入探讨其内部技术及其工作原理！ChatGpt简介根据OpenAI，ChatGpt被描述为：“我们训练了一个名为ChatGpt的模型，它以对话方式进行交互。对话格式使ChatGpt可以回答后续问题、承认错误、挑战不正确的前提并拒绝不适当的请求。ChatGPT是InstructGPT的兄弟模型，它经过训练可以按照提示中的说明进行操作并提供详细的响应。”OpenA
ruby - 在随后的 bundle 安装中跳过 native 扩展重新编译 - 2
由于安装nokogirigem(1.6.0)需要时间，我的生产部署需要额外几分钟。我知道这是因为安装gem会触发native扩展编译。请注意，我已经打包我的包并将其checkinDVCSbundlepackage如果没有其他任何变化，是否有一种方法可以避免重新编译native扩展，从而加快部署速度？更新:我使用OpscodeChef进行部署(具体来说是chef-solo)环境是:Ubuntu12.04LTS64位ruby193-p448 最佳答案我找到了一种方法来做到这一点。解释如下:Bundler，默认情况下将gems安装到环境
ruby - 此修改后的二十一点游戏的最佳获胜策略是什么？ - 2
问题有没有可以保持的最佳值(value)，这样我才能赢得尽可能多的比赛？如果是这样，那是什么？编辑:是否可以为给定的限制计算出确切的获胜概率，而与对手的所作所为无关？(自大学以来，我还没有做过概率和统计)。我有兴趣将其作为与模拟结果进行对比的答案。编辑:修复了我算法中的错误，更新了结果表。背景我一直在玩改进的二十一点游戏，其中对标准规则进行了一些相当烦人的规则调整。我已将与标准二十一点规则不同的规则斜体化，并为不熟悉的人添加了二十一点规则。修改二十一点规则正是两个人类玩家(经销商无关)每个玩家面朝下发两张牌双方玩家_ever_都不知道对手纸牌的_any_的值在_both_完成手牌之前，
ruby - yarn 未初始化常量 Socket::SOL_TCP - 2
我在这里尝试使用yarn，遇到了一个可能与ruby相关的问题。在执行任何yarn命令，我收到错误.../.rvm/gems/ruby-2.3.0/gems/yarn-0.1.1/lib/yarn/server.rb:14:in':uninitializedconstantSocket::SOL_TCP(NameError)错误堆栈:$yarn.../.rvm/gems/ruby-2.3.0/gems/yarn-0.1.1/lib/yarn/server.rb:14:in':uninitializedconstantSocket::SOL_TCP(NameError)Didyoume
Ruby 相当于 Python 的 "array[i:]"选择 i 之后的所有数组元素？ - 2
我发现自己想要类似Python的东西ary=[1,2,3,4,5,6,7,8]ary[2:]#=>[3,4,5,6,7,8]这些天所有的时间。解决方案最终总是多行且丑陋。我想知道最优雅的解决方案可能是什么，因为我的不值得展示。最佳答案使用Array#drop2.1.0:019>ary.drop(2)=>[3,4,5,6,7,8] 关于Ruby相当于Python的"array[i:]"选择i之后的所有数组元素？，我们在StackOverflow上找到一个类似的问题：

tcp - HAProxy 背后的 Akka

更新后的答案:

旧答案:

有关tcp - HAProxy 背后的 Akka的更多相关文章

随机推荐