0

我想在 StreamInsight 应用程序中实现一个输入适配器,它从网络获取事件,给定 ip:port(更多详细信息:http: //social.technet.microsoft.com/Forums/en-US/streaminsight/thread/ e7bcc2c4-45b8-4225-836a-102fd3be437b)。我阅读的所有示例都以拉取方式工作,而我的场景需要推入方式。你知道这样的样本吗?或者你能给点建议吗?网络编程不是我的领域,但如果我知道从哪里开始,我可以快速学习。

谢谢

4

1 回答 1

0

是的,您可以拥有一个允许通过 TCP 将数据/事件推送到它的输入适配器。看看使用 TCPListener 类。这是 MSDN 的链接:http: //msdn.microsoft.com/en-us/library/system.net.sockets.tcplistener.aspx

在输入适配器上调用 Start() 时,您需要实例化 TCPListener 的实例并开始接受连接。在您的“侦听循环”中,您需要处理 NetworkStream 并反序列化传入数据并将其转换为要排入 StreamInsight 查询引擎的事件。您还需要实现 Stop() 以停止接受连接。不要忘记 Dispose() 您在此过程中创建的任何资源。

希望这可以帮助。

于 2011-10-14T22:33:59.557 回答