streaminsight - сетевой источник данных - способ push

Question

Я хочу реализовать Адаптер ввода в приложении StreamInsight, которое получает события из сети, учитывая ip: порт (подробности здесь: http://social.technet.microsoft.com/Forums/en-US/streaminsight/thread/e7bcc2c4-45b8-4225-836a-102fd3be437b). Все примеры, которые я читаю, работают по запросу, тогда как мой Сценарий потребует настойчивого подхода. Знаете ли вы о таком образце? Или могли бы вы дать какие-либо предложения? Сетевое программирование - это не моя область, но я могу быстро научиться, если знаю, с чего начать.

Спасибо

Answer 1

Да, у вас может быть входной адаптер, который позволяет передавать данные / события через TCP. Взгляните на использование класса TCPListener. Вот ссылка на MSDN: http://msdn.microsoft.com/en-us/library/system.net.sockets.tcplistener.aspx

Когда Start () вызывается на вашем адаптере ввода, вам нужно создать экземпляр экземпляра TCPListener и начать принимать соединения. В вашем «цикле прослушивания» вам необходимо обработать NetworkStream и десериализовать входящие данные и преобразовать их в события, которые будут помещены в очередь в механизм запросов StreamInsight. Вам также нужно будет реализовать Stop (), чтобы прекратить принимать соединения. Не забудьте удалить () любые ресурсы, которые вы создали в процессе.

Надеюсь, это поможет.