Entwerfen einer asynchronen Taskbibliothek für ASP.NET

Question

Die ASP.NET-Laufzeit ist für kurze Arbeitsauslastungen vorgesehen, die parallel ausgeführt werden können. Ich muss in der Lage sein, periodische Ereignisse und Hintergrundaufgaben zu planen, die möglicherweise für viel längere Zeit ausgeführt werden.

die oben angegeben Ich habe folgende Probleme zu bewältigen:

• Die AppDomain kann aufgrund von Änderungen shutdown (Web.config, sind, App_Code, etc.)
• IIS recycelt die AppPool auf einem regelmäßig (täglich)
• IIS selbst neu starten könnte, oder was das betrifft könnte der Server

abstürzen ich bin nicht davon überzeugt, dass dieser Code in ASP.NET ausgeführt wird, nicht das richtige zu tun, becuase es würde ein einfacheres Programmiermodell ermöglichen. Dies erfordert jedoch, dass ein externer Dienst regelmäßig Anfragen an die App sendet, damit die Anwendung ausgeführt wird und alle Hintergrundaufgaben mit äußerster Sorgfalt programmiert werden. Sie müssen im Falle eines unerwarteten Fehlers ihre Arbeit unterbrechen und fortsetzen können.

Meine heutige Linie des Denkens geht ungefähr so:

Wenn alle Jobs in der Datenbank registriert sind, sollte es möglich sein, die Datenbank als Buchhaltung Mechanismus zu verwenden. Im Falle eines Fehlers würde die Datenbank alle Zustände enthalten, die notwendig sind, um die Operation bei der nächsten gegebenen Gelegenheit fortzusetzen.

Ich würde wirklich einige Rückmeldungen/Ratschläge in dieser Angelegenheit applaudieren. Ich habe darüber nachgedacht, einen Windows-Dienst zu betreiben und auch eine RPC-Lösung zu verwenden, aber das hat nicht den gleichen Reiz für mich. Stattdessen hätte ich viele Probleme bei der Bereitstellung und die Synchronisierung von Aufgaben und Code durch mehrere Anwendungen. Aufgrund meiner geschäftlichen Bedürfnisse ist dies weniger als optimistisch.

Answer 1

Dies ist ein Schuss in die Dunkelheit, da ich nicht weiß, welche Datenbank Sie verwenden, aber ich würde Ihnen empfehlen, dialog timers und activation zu betrachten. Angenommen, dass die meisten der Jobs haben einige Datenmanipulation zu tun, und ist wahrscheinlich, dass nur Datenmanipulation, Aktivierung und Timer geben eine äußerst zuverlässige Job Scheduling-Lösung, vollständig in die Datenbank eingebettet (Nr Notwendigkeit für einen externen Prozess/Service, keine Abhängigkeiten außerhalb der Datenbank Grenzen wie msdb), und ist eine Lösung, die gewährleistet, dass geplante Aufträge können Neustarts, Failover-Ereignisse und sogar Wiederherstellungen Disaster Recovery überleben. Einfach ausgedrückt: Sobald ein Job geplant ist, wird er ausgeführt, selbst wenn die Datenbank eine Woche später auf einem anderen Computer wiederhergestellt wird.

Werfen Sie einen Blick auf Asynchronous procedure execution für ein verwandtes Beispiel.

Und wenn das zu radikal ist, sehen Sie sich zumindest Using Tables as Queues an, da das Speichern der geplanten Elemente in der Datenbank oft unter den Fall "ausstehende Warteschlange" fällt.

Answer 2

Ich empfehle, dass Sie sich Quartz.Net anschauen. Es ist Open Source und es wird Ihnen einige Ideen geben.

Answer 3

Ich sage dir, was ich habe. Ich habe eine Klasse namens Atzenta, die einen Timer (1-2 Sekunden Trigger) haben. Ich habe auch eine Tabelle in meiner temporären Datenbank erstellt, die die Jobs behalten. Die Tabelle kennt die JobID, andere Parameter, Priorität, Jobstatus, Nachrichten.

Ich kann einen Job in dieser Klasse hinzufügen oder löschen. Wenn keine Aktion ausgeführt werden kann, ist der Timer gestoppt. Wenn ich einen Job hinzufüge, startet der Timer erneut. (Der Timer ist ein Thread von ihm selbst, der parallel arbeiten kann). Ich benutze das System.Timers and not other timers for this.

