C#-Nachrichtenwarteschlangenanwendung -1

Einführung

Microsoft hat kürzlich eine neue Plattform zur Generierung integrierter Anwendungen auf den Markt gebracht – das Microsoft
.NET Framework. .NETTO Das Framework ermöglicht Entwicklern die schnelle Generierung und Bereitstellung von Webdiensten und Anwendungen in jeder Programmiersprache. Microsoft Intermediate Language (MSIL) und Echtzeit Der
(JIT)-Compiler ermöglicht dieses sprachunabhängige Framework.

Zeitgleich mit dem .NET Framework gibt es auch eine neue Programmiersprache C# (ausgesprochen „C Sharp“).

C# ist eine einfache, neuartige, objektorientierte und typsichere Programmiersprache. Nutzung von .NET Frameworks
und C# (zusätzlich zu Microsoft? Visual Basic? und Managed C++) können Benutzer
leistungsstark schreiben Microsoft Windows? und Webanwendungen und -dienste. Dieser Artikel
bietet eine solche Lösung und konzentriert sich dabei eher auf .NET Framework und C# als auf die Programmiersprache
Wörter. Eine Einführung in die Sprache C# finden Sie in „C# Introduction and Overview (English)“.

Der aktuelle Artikel „MSMQ: Eine skalierbare Lösung für den Lastausgleich mit hoher Verfügbarkeit (Englisch)“

Stellt eine Lösung für den skalierbaren Lastausgleich von Nachrichtenwarteschlangen mit hoher Verfügbarkeit (MSMQ) vor.
Lösungsarchitektur. Diese Lösung beinhaltet die Entwicklung eines Windows-Dienstes als intelligenten Nachrichtenrouter. Eine solche Lösung gab es bisher nur von Microsoft Visual C++
Programmierer können dies erreichen, und das Aufkommen des .NET Frameworks hat diese Situation geändert. Sie können dies in der Lösung
unten sehen.

.NET Framework-Anwendung

Die hier vorgestellte Lösung ist ein Windows-Dienst, der mehrere Nachrichtenwarteschlangen verwaltet;

Jede Warteschlange wird von mehreren Threads verarbeitet (Empfangen und Verarbeiten von Nachrichten). Handler macht

Routen Sie Nachrichten aus der Zielwarteschlangentabelle
mithilfe von Round-Robin-Techniken oder anwendungsspezifischen Werten (AppSpecific-Eigenschaften für Nachrichten) und verwenden Sie die Nachrichteneigenschaften, um Komponentenmethoden aufzurufen. (Der Beispielprozess fällt ebenfalls in diese Kategorie
Situation. ) Im letzteren Fall besteht die Anforderung der Komponente darin, dass sie die angegebene Schnittstelle IWeb
Message implementiert. Um Fehler zu verarbeiten, muss die Anwendung Nachrichten, die nicht verarbeitet werden können, an die Fehlerwarteschlange senden.

Die Messaging-Anwendung ist insofern ähnlich aufgebaut wie die vorherige Active Template Library (ATL)-Anwendung

Der Hauptunterschied zwischen ihnen besteht in der Kapselung des Codes, der zur Verwaltung des Dienstes verwendet wird, und in der Verwendung von .NET Framework-Komponenten

. Um einen Windows-Dienst zu erstellen, müssen .NET Framework-Benutzer lediglich einen Slave erstellen Von ServiceBase
(von der System.ServiceControl-Assembly) geerbte Klasse. Dies ist keine Überraschung, da das .NET
Framework objektorientiert ist.

Anwendungsstruktur

Die Hauptklasse in der Anwendung ist ServiceControl, die

von ServiceBase erbt. Daher muss es OnStart und OnStop implementieren -Methode und die optionalen Methoden OnPause und

OnContinue. Tatsächlich wird die Klasse innerhalb der statischen Methode Main erstellt:

using System

using System.ServicePRocess;

public class ServiceControl: ServiceBase

{

// Erstellen Sie den Haupteinstiegspunkt für das Serviceobjekt
public static void Main()
{
ServiceBase.Run(new ServiceControl());
　 }

　 // Konstruiertes Objekt, das Dienstparameter definiert

　 public ServiceControl()

　 {
CanPauseAndContinue = true;
ServiceName = "MSDNMessageService";
　AutoLog = false;
}

protected override void OnStart(string[] args) {...}

protected override void OnStop() {...}

protected override void OnPause() {...}
protected override void OnContinue() {...}
}

Die ServiceControl-Klasse erstellt eine Reihe von CWorker-Objekten, d. h. für jede

