- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我正在尝试学习 Erlang,但在向另一个节点发送消息时遇到问题。该程序只是一个非常简单的乒乓球,应该像这样工作。我在节点 m1@ASUS-N55SF 上启动一个程序。它创建了一个进程,并在节点 m2 上成功生成了一个进程。所以我得到包含 {PidPing, PidPong} 元组的 Pids。 PidPing 和 PidPong 是进程 ID,如 <0.X.0> 和
之后我调用 ps5:start_pinging(Pids) 函数并收到错误:
Pinging started
Ping received 0 on <0.53.0>
{ping,{<0.53.0>,<6807.43.0>},0}
Nodes: 'm1@ASUS-N55SF' 'm2@ASUS-N55SF'
(m1@ASUS-N55SF)8>
=ERROR REPORT==== 1-Dec-2012::15:27:18 ===
Error in process <0.53.0> on node 'm1@ASUS-N55SF' with exit
value: {badarg,[{ps5,loop_ping,0,[{file,"ps5.erl"},{line,33}]}]}
因此,初始消息到达 PidPing 并被 Loop_ping 接收并成功匹配,但我无法将消息发送到另一个节点,即使它们彼此可见。这会成功,因为此初始消息是在同一节点上发送的:
PidPing ! {pong, {PidPing, PidPong}, 0}.
据我了解,要向另一个节点发送消息,我应该发送如下消息:
{PidPong, ?NODE_TP} ! {pong, {PidPing, PidPong}, Number + 1},
但它返回 badarg。节点已连接,使用相同的 cookie 启动,在同一台机器上运行,并且可以互相 ping 通并且可见。它们在同一文件夹中启动,因此它们会查找相同的 ps5.erl 文件。我也在不同的文件夹中尝试过,但也不起作用。如果代码在 seme 节点上运行,只需删除另一个节点上的生成并在同一节点上创建进程,它就可以工作。
这是代码:
-module(ps5).
-define(NODE_AS, 'm1@ASUS-N55SF').
-define(NODE_TP, 'm2@ASUS-N55SF').
%-define(NODE_TP, 'm2@ThinkPad-Z60m').
-compile(export_all).
start() ->
PidPing = ps5:start_ping(),
PidPong = ps5:start_pong(),
Pids = {PidPing, PidPong}.
start_ping() ->
Pid = spawn(?NODE_AS, ps5, loop_ping, []).
start_pong() ->
Pid = spawn(?NODE_TP, ps5, loop_pong, []).
start_pinging({PidPing, PidPong}) ->
io:format("Pinging started ~n", []),
PidPing ! {ping, {PidPing, PidPong}, 0}.
stop({PidPing, PidPong}) ->
exit(PidPing, normal),
exit(PidPong, normal).
loop_ping() ->
receive
{ping, {PidPing, PidPong}, Number} when Number < 10 ->
io:format("Ping received ~p on ~p~n", [Number, PidPing]),
io:format("Nodes: ~p ~p ~n", [?NODE_AS, ?NODE_TP]),
{PidPong, ?NODE_TP} ! {pong, {PidPing, PidPong}, Number + 1},
io:format("Ping sent ping ~p to ~p~n", [Number, PidPong]),
ps5:loop_ping();
{ping, {PidPing, PidPong}, Number} when Number >= 10->
io:format("Ping received ~p on ~p~n and closing.~n", [Number, PidPing]);
Oops ->
io:format("Oops received: ~p~n", [Oops]),
ps5:loop_ping()
end.
loop_pong() ->
receive
{pong, {PidPing, PidPong}, Number} when Number < 10 ->
io:format("Pong received ~p on ~p~n", [Number, PidPong]),
io:format("Nodes: ~p ~p ~n", [?NODE_AS, ?NODE_TP]),
{PidPing, ?NODE_AS} ! {ping, {PidPing, PidPong}, Number + 1},
io:format("Pong sent ping ~p to ~p~n", [Number, PidPing]),
ps5:loop_pong();
{pong, {PidPing, PidPong}, Number} when Number >= 10->
io:format("Pong received ~p on ~p~n and closing.~n", [Number, PidPing]);
Oops ->
io:format("Oops received: ~p~n", [Oops]),
ps5:loop_pong()
end.
编译过程中出现一些警告,但它们与这个问题无关(至少我这么认为)。
最佳答案
构造{Registered_process_name, Erlang_node}! Some_message
用于向您不知道 PID 的远程注册进程发送消息。
在您的情况下,您知道 pid(并且进程未注册),这意味着您不能使用 {name, node} !消息
而是PID!消息
即更改:
{PidPong, ?NODE_TP} ! {pong, {PidPing, PidPong}, Number + 1},
至
PidPong ! {pong, {PidPing, PidPong}, Number + 1},
和
{PidPing, ?NODE_AS} ! {ping, {PidPing, PidPong}, Number + 1},
至
PidPing ! {ping, {PidPing, PidPong}, Number + 1},
关于erlang - 从一个节点向另一个节点发送 Erlang 消息返回 badarg,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/13660657/
我想实现一个 Erlang 解释器,最近我在阅读 Erlang 的标准库源代码。我在 erlang.erl 中找到 erlang:display/1 的源代码是: %% display/1 -spec
我即将用 Erlang 构建一个系统(我的问题可以用多个 CPU 更好地解决),我已经浏览了: 向你学习一些 Erlang; Erlang/OTP 在行动 编程 Erlang(阿姆斯壮); Erlan
我真的很难理解 Erlang 中的尾递归。 我有以下 eunit 测试: db_write_many_test() -> Db = db:new(), Db1 = db:write(f
我不确定或者我不知道 erlang 定位不在默认目录中的模块的传统方式。我知道它会查看已编译的文件夹和 erlang 的系统文件夹或 - lists:foreach(fun (E) -> io:fwr
对 Erlang 完全陌生。我正在尝试为函数组合定义一些函数,例如 compose , juxt和 pipe但是遇到这样一个事实,即 Erlang 没有(据我所知)可变参数,因此很难只编写适用于所有输
在 Erlang 中存储和管理高性能可变对象的最佳方法是什么?假设我想编写具有实时游戏玩法的非常简单的在线游戏服务器。不知何故,我需要在 Erlang 内存中表示玩家的状态。例如,它可能只是一个简单的
警告:前面的 erlang n00b。 我正在尝试掌握 erlang,只是尝试与牛仔一起使用基本的 hello world 应用程序。我正在模拟一个错误,基本上是在我的代码中的某处返回一个无效值,并试
当你向 shell 进程发送消息时,你可以通过调用: c:flush(). 来清除所有消息。 C:\Windows\System32>erl Eshell V5.9(使用 ^G 中止) 1> 自我()
这应该是一个简单的问题,但我不太了解文档,无法找到答案。 如果 OTP 管理器在崩溃后重新启动 gen_server,新子进程是否继承了崩溃进程的消息队列,或者消息是否在崩溃之前发送但尚未由旧子进程处
我将 net_ticktime 值设置为 600 秒。 net_kernel:set_net_ticktime(600) 在 net_ticktime = TickTime 的 Erlang 文档中:
我正在监视一个 Erlang 应用程序,我目前正在尝试确定特定 PID 已经运行了多长时间。绝对时间戳或持续时间对我有用,但我在 process_info 或通过 sys 模块看不到这些数据位中的任何
我想重新定义查找特定单词的元组的顺序 例如,我有一个像这样的元组列表: [{"a",["r001"]}, {"bi",["bidder"]}, {"bo",["an"]}] 但有时元组的顺序可能会
以下几行出现在 http://aosabook.org/en/riak.html 中,在该部分的第二段: 15.1. Erlang 简介 : "Calling the function with a
我认为 Erlang 节点之间的消息不应该很大。如果我想构建一个流服务器,通常每个连接都需要很大的带宽,Erlang 能做好吗?如果是,是否有任何开源代码可供我学习?我了解到 Erlang 很适合处理
下一个代码在结果中给了我 5.999999999999998,但正确答案是 6。 Alpha = math:acos((4*4 + 5*5 - 3*3) / (2*4*5)) Area = 1/2 *
注意:这是我的 previous question 的进化延续。关于类似的话题。 一段时间以来,我一直在寻找有关部署和更新 Erlang/OTP 版本(一组应用程序)的“最佳实践”,但我找不到任何直接
我试图在头文件中指定一个函数。 像这样: -spec update(pid(), tuple(tuple(), integer(), atom()), tuple(atom(), atom())) -
所以我在过去的八个小时里一直在使用 Erlang,我花了两个时间用我的头敲击键盘试图找出我的控制台不断返回的异常错误。 我正在编写一个骰子程序来学习erlang。我希望它能够通过 erlang 解释器
当我编译以下模块时: -module(x). -export([inp/0]). f(X) -> g(X). g(X) -> error(X). inp() -> f(123)
我目前正在开发一个实时媒体服务器,它将允许普通消费者向我们发送实时视频。在我们当前的环境中,我们已经看到发送给我们的广播持续了几天,因此能够在不断开用户连接的情况下修复错误(或添加功能)的想法非常引人
我是一名优秀的程序员,十分优秀!