2

我正在通过 TCP/IP 实现 JSON RPC 连接，但我遇到了一个基本问题。目前我正在使用同步方法，效果很好。

我能发送

{"id":1,"jsonrpc":"2.0","method":"Input.Home"}

并收到

{"id":1,"jsonrpc":"2.0","result":true}

这没有问题。当我收到通知时会出现问题。这些可能会在任何时候出人意料地到达。我正在与 XBMC JSON RPC API 交互。如果 XBMC 已发送通知，我会同时收到多个 JSON 请求。例如

{"jsonrpc":"2.0","method":"GUI.OnScreensaverActivated","params":{"data":null,"sender":"xbmc"}}{"jsonrpc":"2.0","method":"GUI.OnScreensaverDeactivated","params":{"data":null,"sender":"xbmc"}}

这会导致 JSON.NET 崩溃，这是可以理解的。我的第一直觉是我需要异步接收这些通知，这样我就不必等到调用下一个方法来接收它们。然而，这使我上面展示的简单示例变得复杂，因为我不能再使用同步调用。IE

SendJson(json);
result = ReceiveJson();

有没有一种干净的方法来实现它而不会使它过于复杂？任何/所有建议表示赞赏。

4

1 回答 1

2

这里是所有阅读的地方。如果你想进入它，这一切都是值得的。 http://msdn.microsoft.com/en-us/library/ms228969.aspx

不过总结一下..

基本上需要发生的是您需要创建一个实现 IAsyncResult 的对象。这将存储有关您的异步操作的状态，以及完成时的回调。

创建一个可以将您的 IAsyncResult 对象作为输入的方法，并且在该方法返回之前，它应该在您的 IAsyncResult 对象上调用 .SetCompleted()。在这种方法中，您可以完成通常所做的工作。

然后，您将创建 IAsyncResult 对象的实例（设置其数据和回调），然后调用 Task.Factory.StartNew([YourNewMethod],[YourInstanceOf IAsyncResult])。

这是需要发生的事情的核心。只要确保设置你的回调并处理异常。

如果您想要一个关于我如何使用异步 http 处理程序来执行 json-rpc 的工作示例，请查看http://jsonrpc2.codeplex.com/SourceControl/changeset/view/13061#74311以及调用 Process 的位置并且正在设置异步对象http://jsonrpc2.codeplex.com/SourceControl/changeset/view/13061#61720

希望有帮助。

于 2012-05-03T23:37:18.890 回答