RabbitMQ Verbraucher als windows-Dienst

Ich habe einen rabbitmq-consumer-Anwendung implementieren "publish/subscribe-pattern .net, das läuft perfekt, wie eine Konsole-Anwendung, aber wenn ich bereitstellen, die als windows-Dienst scheint es nicht zu sein, die Speicherung der Daten in mongodb.

    protected override void OnStart(string[] args)
    {
        try
        {
             var connectionString = "mongodb://localhost";
            var client = new MongoClient(connectionString);
            var factory = new ConnectionFactory() { HostName = "localhost" };            
            using (var connection = factory.CreateConnection())
            {
                using (var channel = connection.CreateModel())
                {
                    channel.ExchangeDeclare(exchange: "test", type: "fanout");
                    var queueName = channel.QueueDeclare().QueueName;
                    channel.QueueBind(queue: queueName,                                       exchange: "logs", routingKey: "");

                    var consumer = new EventingBasicConsumer(channel);
                    consumer.Received += (model, ea) =>
                    {
                        var body = ea.Body;
                        var message = Encoding.UTF8.GetString(body);
                        BsonDocument document = BsonDocument.Parse(message);
                        var database = client.GetDatabase("test");
                        var collection = database.GetCollection<BsonDocument>("test_collection");
                        collection.InsertOneAsync(document);
                    };
                    channel.BasicConsume(queue: queueName,                                       noAck: true,consumer: consumer);

                }
            }
        }
        catch (Exception ex)
        {
            throw;
        }
    }

Gibt es etwas, was ich bin fehlt?

  • Haben Sie die Protokolle?
  • Sie werden nicht warten, für das Ergebnis der InsertOneAsync... was könnte passiert sein und du wirst nie wissen... mit Auflistung.InsertOneAsync(Dokument).GetAwaiter().GetResult();
  • Ich habe versucht, die Protokollierung zu sehen, ob die Nachricht tatsächlich empfangen wird. Ist aber nicht so Aussehen mag.
  • Es schadet auch nicht, alle Meldungen dump in mongoDB zu beginnen. Auch, um zu überprüfen, überprüfte ich die logs von mongoDB. Es gibt keine Daten, die gedumpt ist, um von diesem service
InformationsquelleAutor sandy | 2015-11-13
  1. 11

    Es ist eine schlechte Idee, ein busy wait in OnStart (), da das Betriebssystem erwarten eine Rückkehr von ihm. Lesen Sie hier: https://msdn.microsoft.com/en-us/library/zt39148a%28v=vs.110%29.aspx

    Edit: Das problem mit den obigen code ist, dass Sie Ihre Verbindung und Kanal in der using-Anweisungen. Der springende Punkt, das zu tun, zu Entsorgen, sobald die out-of-scope. Also in diesem Fall, obwohl Sie das hinzufügen eines event-handler, du bist kurz nach dem verlassen aus dem Umfang und der Entsorgung der Kanal, etc. Um dies zu beheben, ziehen Sie die Verbindung, den Kanal und die Verbraucher vor der "OnStart" - Methode und machen Sie Klasse (wahrscheinlich privaten) Mitgliedern. Das sollte halten, Sie zu öffnen, auch beim beenden der Methode und Ihrer Veranstaltung halten sollte Zuhören.

    InformationsquelleAutor Svet Angelov
  2. 2

    Wir müssen heute gemacht RabbitMQ Verbraucher als windows-Dienst und lösen mit Timer-Funktion in der Methode OnStart.

    private Timer _timer;

protected override void OnStart(string[] args)

{
     _timer = new Timer();
     _timer.Interval = 5000; 
     _timer.Elapsed += new ElapsedEventHandler(this.OnTimer);
     _timer.Start();
}

public void OnTimer(object sender, System.Timers.ElapsedEventArgs args)
{
     _timer.Enabled = false;

     ...
}

    Vielen Dank für die Hilfe und hoffe geholfen zu haben mit dieser Lösung zu

    InformationsquelleAutor Fabio Morcillo do Nascimento
  3. 0

    Machen Sie die folgenden änderungen an meinem Onstart-Methode hat den trick

        protected override void OnStart(string[] args)
    {

        ConnectionFactory factory = new ConnectionFactory { HostName = localhost" };
        var connectionString = "mongodb://localhost";
        var client = new MongoClient(connectionString);


        using (IConnection connection = factory.CreateConnection())
        {
            using (IModel channel = connection.CreateModel())
            {
                channel.ExchangeDeclare(exchange: "test", type: "fanout");

                string queueName = channel.QueueDeclare();

                channel.QueueBind(queueName, "test", "");

                this.EventLog.WriteEntry("Waiting for messages");

                QueueingBasicConsumer consumer = new QueueingBasicConsumer(channel);
                channel.BasicConsume(queueName, true, consumer);

                while (true)
                {
                    BasicDeliverEventArgs e = (BasicDeliverEventArgs)consumer.Queue.Dequeue();
                    var message = Encoding.UTF8.GetString(e.Body);
                    BsonDocument document = BsonDocument.Parse(message);
                    var database = client.GetDatabase("test");
                    var collection = database.GetCollection<BsonDocument>("test_collection");
                    collection.InsertOneAsync(document);

                }
            }
        }
    }
    • Wie funktioniert dieser Dienst Griff zu stoppen? I. e. wird es jemals aufhören? Wird es nicht notwendig sein, ihn zu töten, da a) es gibt keine Bedingung der while-Schleife, und b) ist der Aufruf an die Verbraucher.Warteschlange.Dequeue() nicht blockiert?
    InformationsquelleAutor sandy
Schreibe einen Kommentar