Nachrichtenwarteschlange, die verarbeitet werden muss Eine Instanz der CWorker-Klasse. Entsprechend der Anzahl der Threads, die zum Verarbeiten der Warteschlange in der Definition erforderlich sind, erstellt die CWorker-Klasse eine Reihe von Threads CWorkerThread-Objekt. Ein von der Klasse CWorkerThread

erstellter Verarbeitungsthread führt die eigentliche Servicearbeit aus.

Der Hauptzweck der Verwendung der Klassen CWorker und CWorkerThread besteht darin, die Dienststeuerelemente Start,
Stop, Pause und Continue zu bestätigen Befehl. Da diese Prozesse nicht blockierend sein dürfen, werden Befehlsoperationen

letztendlich in einem Hintergrundverarbeitungsthread ausgeführt.

CWorkerThread ist eine abstrakte Klasse, definiert durch CWorkerThreadAppSpecific,
CWorkerThreadRoundRobin und CWorkerThreadAssembly erben. Diese Kategorien sind es nicht

Verarbeiten Sie Nachrichten auf die gleiche Weise. Die ersten beiden Klassen verarbeiten Nachrichten, indem sie sie an eine andere Warteschlange senden (ihr

Unterschied liegt in der Art und Weise, wie der Pfad der Empfangswarteschlange bestimmt wird), und die letzte Klasse verwendet Nachrichtenattribute zum Aufrufen
Verwenden Sie die Komponentenmethode.

　Die Fehlerbehandlung innerhalb des .NET Frameworks basiert auf der Basisklasse Exception. Wenn das System
Fehler auslöst oder erkennt, müssen diese ihren Ursprung haben In Exception exportierte Klassen. Die Klasse CWorker

ThreadException ist eine solche Implementierung, indem zusätzliche Eigenschaften angehängt werden (die zum Definieren verwendet werden).

Ob der Dienst weiterhin ausgeführt werden soll), um die Basisklasse zu erweitern.

Schließlich enthält die Anwendung zwei Strukturen. Diese Werttypen definieren
Laufzeitparameter für Arbeitsprozesse oder Threads, um CWorker und zu vereinfachen Die Struktur des CWorkerThread-Objekts. Durch die Verwendung einer Werttyp-
-Struktur (anstelle einer Referenztypklasse) wird sichergestellt, dass diese Laufzeitparameter Werte beibehalten (anstelle von
-Referenzen).

IWebMessage-Schnittstelle

　Eine der Implementierungen von CWorkerThread ist eine Klasse, die Komponentenmethoden aufruft. Diese Klasse namens
CWorkerThreadAssembly verwendet Die IWebMessage-Schnittstelle definiert die Vereinbarung zwischen Diensten und Komponenten.

Mit der aktuellen Version von Microsoft Visual Studio? Im Gegensatz dazu können C#-Schnittstellen explizit in jeder

-Sprache definiert werden, ohne dass IDL-Dateien erstellt und kompiliert werden müssen. C# Das
der IWebMessage-Schnittstelle ist wie folgt definiert:
öffentliche Schnittstelle IWebMessage
{
WebMessageReturn Process(string sMessageLabel, string sMessage
　 Body, int iAppSpecific);
void Release();
}

Die Process-Methode im ATL-Code wird für die Verarbeitung von Nachrichten angegeben. Der Rückgabecode der Process-Methode

ist als Aufzählungstyp WebMessageReturn definiert:

public enum WebMessageReturn

{
ReturnGood,
ReturnBad,
ReturnAbort
}

Die Definition der Aufzählung lautet wie folgt: „Gut“ bedeutet, die Verarbeitung fortzusetzen, „Schlecht“ bedeutet, die Nachricht in die Fehlerwarteschlange zu schreiben, und

Abort bedeutet, die Verarbeitung zu beenden. Freigeben Methoden bieten Diensten die Möglichkeit, Klasseninstanzen einfach zu löschen.
Da der Destruktor einer Klasseninstanz nur während der Garbage Collection aufgerufen wird, stellen Sie sicher, dass alle Klassen, die
teure Ressourcen (z. B. Datenbankverbindungen) verbrauchen, über eine Methode verfügen, die vor der Zerstörung aufgerufen werden kann.
Dies ist eine sehr gute Idee, diese Ressourcen freizugeben.

Namespace

Hier finden Sie eine kurze Einführung in Namespaces. Namespaces ermöglichen die Organisation von Anwendungen in logischen Elementen sowohl in internen als auch externen Darstellungen. Der gesamte Code innerhalb des Dienstes ist in MSDNMessage enthalten

