Streaminsight-网络数据源-推送方式
我想在 StreamInsight 应用程序中实现一个输入适配器，根据给定的 ip:port 从网络获取事件（更多详细信息请参见：http://social.technet.microsoft.com/Forums/en-US/streaminsight/thread/e7bcc2c4-45b8-4225-836a-102fd3be437b）。我读到的示例都以拉式方式工作，而我的场景则需要推式方法。你知道这样的样本吗？或者您能给一些建议吗？网络编程不是我的领域，但如果我知道从哪里开始，我可以很快学习。
谢谢
I want to implement an Input Adapter in a StreamInsight app, that gets events from the network, given ip:port (more details here: http://social.technet.microsoft.com/Forums/en-US/streaminsight/thread/e7bcc2c4-45b8-4225-836a-102fd3be437b). The samples I read all work in a pull manner, whereas my scenario would require a push approach. Do you know of such a sample? Or could you give any suggestions? Network programming is not my field, but I can quickly learn, if I know where to start.
Thanks
如果你对这篇内容有疑问，欢迎到本站社区发帖提问 参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱，如果其他用户或者作者回复了您的评论，将不能在第一时间通知您！
发布评论
评论（1）
是的，您可以拥有一个输入适配器，允许通过 TCP 将数据/事件推送给它。看一下 TCPListener 类的使用。以下是 MSDN 的链接： http://msdn.microsoft .com/en-us/library/system.net.sockets.tcplistener.aspx
当在输入适配器上调用 Start() 时，您需要实例化 TCPListener 的实例并启动接受连接。在“侦听循环”中，您需要处理 NetworkStream 并反序列化传入数据，并将其转换为要排队到 StreamInsight 查询引擎中的事件。您还需要实现 Stop() 来停止接受连接。不要忘记 Dispose() 您在此过程中创建的任何资源。
希望这有帮助。
Yes, you can have an input adapter that allows data/events to be pushed to it via TCP. Take a look at using the TCPListener class. Here's the link to MSDN: http://msdn.microsoft.com/en-us/library/system.net.sockets.tcplistener.aspx
When Start() is called on your input adapter, you'll need to instantiate an instance of the TCPListener and start accepting connections. In your "listening loop", you'll need to handle the NetworkStream and deserialze the incoming data and convert it to events to be enqueued into the StreamInsight query engine. You will also need to implement Stop() to stop accepting connections. Don't forget to Dispose() any resources you've created in the process.
Hope this helps.