Publicar en el servidor de StreamInsight y conectarse a él

Artículo
07/28/2011

En una aplicación de StreamInsight, puede elegir si incrusta el servidor de StreamInsight en el proceso o si se conecta a un servidor remoto. En ambos casos, utiliza un objeto de servidor para desarrollar las consultas de StreamInsight. Para conectar a una instancia remota, debe hospedar el servidor de StreamInsight y exponer la interfaz de capacidad de administración del servicio web.

Conectar a un servidor

Cuando se hospeda en el proceso, el servidor de StreamInsight se crea a través de la siguiente llamada:

    Server server = Server.Create(…);

La aplicación de StreamInsight también se puede conectar a un servidor existente que se ejecuta como un proceso independiente. En el siguiente ejemplo, una aplicación cliente se conecta a un servidor identificado por una dirección de extremo específica.

    Server server = Server.Connect(new System.ServiceModel.EndpointAddress(@"https://localhost/StreamInsight/MyInstance"));

En este ejemplo se conecta a un servicio StreamInsight instalado con el nombre de instancia "MyInstance". Observe que para conectar con cualquier servidor StreamInsight (un servicio instalado o su aplicación de servidor personalizada), el usuario que se conecta debe estar en el grupo que corresponde a la instancia del servidor. Para obtener más información acerca de este grupo y el servicio StreamInsight, vea Instalación (StreamInsight).

Exponer el extremo del servidor

Para que el método Connect() se ejecute correctamente, el servidor debe exponer su interfaz de capacidad de administración a través de un extremo de servicio web en el identificador uniforme de recursos (URI) determinado. Por ejemplo, el depurador de flujo de eventos de StreamInsight es una aplicación cliente que, cuando se conecta a un extremo de un servidor activo, puede recuperar información de diagnóstico sobre las consultas y otros objetos en el nivel de servidor o grabar eventos de una consulta en ejecución para su depuración detallada.

Una aplicación puede exponer la interfaz de capacidad de administración de un servidor de StreamInsight hospedado agregando un extremo de servicio web, tal como se muestra en el siguiente ejemplo. En el ejemplo se supone que existe una instancia de StreamInsight registrada con el nombre "MyInstance".

    Server server = Server.Create("MyInstance");
    ServiceHost host = new ServiceHost(server.CreateManagementService());
    host.AddServiceEndpoint(typeof(IManagementService),
                            new WSHttpBinding(SecurityMode.Message),
                            "https://localhost:8090/MyStreamInsightServer");
    host.Open();
    ...
    host.Close;

Observe que debe agregar una referencia a Microsoft.ComplexEventProcessing.ManagementService.dll y especificar el espacio de nombres correspondiente para usar Management Service.

StreamInsight usa Windows Communication Foundation (WCF) para su interfaz de servicio web. Una descripción completa de la configuración de WCF está más allá del ámbito de esta documentación, pero debe tener en cuenta los siguientes puntos cuando vaya a exponer el servicio web:

El enlace con la URL especificada exige que sea una URL reservada para la cuenta del usuario que ejecuta la aplicación. Si la aplicación StreamInsight no se ejecuta bajo los derechos de administrador, el siguiente comando se debe ejecutar en un shell de comando elevado:
```
netsh http add urlacl url=http://+:8090/MyStreamInsightServer user=<domain\userid>
```
La reserva de URL a través de netsh siempre exige proporcionar un nombre de puerto. Elija un puerto que aún no se haya usado. Use el siguiente comando para mostrar las URL actualmente reservadas.
```
netsh http show urlacl
```
Observe que el uso de caracteres comodín de la reserva de direcciones URL afecta al parámetro HostNameComparisonMode del enlace. El modo de coincidencia predeterminado de un enlace es StrongWildcard. Por ejemplo, si desea habilitar el nombre de host coincidente exacto (usando "localhost" en la especificación del extremo del servidor y solo permitiendo clientes locales), debe establecer primero el modo de coincidencia correspondiente:
```
WSHttpBinding binding = new WSHttpBinding(SecurityMode.Message);
binding.HostNameComparisonMode = HostNameComparisonMode.Exact;
host.AddServiceEndpoint(typeof(IManagementService),
        binding,
        "https://localhost:8090/MyStreamInsightServer");
```
Como cualquier otra propiedad de WCF, esta también se puede especificar en el archivo app.config.

A continuación, también debe reservar el ámbito de la dirección URL correspondiente usando el comando netsh:
```
netsh http add urlacl url=https://localhost:8090/MyStreamInsightServer user=<domain\userid>
```
En el ejemplo anterior, la configuración del extremo se especifica mediante programación. Como alternativa, el extremo se puede configurar a través de un archivo app.config como cualquier otra aplicación basada en WCF. El servicio StreamInsight instalado, por ejemplo, usa este tipo de configuración para cada instancia registrada. El archivo de configuración se puede encontrar en la carpeta de instalación de StreamInsight bajo Host\<instance_name> con el nombre StreamInsightHost.exe.config.
En Windows XP y Windows Server 2003, netsh no está disponible. En su lugar, debe instalar las herramientas de soporte de Windows Server 2003 y usar el comando httpcfg desde la "<unidad>:Archivos de programa\Support Tools" para reservar las direcciones URL. Por ejemplo, el comando para reservar una URL de carácter comodín para la cuenta del servicio de red, es:
```
httpcfg set urlacl /u http://+:80/StreamInsight/MyStreamInsightServer /a "D:(A;;GX;;;NS)"
```

Al exponer el servicio web para conexiones por la red, considere la siguiente información específica.

El servicio de StreamInsight instalado solo permite conexiones locales de forma predeterminada. Cuando deba exponer el servicio web del servicio instalado en máquinas que no sean el host local, debe seguir los pasos descritos anteriormente para:
1. Cambiar la reserva de dirección URL para el servicio de "localhost" explícito al carácter comodín "+".
2. Cambiar el nombre del host coincidente del archivo app.config del servicio a StrongWildcard.
Al habilitar conexiones remotas, se debe abrir el puerto especificado en el firewall del servidor.
Al conectar un cliente a una instancia del servidor remoto en la red usando el nombre de equipo, se usa Kerberos para autenticar en lugar de NTLM al usar la dirección IP. Es decir, el cliente necesita establecer una identidad de nombre principal del usuario (UPN) para el extremo antes de conectar:
```
EndpointIdentity ei = EndpointIdentity.CreateUpnIdentity(WindowsIdentity.GetCurrent().Name);
EndpointAddress ea = new EndpointAddress(new Uri(@"http://machinename:8090/MyStreamInsightServer"), ei, (AddressHeaderCollection)null);
server = Server.Connect(ea);
```

Consulte la documentación de WCF para ver obtener detalles adicionales sobre cómo especificar los extremos.

Vea también

Conceptos

Supervisar el servidor y las consultas de StreamInsight

Usar el Depurador de flujo de eventos de StreamInsight

Ejemplo integral de StreamInsight

Historial de cambios

Contenido actualizado
Se han corregido los ejemplos de código y se ha agregado la nueva información en la sección "Exponer el extremo del servidor”.

Compartir a través de