我不能确定错误在哪里,但我正在尝试在Python客户机和Chapel服务器之间传递消息。客户端代码是
import zmq
context = zmq.Context()
socket = context.socket(zmq.REQ)
socket.connect("tcp://localhost:5555")
for request in range(10):
print("Sending request %s ..." % request)
socket.send(str("Yo"))
message = socket.recv()
print("OMG!! He said %s" % message)
礼拜堂的侍者是
^{pr2}$这个信息似乎很普遍,但我并不真正理解。在
server.chpl:7: error: halt reached - Error in Socket.recv(string): Operation cannot be accomplished in current state
我想我双方都在发送/接收。最初的礼拜堂示例on the Chapel site运行得很好,但是我在修改它时遇到了困难。在
在this thread礼拜堂团队的帮助下,这项工作开始了。在
客户。py
import zmq
context = zmq.Context()
socket = context.socket(zmq.REQ)
socket.connect("tcp://localhost:5555")
for request in range(10):
message = "Hello %i from Python" % request
print("[Python] Sending request: %s" % message)
socket.send_string(message)
message = socket.recv_string()
print("[Python] Received response: %s" % message)
服务器。chpl
use ZMQ;
var context: Context;
var socket = context.socket(ZMQ.REP);
socket.bind("tcp://*:5555");
for i in 0..#10 {
var msg = socket.recv(string);
writeln("[Chapel] Received message: ", msg);
socket.send("Hello %i from Chapel".format(i));
}
@user3666197的回答很好地讨论了ZeroMQ状态机,我认为问题在于Chapel
ZMQ
模块如何序列化和传输字符串。在Chapel中的^{} 和^{} 方法通过发送两条消息来序列化字符串。这是为了匹配ZeroMQ Guide's "Minor Note on Strings"中的模式,的目的是为了匹配ZeroMQ Guide's "Minor Note on Strings"中的模式,但是,在实现时,此序列化方案是不正确的,并且与某些ZeroMQ套接字模式不兼容。在
为了发送一个字符串,Chapel发送一个包含两个调用的多部分消息}标志,第二个是字节缓冲区;接收的工作原理类似。这意味着你对
zmq_send()
:第一个字符串大小带有{socket.recv(string)
的一个调用实际上是在幕后对zmq_recv()
进行两个背靠背的调用。对于REQ
/REP
模式,这两个连续的zmq_recv()
调用将ZeroMQ状态机置于无效状态,因此会出现错误消息。在这绝对是Chapel的
ZMQ
模块的一个bug。在作为参考,我是Chapel
ZMQ
模块的作者(绝对不是没有bug的)。在在chapel团队解决并重新确认之前,请仅使用}原型(由于字符串匹配悬而未决的问题)。在
int
有效负载测试任何{a1}ZMQ模块服务,并可能避免{由于@Nick最近disclosed here,要实现
ZMQ
服务以满足ZeroMQ API合规性,并为异构分布式系统完全打开交叉兼容大门,还有一条路要走:几个步骤可以让现场更加明朗:
在诊断根本原因之前,让我提出一些要采取的措施。ZeroMQ是一个非常强大的框架,在这个框架中,人们很难选择比
REQ/REP
更难(和更脆弱)的消息传递原型。在内部的有限状态自动机(事实上,分布式FSA)都是阻塞的(通过设计,在连接的对等点之间强制执行类似钟摆的消息传递(不需要仅仅是前2个),这样[a]-
.send()
-.recv()
-.send()
-.recv()
-。。。在一侧[A]匹配[B]-.recv()
-.send()
-.recv()
-…)如果由于某种原因,双方都进入等待状态,此时[a]和[B]都期望从信道的另一端接收下一条消息,那么这个dFSA也存在一个主要无法挽救的相互死锁。在这就是说,我的建议是首先进行一个最简单的测试-使用一对不受限制的单纯形通道(可以是[a]}的更复杂的方案)。在
PUSH
/[B]PULL
+[B]PUSH
/[a]PULL
,或者使用{不是为一个完全网格化的多代理基础设施建立,而是这个基础设施的简化版本(不需要也不打算使用
ROUTER/DEALER
通道,但是如果扩展模型方案,可能会复制(反转)PUSH/PULL
-s):对于由当前的chapel实现约束产生的隐含限制,还需要花费更多的精力:
如果这些备注不仅仅是线级别的内部特性,并且扩展到顶层的ZeroMQ消息传递/信令层(参见管理订阅的详细信息,其中ZeroMQ主题筛选器匹配基于左侧与接收到的消息的精确匹配,则应该进行一些调整 ). 在
python侧享有更大的设计自由:
一些进一步的
try:/except:/finally:
构造应该为来自无限while()
-loops等的KeyboardInterrupt
-s服务,但是为了清楚起见,这里省略了这些。在在chapel方面,我们将尽力跟上API的步伐,如下所示:
如果对
^{pr2}$.send()
/.recv()
方法的调用隐式总是阻塞的,而您的代码假定它是在阻塞模式下运行的(对于任何分布式系统设计,我总是强烈建议不要使用这种模式),文档也不能帮助决定用户代码是否可以控制,阻塞是一个糟糕的实践-more on this here)。在相关问题 更多 >
编程相关推荐