Service.Service-Namespace. Obwohl der Dienstcode in mehreren Dateien enthalten ist, müssen Benutzer nicht auf andere Dateien verweisen, da diese im selben Namespace enthalten sind.

Da die IWebMessage-Schnittstelle im Namen MSDNMessageService.Interface enthalten ist
Leerzeichen, sodass Thread-Klassen, die diese Schnittstelle verwenden, einen Schnittstellen-Namespace haben.

Dienstklasse

Der Zweck der Anwendung besteht darin, Nachrichtenwarteschlangen zu überwachen und zu verarbeiten. Jede Warteschlange führt beim Empfang einer Nachricht einen anderen Prozess aus. Anwendungen werden als Windows-Dienste implementiert.

ServiceBase-Klasse

Wie bereits erwähnt, ist die Grundstruktur des Dienstes die von ServiceBase geerbte Klasse. Wichtige Methoden

sind OnStart, OnStop, OnPause und OnContinue entspricht jede alternative Methode direkt

einem Dienststeuerungsvorgang. Der Zweck der OnStart-Methode besteht darin, ein CWorker-Objekt zu erstellen,

und Die CWorker-Klasse erstellt wiederum ein CWorkerThread-Objekt und erstellt dann in diesem Objekt einen Thread, der die Dienstarbeit

ausführt.

Die Laufzeitkonfiguration des Dienstes (und die Eigenschaften der CWorker- und CWorkerThread-Objekte) wird
in einer XML-basierten Konfigurationsdatei verwaltet. Sie hat denselben Namen wie die erstellte .exe-Datei, aber
Mit einem .cfg-Suffix. Das Konfigurationsbeispiel lautet wie folgt:

〈?xml version="1.0"?〉

〈configuration〉
〈ProcessList〉
　ProcessDefinition
　ProcessName="Worker1"
ProcessDesc="Message Worker mit 2 Threads"
　ProcessType="AppSpecific"
　ProcessThreads="2"
　InputQueue=".private$test_load1"
　ErrorQueue=".private$test_error"〉
　OutputList〉
　〈OutputDefinition OutputName=".private$test_out11" /〉
　〈OutputDefinition OutputName=".private$test_out12" /〉
　 〈/OutputList〉
〈/ProcessDefinition〉
〈ProcessDefinition
　ProcessName="Worker2"
　ProcessDesc="Montagearbeiter mit 1 Thread"
　ProcessType="Assembly"
　ProcessThreads="1"
　InputQueue=".private$test_load2"
　ErrorQueue=".private$test_error"〉
　OutputList〉
　　OutputDefinition OutputName="C:MSDNMessageServiceMessage
　Example.dll" /〉
　OutputDefinition OutputName="MSDNMessageService.Message
　Sample.ExampleClass"/〉
　〈/OutputList〉
〈/ProcessDefinition〉
〈/ProcessList〉
〈/Konfiguration〉

Der Zugriff auf diese Informationen wird über die Config
Manager-Klasse aus der System.Configuration-Assembly verwaltet. statisch Die Get-Methode gibt eine Sammlung von Informationen zurück, die zum Abrufen einzelner Eigenschaften aufgelistet werden. Die Einstellungen dieser Eigenschaftssätze bestimmen die Laufzeiteigenschaften des Hilfsobjekts. Zusätzlich zu dieser
Konfigurationsdatei sollten Sie auch die Definition erstellen Metadatei der XML-Dateistruktur und Referenzen
die Metadatei in der Konfigurationsdatei machine.cfg des Servers:

〈?xml version ="1.0"?〉

〈MetaData xmlns ="x-schema :CatMeta.xms"〉
　〈DatabaseMeta InternalName="MessageService"〉
　　ServerWiring Interceptor="Core_XMLInterceptor"/〉
　 〈Collection
InternalName="Process" PublicName="ProcessList"
PublicRowName="ProcessDefinition"
　SchemaGeneratorFlags="EMITXMLSCHEMA"〉
　　Flags="PRIMARYKEY" /〉
　　Property InternalName="ProcessDesc" Type="String" /〉
　　Property InternalName="ProcessType" Type="Int32" Default
　Value="RoundRobin" 〉
　　　〈Enum InternalName="RoundRobin"　Value="0"/〉
　　　　　　 〈/Property〉
　 〈Property InternalName="ProcessThreads" Type="Int32"
　DefaultValue="1" /〉
　　　Property InternalName="ErrorQueue" Type="String" /〉
　　Property InternalName="OutputName" Type="String" /〉
　　　〈QueryMeta InternalName="QueryByFile" CellName="__FILE"
　Operator="EQUAL"　/〉
　〈/Collection〉
　Collection
　InternalName="Output" PublicName="OutputList"
　　PublicRowName="OutputDefinition"
　SchemaGeneratorFlags="EMITXMLSCHEMA"〉
　　Flags="PRIMARYKEY" /〉
　Property InternalName="OutputName" Type="String" Meta
　Flags="PRIMARYKEY" /〉
　　QueryMeta InternalName="All" MetaFlags="ALL" /〉
　〈QueryMeta InternalName="QueryByFile" CellName="__FILE"
　Operator="EQUAL"　/〉
　〈/Collection〉
　〈/DatabaseMeta〉
　RelationMeta　
PrimaryTable="Process" PrimaryColumns="Prozessname"
ForeignTable="Output" ForeignColumns="ProcessName"
　MetaFlags="USECONTAINMENT"/〉
〈/MetaData>

