7
Tengo una aplicación que usa MSMQ para el procesamiento asincrónico de ciertas cosas.Forma correcta de alojar un * stable * Servicio de ventanas WCF MSMQ
Puedo utilizar WCF para colocar mensajes en la cola y tienen un oyente WCF MSMQ (un servicio de Windows) para recibir mensajes y tratar con ellos.
Mi problema es mantener esto estable. ¿Cuál es la forma correcta de tratar (por ejemplo) el servidor de cola (que es un cuadro separado) que baja? El otro día sucedió esto y el servicio solo se sentó allí; no se lanzaron excepciones, solo dejó de recibir mensajes. Me gustaría arrojar una excepción cuando el servidor de cola se cayó y luego volver a intentar conectarlo hasta que pueda.
También he notado que la ejecución de una "parada" en el servicio a menudo hace que se cuelgue durante bastante tiempo antes de que finalmente se detiene.
Cualquier código o sugiere crítica sería bienvenido. Obviamente, primero hice Google para esto, pero la mayoría de los ejemplos me muestran más o menos lo que ya tengo y me gustaría que mi sistema sea más sólido que eso.
Actualmente tengo esto:
(Nota: IMyExampleServiceContract es mi contrato de servicio WCF y QueueHandler es lo que lo implementa)
namespace xyz.MyExample.MSMQListener
{
/// <summary>
/// The class that handles starting and stopping of the WCF MSMQ Listener windows service.
/// It will respond to start and stop commands from within the windows services administration snap-in
/// It creates a WCF NetMsmqBinding that watches a particular queue for messaages defined by a contract
/// in the ServiceContracts project.
/// </summary>
public partial class MsmqListenerService : ServiceBase
{
/// <summary>
/// The WCF service host
/// </summary>
private ServiceHost _serviceHost;
/// <summary>
/// Defines the maximum size for a WCF message
/// </summary>
private const long MaxMessageSize = 1024 * 1024 * 1024; // 1 gb
/// <summary>
/// Defines the maximum size for a WCF array
/// </summary>
private const int MaxArraySize = 1024 * 1024 * 1024; // 1 gb
/// <summary>
/// The queue name
/// </summary>
private readonly string _queueName;
/// <summary>
/// The queue server
/// </summary>
private readonly string _queueServer;
/// <summary>
/// Initializes a new instance of the <see cref="MsmqListenerService"/> class.
/// </summary>
public MsmqListenerService()
{
InitializeComponent();
using (ConfigManager config = new ConfigManager())
{
_queueName = config.GetAppSetting("QueueName");
_queueServer = config.GetAppSetting("QueueServer");
}
}
/// <summary>
/// When implemented in a derived class, executes when a Start command is sent to the service by the Service Control Manager (SCM) or when the operating system starts (for a service that starts automatically). Specifies actions to take when the service starts.
/// <para>
/// The logic in this method creates a WCF service host (i.e. something that listens for messages) using the <see cref="IMyExampleServiceContract"/> contract.
/// The WCF end point is a NetMSMQBinding to the MyExample MSMQ server/queue.
/// It sets up this end point and provides a class to handle the messages received on it.
/// The NetMSMQBinding is a Microsoft WCF binding that handles serialisation of data to MSMQ. It is a ms proprietary format and means that the message on the queue
/// can only be read by a WCF service with the correct contract information.
/// </para>
/// </summary>
/// <param name="args">Data passed by the start command.</param>
protected override void OnStart(string[] args)
{
try
{
Logger.Write("MyExample MSMQ listener service started.", StandardCategories.Information);
Uri serviceUri = new Uri("net.msmq://" + QueueServer + QueueName);
NetMsmqBinding serviceBinding = new NetMsmqBinding();
serviceBinding.Security.Transport.MsmqAuthenticationMode = MsmqAuthenticationMode.None;
serviceBinding.Security.Transport.MsmqProtectionLevel = System.Net.Security.ProtectionLevel.None;
serviceBinding.MaxReceivedMessageSize = MaxMessageSize;
serviceBinding.ReaderQuotas.MaxArrayLength = MaxArraySize;
//QueueHandler implements IMyExampleServiceContract
_serviceHost = new ServiceHost(typeof(QueueHandler));
_serviceHost.AddServiceEndpoint(typeof(IMyExampleServiceContract), serviceBinding, serviceUri);
_serviceHost.Open();
Logger.Write("MyExample MSMQ listener service completed OnStart method.", StandardCategories.Information);
}
catch (Exception ex)
{
ExceptionReporting.ReportException(ex, "DefaultExceptionPolicy");
throw;
}
}
/// <summary>
/// Gets the name of the queue to send to.
/// This is retrieved from the application settings under QueueName
/// </summary>
private string QueueName
{
get { return _queueName; }
}
/// <summary>
/// Gets the name of the queue server to send to.
/// This is retrieved from the application settings under QueueServer
/// </summary>
private string QueueServer
{
get { return _queueServer; }
}
/// <summary>
/// When implemented in a derived class, executes when a Stop command is sent to the service by the Service Control Manager (SCM). Specifies actions to take when a service stops running.
/// </summary>
protected override void OnStop()
{
if (_serviceHost != null)
{
_serviceHost.Close();
_serviceHost = null;
}
}
/// <summary>
/// The main entry point for the application.
/// </summary>
public static void Main()
{
//Code will have to be compiled in release mode to be installed as a windows service
#if (!DEBUG)
try
{
Logger.Write("Attempting to start queue listener service.", StandardCategories.Information);
ServiceBase[] ServicesToRun;
ServicesToRun = new ServiceBase[]
{
new MsmqListenerService()
};
ServiceBase.Run(ServicesToRun);
Logger.Write("Finished ServiceBase.Run of queue listener service.", StandardCategories.Information);
}
catch (Exception e)
{
ExceptionReporting.ReportException(e, "DefaultExceptionPolicy");
throw;
}
#else
//This allows us to run from within visual studio
MsmqListenerService service = new MsmqListenerService();
service.OnStart(null);
System.Threading.Thread.Sleep(System.Threading.Timeout.Infinite);
#endif
}
}
}
El evento de fallo se ve muy bien. Supongo que crees que no entrará en este estado si falla el servidor MSMQ. (Como se está recomendando el servicio "ping") El servicio "ping" suena como una buena solución temporal para comprobar la disponibilidad de servidores, sólo pensé que no habría habido algo integrado en WCF que lidiar con esto por mí. De todos modos, voy a dar el caso Faulted una oportunidad, así que gracias por dirigirme en su dirección. – David
Para ser honesto, no sé a ciencia cierta, por lo tanto porqué recomendé ambas opciones :) – tomasr