问题标签 [message-passing]

我已经从我的内容脚本发送了一个请求，并成功地从我的后台页面收到了响应。现在我想在我的内容脚本中设置一个变量 - 基于响应。这就是我遇到麻烦的地方。应该很简单......我想我一定是语法错误。这是我的内容脚本中的内容：

控制台显示goaway为响应，但wasPoite仍未定义。

我想在一个新线程上调度一个任务，并且我希望这个任务在其执行的各个阶段通知父线程。如下所示：

这个用例的标准库解决方案是什么？（我想外部依赖。）

所以我在这里，几乎无法在 Windows 桌面上安装 libzmq，然后用 cabal 安装 zeromq-haskell。我想通过在 hello-world 类型的应用程序中将 python 程序与 haskell 程序绑定来测试 api。

所以我看到的最基本的模式是请求-回复模式。首先，我尝试用haskell（REP）制作服务器，用python（REQ）制作客户端，无论我做什么，女巫都惨遭失败。生成的异常消息是 Exception: receive: failed (No error)。

因此，我查看了 System.ZMQ 和 System.ZMQ.Base 源代码，我看到在调用 c_zmq_recv 时接收会引发错误，而女巫又会直接映射到对 C api 的 ffi（？）调用。所以我想也许我没有正确安装，但后来我尝试在 Haskell 中创建客户端，在 python 中创建服务器，我注意到它没有任何问题，所以可能 recv 接口不是这里的问题。

这是下面的haskell代码，具有客户端和服务器功能

现在我真的没有时间测试所有其他通信模式（推/拉、订阅/发布、配对等），而对于我需要的 python 服务器/haskell 客户端可能更好，但我对天气很好奇我'我做错了什么，或者我的代码的任何部分以任何方式损坏。

提前致谢

kaazing publishBasic 传递 json 数据并在 node.js 中捕获它

下面是通过 kaazing AMQP 库将数据发布到 RabbitMQ 的代码

这是在 node.js 中捕获数据的代码

问题是 publishBasic 函数期望正文以字节为单位，我想传递 json 并在 node.js 中获取该 json

任何帮助将不胜感激。

我在 Global.asax 中有一个全局错误处理程序，并试图在名为 ErrorPage.aspx 的页面中显示异常信息。我已经阅读了微软关于在 asp.net 页面之间传递信息的页面 (http://msdn.microsoft.com/en-us/library/6c3yckfw.aspx)。我认为这些都行不通：

• QueryString：我担心异常的长度会超过QueryString的最大长度。
• 发布信息： Global.asax 页面没有任何表单字段。
• 会话状态：会话状态在 Global.asax 中不可用
• 公共价值观：我认为这仅适用于 .aspx 页面
• 来自源页面的控件：Global.asax 不能有 asp.net 控件。

我目前的想法是创建 ErrorPage 对象的实例并导航到它是合乎逻辑的（就像您可以在 Windows 窗体应用程序中所做的那样），但我不知道如何做到这一点，或者在 asp 中是否可行。网。

最终，我正在寻找一种在标准 .aspx 页面中显示由全局错误处理程序捕获的错误的方法。任何的意见都将会有帮助。

我有一个类，称之为A将一些数据解析为NSDictionary. 该类有一个表格视图，当一个单元格被选中时，会实例化一个新类，我们称之为该类B。类B反过来实例化类C。我希望班级C接收NSDictionary在A.

代表会工作吗？即使C没有实例化类，它会起作用吗？如果这是真的而且它真的不是，我应该在方法中传递来自A--> B-->的数据吗？Objective-C 中有更好的消息传递方法吗？Cinit

我已经实现了一个带有生产者和消费者的示例 MPI 应用程序。生产者在等级为 0 的进程上运行，消费者将在所有非零等级上运行。消费者将产生消费者工作线程来处理生产者生成的消息。消费者线程分为接收线程和工作线程。

消费者接收者线程执行recv，并在接收时传递要由消费者工作者消费的消息，消费者工作者在执行计算后将处理后的消息发送回生产者（根）。

我在我的双核机器上运行这段代码。我注意到的是，当我使用 执行我的应用程序时mpirun -np 2，该应用程序对于生产者生成的任意数量的消息都运行良好。当我尝试使用 运行应用程序时mpirun -np 4，应用程序在处理几次运行后崩溃。

以前有人遇到过这个问题吗？了解为什么会发生这种情况会很棒。

编辑：这是我每次运行应用程序时都会遇到的异常：

谢谢

谁能简单地向我解释一下消息传递是如何在方案中实现的？我认为我对消息传递的整个概念不太了解。

在共享地址空间模型中，进程之间共享一个公共地址空间，并表示为内存中的数据结构（如ConcurrentHashMap）。这提供了非常快速的数据共享的优势，因为共享对象位于单个计算机上（为了简单起见，我们假设如此）。由于进程可能发生冲突，各种锁机制（互斥锁）有助于确保访问共享内存时的互斥。这种方案缺乏可扩展性，因为处理器数量的增加会几何地增加共享内存上的流量，并且单台计算机最多只能有 8 个处理器。

在消息传递模型中，没有全局地址空间的意义。每个进程都有一个私有的本地内存。进程可以通过传递消息相互通信。与共享地址空间不同，消息传递模型提供了处理器和内存之间的可伸缩性，尽管需要复制公共数据。处理器的增加也会成比例地增加内存（用于该数据）的大小，尽管在这种情况下不需要锁定机制。

阅读“Thinking in Java”以获得灵感，我发现只有一个关于具有同步原理的共享地址空间模型的讨论。随着我的问题变得越来越复杂，我将尝试消息传递范式，据我所知，这本书没有介绍过。

您能否推荐 Java 本机类或任何经过验证的外部库来使用消息传递模型，例如 C++ 中的 MPI？任何指向该来源的链接将不胜感激！

这是我的问题的简化版本：

1. 在我们拥有的服务器上n*m- 类型的矩阵int[][]，我们将该矩阵拆分为一组n行向量并将它们放入队列中。
2. 当队列准备好（充满向量）时，我们循环并将每个向量发送到k网络上某处的一个客户端，当且仅当客户端可以自由获取向量时（一些客户端状态以消息的形式检查-通过会很方便）。
3. 所有客户端对给定的向量执行相同的操作 - 它们计算向量的范数（长度）并将结果发送回存储它的服务器。
4. 当所有客户端都完成后，服务器会在启动初始作业的机器上打印结果。

我将在 Java 中使用Akka分布式计算框架。您能否告诉我从哪里开始学习 Akka 工具，因为我还不知道如何使用它。演员可能是那些客户..