Da die Service-Klasse eine Liste der erstellten Hilfsobjekte verwalten muss, wird die

Hashtable-Sammlung verwendet, um den Namen von Typobjekten zu speichern. Liste der Zahlenpaare. Hashtable unterstützt nicht
nur Aufzählungen, sondern ermöglicht auch die Abfrage von Werten über Schlüsselwörter. Innerhalb der Anwendung ist der XML-Prozessname
das einzige Schlüsselwort:
private Hashtable htWorkers = new Hashtable();
IConfigCollection cWorkers = ConfigManager.Get("ProcessList", new
AppDomainSelector());
foreach (IConfigItem ciWorker in cWorkers)
{
WorkerFormatter sfWorker = new WorkerFormatter();
　 sfWorker.ProcessName = (string)ciWorker["ProcessName"];
　 sfWorker.ProcessDesc = (string)ciWorker["ProcessDesc"];
　 sfWorker.NumberThreads = (int)ciWorker["ProcessThreads"];
　 sfWorker.InputQueue = (string)ciWorker["InputQueue"];
　 sfWorker.ErrorQueue = (string)ciWorker["ErrorQueue"];

 // 计算并定义进程类型
　 switch ((int)ciWorker["ProcessType"])
　 {
　　　case 0:
　　　　 sfWorker.ProcessType = WorkerFormatter.SFProcessType.
　　　　 ProcessRoundRobin;
　　　　 Pause;
　　　Fall 1:
　　　　 sfWorker.ProcessType = WorkerFormatter.SFProcessType.
　　　　 ProcessAppSpecific;
　　　　 Pause;
　　　Fall 2:
　　　　 sfWorker.ProcessType = WorkerFormatter.SFProcessType.
　　　　 ProcessAssembly;
　　　　 Pause;
　　　Standard:
　　　　 neu werfen Exception("Unbekannter Verarbeitungstyp");
　 }
　 // 执行更多的工作以读取输出信息
　 string sProcessName = (string)ciWorker["ProcessName"];
　 wenn (htWorkers.ContainsKey(sProcessName))
　　　throw new ArgumentException("Prozessname muss eindeutig sein: "
　　　+ sProcessName);
　 htWorkers.Add(sProcessName, new CWorker(sfWorker));
}

　　在这段代码中没有包含的主要信息是输出数据的获取.每一个进程定
义中都有一组相应的输出定义项.该信息是通过如下的简单查询读取的:

string sQuery = "SELECT * FROM OutputList WHERE ProcessName=" +
　 sfWorker.ProcessName + " AND Selector=appdomain://";
ConfigQuery QQuery = new ConfigQuery(sQuery);
IConfigCollection cOutputs = ConfigManager.Get("OutputList",
qQuery);
int iSize = cOutputs.Count, iLoop = 0;
sfWorker.OutputName = neu string[iSize];
foreach (IConfigItem ciOutput in cOutputs)
　 sfWorker.OutputName[iLoop++] = (string)ciOutput["OutputName"];

　　CWorkerThread und Cworker操作进行调用.由于 Hashtable中引用了每一个 CWorker对象，因此需
要枚举 Hashtable的内容，以调用适当的服务控制方法：
foreach (CWorker cWorker in htWorkers.Values)
　 cWorker.Start();

　　类似地, 实现的 OnPause, OnContinue und OnStop 方法是通过调用

CWorker 对象上的相应方法来执行操作的.

CWorker 类

　　CWorker 类的主要功能是创建和管理 CWorkerThread对象.Start 、

Stop、Pause 和 Continue Klicken Sie auf CWorkerThread
助对象引用的 Service类相似，CWorker 使用 ArrayList（简单的动态数
组）来维护线程对象的列表。 

 以上就是C#消息队列应用程序 -1的内容，更多相关文章请关注PHP中文网（m.sbmmt.com）！