动态接收输入文件并让我的 mule 应用程序处于监听状态
receiving an input file dynamically and put my mule application in listening
场景：
- 应用程序想要向设备列表发送推送。
- 所以她将信息发送到我的 mule 应用程序，它必须监听到达的信息。
- 我的应用程序将通过 Web 服务将此信息发送到将发送推送的应用程序，然后我的应用程序将等待响应，该响应是一个 json 文件，内容为：成功：0/1 失败：0/1，
- 根据这个答案，如果相关设备没有收到推送，我的 mule 应用程序将发送我从数据库中获取的电子邮件。
我已经完成了这个场景的最后一部分。从收到推送的答案。现在我对第一部分有一些疑问：
- 我猜应用程序发送了一个 json 文件，其中包含每个设备的信息列表。
如何处理信息设备列表。我必须循环 json 文件的内容。这有什么例子吗？
- 如何让我的应用程序监听到达请求以发送推送？
http 连接器是否足够？如果是如何配置路径变量。
我正在使用 mule 3.5.0 CE，在此先感谢您。
让我们将其分解为各个组件：
Sender Application - 这是需要与设备通信的服务。
设备控制器 - 这是与硬件设备对话的应用程序。
Proxy - 这就是您在 Mule ESB 上开发的内容。它将连接到 Sender Application 和 Device Controller 并将请求从 Sender 传输到 Controller；然后将结果从 Controller 发送回 Sender。
流程看起来像这样：
- 发件人应用程序需要与设备通信。
- 发件人应用程序使用JSON传输信息。
- 代理收到此 JSON 请求。
- 代理然后通过 HTTP 联系设备控制器。
- 设备控制器仅与代理对话，returns结果为 0 或 1，具体取决于物理设备的结果。
- 代理随后需要将此结果传达给发送方应用程序。
起初，您可能会考虑通过 HTTP 开发代理（使用 HTTP Connector）。此连接器创建一个可以侦听和响应请求的 Web 服务端点（基本上是一个网站）。
发件人应用程序通过 HTTP 连接到此端点并提交包含要执行的命令的 JSON 文档。
然后您的代理立即联系设备控制器（同样，使用相同的连接器通过 HTTP）。
设备控制器与设备对话，然后returns响应您的代理（通过 HTTP）。
您获取此响应，然后将其作为对原始 HTTP 请求（来自发件人应用程序）的响应发回。
这里的问题是，如果您的连接与设备控制器（或设备控制器与物理设备）之间存在任何延迟，连接将在两侧保持阻塞状态（因为您需要发送响应）。
如果延迟很大，您的代理和发件人应用程序之间的 HTTP 连接可能会终止。
当某些站点过载并且没有响应时也是如此 - 浏览器最终会超时。
为避免这种情况，请将您的集成分成三个独立的流程。
第一个流程将创建一个正常的 HTTP 连接，发件人应用程序将向其上传 JSON 文档。它将获取 JSON 文档并使用 batch module 将每个条目转换为消息（注意：这仅适用于企业版 - 对于 CE 版本，您必须自己编写此逻辑） .接下来，获取此消息并将它们放入单独的队列中。 Return 此消息的唯一 ID，作为对发件人应用程序的 JSON 响应。
您的第二个流正在侦听此队列，每当消息到达时，它都会连接到设备控制器并获得响应。然后将响应写入另一个队列。
您的第三个也是最后一个流侦听此结果队列，获取此队列中的每条消息并将其转换为 JSON/XML。然后它有一个 HTTP 连接器，可以在其中查询每个命令的结果。
在上面的设置中，您的发送方应用程序可以放置一个大的 JSON 文件来执行命令；对于每个命令，一个唯一的 ID 将返回给发送方应用程序。
然后它将查询结果端点（您的最后一个流公开的内容）并将消息 ID 发送给它。结果端点随后将检查此请求的状态并使用适当的代码进行响应。
这是一个如何工作的示例（从发件人应用程序的角度来看）：
I 是您流程的输入，O 是发送的结果。
第 1 步 - 发送要执行的命令的请求：
I: Sender Application > http://localhost:8080/input-commands?device=1&command=Y
O: <command><req-status>OK</req-status><id>1234-123</id></command>
第 2 步 - 查询结果：
I: Sender Application > http://localhost:8080/result?id=1234-123
O: <command><id>1234-123</id><result>0</result></command>
场景： - 应用程序想要向设备列表发送推送。 - 所以她将信息发送到我的 mule 应用程序，它必须监听到达的信息。 - 我的应用程序将通过 Web 服务将此信息发送到将发送推送的应用程序，然后我的应用程序将等待响应，该响应是一个 json 文件，内容为：成功：0/1 失败：0/1， - 根据这个答案，如果相关设备没有收到推送，我的 mule 应用程序将发送我从数据库中获取的电子邮件。
我已经完成了这个场景的最后一部分。从收到推送的答案。现在我对第一部分有一些疑问：
- 我猜应用程序发送了一个 json 文件，其中包含每个设备的信息列表。 如何处理信息设备列表。我必须循环 json 文件的内容。这有什么例子吗？
- 如何让我的应用程序监听到达请求以发送推送？ http 连接器是否足够？如果是如何配置路径变量。
我正在使用 mule 3.5.0 CE，在此先感谢您。
让我们将其分解为各个组件：
Sender Application - 这是需要与设备通信的服务。
设备控制器 - 这是与硬件设备对话的应用程序。
Proxy - 这就是您在 Mule ESB 上开发的内容。它将连接到 Sender Application 和 Device Controller 并将请求从 Sender 传输到 Controller；然后将结果从 Controller 发送回 Sender。
流程看起来像这样：
- 发件人应用程序需要与设备通信。
- 发件人应用程序使用JSON传输信息。
- 代理收到此 JSON 请求。
- 代理然后通过 HTTP 联系设备控制器。
- 设备控制器仅与代理对话，returns结果为 0 或 1，具体取决于物理设备的结果。
- 代理随后需要将此结果传达给发送方应用程序。
起初，您可能会考虑通过 HTTP 开发代理（使用 HTTP Connector）。此连接器创建一个可以侦听和响应请求的 Web 服务端点（基本上是一个网站）。
发件人应用程序通过 HTTP 连接到此端点并提交包含要执行的命令的 JSON 文档。
然后您的代理立即联系设备控制器（同样，使用相同的连接器通过 HTTP）。
设备控制器与设备对话，然后returns响应您的代理（通过 HTTP）。
您获取此响应，然后将其作为对原始 HTTP 请求（来自发件人应用程序）的响应发回。
这里的问题是，如果您的连接与设备控制器（或设备控制器与物理设备）之间存在任何延迟，连接将在两侧保持阻塞状态（因为您需要发送响应）。
如果延迟很大，您的代理和发件人应用程序之间的 HTTP 连接可能会终止。
当某些站点过载并且没有响应时也是如此 - 浏览器最终会超时。
为避免这种情况，请将您的集成分成三个独立的流程。
第一个流程将创建一个正常的 HTTP 连接，发件人应用程序将向其上传 JSON 文档。它将获取 JSON 文档并使用 batch module 将每个条目转换为消息（注意：这仅适用于企业版 - 对于 CE 版本，您必须自己编写此逻辑） .接下来，获取此消息并将它们放入单独的队列中。 Return 此消息的唯一 ID，作为对发件人应用程序的 JSON 响应。
您的第二个流正在侦听此队列，每当消息到达时，它都会连接到设备控制器并获得响应。然后将响应写入另一个队列。
您的第三个也是最后一个流侦听此结果队列，获取此队列中的每条消息并将其转换为 JSON/XML。然后它有一个 HTTP 连接器，可以在其中查询每个命令的结果。
在上面的设置中，您的发送方应用程序可以放置一个大的 JSON 文件来执行命令；对于每个命令，一个唯一的 ID 将返回给发送方应用程序。
然后它将查询结果端点（您的最后一个流公开的内容）并将消息 ID 发送给它。结果端点随后将检查此请求的状态并使用适当的代码进行响应。
这是一个如何工作的示例（从发件人应用程序的角度来看）：
I 是您流程的输入，O 是发送的结果。
第 1 步 - 发送要执行的命令的请求：
I: Sender Application > http://localhost:8080/input-commands?device=1&command=Y
O: <command><req-status>OK</req-status><id>1234-123</id></command>
第 2 步 - 查询结果：
I: Sender Application > http://localhost:8080/result?id=1234-123
O: <command><id>1234-123</id><result>0</result></command>