Die Jobs können unterschiedliche Priorität haben.

Jetzt sagen, dass ich einen Job auf diesem Tisch mit der Atzenta Klasse platzieren. Wenn der Timer das nächste Mal ausgelöst wird, überprüfen Sie die Abfrage in dieser Tabelle und suchen Sie den ersten verfügbaren Job, und führen Sie ihn einfach aus. Keine anderen Jobs laufen, bis dieser beendet ist.

Alle Synchronisierungen und Flags erfolgen aus der Tabelle. In der Tabelle habe ich Flags für jeden Job, der anzeigt, ob | er darauf wartet, dass er | ausgeführt wird | run | pause | finish |

Alle Jobs sind alle bekannte Funktionen oder Klassen (zB die Erstellung von Statistiken).

Zum Stoppen und Starten verwende ich global.asax und Application_Start, Application_End, um das Objekt zu starten und zu pausieren, das die Aufgaben behält. Zum Beispiel, wenn ich einen Job mache, und ich bekomme den Application_End Ether Ich warte, um zu beenden und dann die App zu stoppen, Ether Ich stoppe die Aktion, benachrichtigen Sie die Tabelle und starten Sie erneut auf Application_start.

Also sage ich, Atzenta.RunTheJob (Jobs.StatisticUpdate, ProductID); und dann füge ich diesen Job in die Tabelle ein, öffne den Timer, und dann wird dieser Job ausgeführt und ich aktualisiere die Statistiken für die angegebene Produkt-ID.

Ich benutze eine Tabelle in einer Datenbank, um viele Pools zu synchronisieren, die die gleiche Web-App ausführen, und tatsächlich funktioniert es so. Mit einer gemeinsamen Tabelle ist die Synchronisierung der Jobs einfach und Sie vermeiden, dass zwei Pools denselben Job zur gleichen Zeit ausführen.

In meinem Backoffice habe ich eine einfache Tabellenansicht, um den Status aller Jobs zu sehen.

Answer 4

Die Verwendung der Datenbank als Zustandsmechanismus ist eine vollkommen gültige Idee. Wie komplex es sein wird, hängt davon ab, wie weit Sie es nehmen wollen. In vielen Fällen werden Sie Ihre Datenbanklogik mit einem Windows-Dienst verknüpfen, um das gewünschte Ergebnis zu erzielen.

FWIW, es ist in der Regel keine gute Praxis, den Thread-Pool innerhalb einer ASP.Net-Anwendung manuell zu verwenden, obwohl es (im Gegensatz zu dem, was Sie lesen) eigentlich ganz anders als die große Einschränkung funktioniert, die Sie nicht können garantie es wird funktionieren.

Wenn Sie also einen Hintergrund-Thread benötigen, der alle 30 Sekunden den Status eines Objekts überprüft und es nicht interessiert, ob er alle 30 Sekunden oder 29 Sekunden oder 2 Minuten ausgelöst hat (z. B. in einem langen App-Pool-Recycling), Ein von ASP.Net erstellter Thread ist eine schnelle und sehr schmutzige Lösung.

Asynchron ausgelöst Callbacks (wie auf dem ASP.Net Cache-Objekt) können auch eine Art "hinter den Kulissen" Rolle ausführen.

Ich hatte ähnliche Herausforderungen und entschied mich letztendlich für einen Windows-Dienst, der eine Kombination von Bausteinen für maximale Flexibilität verwendet.Das heißt, ich benutze:

1) WCF mit umsetzungs bestimmte Arten oder

2) Typen, die gemeint sind, zu transportieren und Objekte, die einen Job wickeln ODER

3) vollständig generisch, serialisierbare Objekte enthalten in einem benutzerdefinierten Wrapper. Da sie nur eine binäre Nutzlast sind, können alle Objekte an den Dienst übergeben werden. Sobald der Wrapper im Dienst ist, definiert er, was mit dem Objekt geschehen soll (z. B. eine Methode aufrufen, ein Ergebnis sammeln und optional das Ergebnis für eine Rückkehr verfügbar machen).

Letztendlich ist die Website verantwortlich für die Abfrage des Dienstes über seinen Zustand. Diese Abfrage kann so einfach sein wie das Abfragen oder kann asynchrone Rückrufe mit WCF verwenden (obwohl ich glaube, dass dies auch eine Art von Polling hinter den Kulissen verwendet).