Az el\u0151z\u0151 post kommentjei alapj\u00e1n (amit nagyon k\u00f6sz\u00f6n\u00f6k mindenkinek) nem kaptam sok b\u00e1tor\u00edt\u00e1st az aszinkron, queue alap\u00fa, k\u00e9r\u00e9s-v\u00e1laszt k\u00fcl\u00f6nv\u00e1laszt\u00f3 gazdag kliens – szerviz kommunik\u00e1ci\u00f3hoz, \u00fagy t\u0171nik senki nem csin\u00e1lt ilyet, \u00edgy nem akarok \u00fatt\u00f6r\u0151 lenni a t\u00e9m\u00e1ban.
\nEhhez m\u00e9g hozz\u00e1j\u00e1rul, hogy h\u00e9tv\u00e9g\u00e9n m\u00e9regettem az MSMQ teljes\u00edtm\u00e9ny\u00e9t. Az\u00e9rt ezt, mert a WCF is erre \u00e9p\u00edt, \u00e9s pl. az NServiceBus is.<\/p>\n
A tesztk\u00f3d 1.5kByteos \u00fczeneteket rak \u00e1t egyik sorb\u00f3l a m\u00e1sikba. Az \u00f6tlet innen<\/a> j\u00f6tt, csak t\u00f6bbsz\u00e1las\u00edtottam.<\/p>\n A tesztk\u00f3d:<\/p>\n using System; namespace MsmqTran static void Main() Console.WriteLine(“Filling source queue…”); WaitHandle.WaitAll(WaitForEmpty);<\/p>\n Console.WriteLine(“Duration: {0}ms, throughput: {1:F0} messages\/s”, sp.ElapsedMilliseconds, 1000.0 * NumberOfTests \/ sp.ElapsedMilliseconds); private static void ProcessMsg(MessageQueue q1, MessageQueue q2, ManualResetEvent w) Message message; q2.Send(message, msmqTx);<\/p>\n msmqTx.Commit(); A g\u00e9pemen 50 tran\/sec-kel megy 1 sz\u00e1lon, \u00e9s 200 f\u00f6l\u00e9 nem nagyon megy. J\u00f3, ez laptop, de rel\u00e1ci\u00f3s adatb\u00e1ziskezel\u0151vel (sql server \u00e9s oracle is fut a g\u00e9pen) t\u00f6bb ezer tran\/seccel mennek a dolgok. Sz\u00f3val ez el\u00e9g g\u00e1zosan lass\u00fa. Emellett cs\u00fanya le\u00e1ll\u00e1sokr\u00f3l is \u00edrnak a blogokban, amikor be\u00e1ll az msmq.<\/p>\n Marad a aszinkron\u00edtott WCF egyel\u0151re, csak a szerverr\u0151l visszafel\u00e9 h\u00edv\u00e1sokat tervezem queue alapon megcsin\u00e1lni, WCF msmq bindinggal. \u00cdgy tudom \u00e9rtes\u00edteni az appokat polling n\u00e9lk\u00fcl. Erre 3 okom van most: K\u00f6sz\u00f6n\u00f6m m\u00e9g egyszer az \u00e9p\u00edt\u0151 javaslatokat.<\/p>\n","protected":false},"excerpt":{"rendered":" Az el\u0151z\u0151 post kommentjei alapj\u00e1n (amit nagyon k\u00f6sz\u00f6n\u00f6k mindenkinek) nem kaptam sok b\u00e1tor\u00edt\u00e1st az aszinkron, queue alap\u00fa, k\u00e9r\u00e9s-v\u00e1laszt k\u00fcl\u00f6nv\u00e1laszt\u00f3 gazdag kliens –…<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[8,75,49,6,13,4],"tags":[],"class_list":["post-1181","post","type-post","status-publish","format-standard","hentry","category-net","category-net-4","category-architektura","category-adatbazisok","category-design","category-szakmai-elet"],"_links":{"self":[{"href":"https:\/\/soci.hu\/blog\/index.php\/wp-json\/wp\/v2\/posts\/1181","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/soci.hu\/blog\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/soci.hu\/blog\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/soci.hu\/blog\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/soci.hu\/blog\/index.php\/wp-json\/wp\/v2\/comments?post=1181"}],"version-history":[{"count":3,"href":"https:\/\/soci.hu\/blog\/index.php\/wp-json\/wp\/v2\/posts\/1181\/revisions"}],"predecessor-version":[{"id":1183,"href":"https:\/\/soci.hu\/blog\/index.php\/wp-json\/wp\/v2\/posts\/1181\/revisions\/1183"}],"wp:attachment":[{"href":"https:\/\/soci.hu\/blog\/index.php\/wp-json\/wp\/v2\/media?parent=1181"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/soci.hu\/blog\/index.php\/wp-json\/wp\/v2\/categories?post=1181"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/soci.hu\/blog\/index.php\/wp-json\/wp\/v2\/tags?post=1181"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}
\nusing System.Diagnostics;
\nusing System.Messaging;
\nusing System.Threading;<\/p>\n
\n{
\n class Program
\n {
\n private const int NumberOfTests = 1000;
\n private const int MaxDop = 10;
\n private static readonly ManualResetEvent[] WaitForEmpty = new ManualResetEvent[MaxDop];<\/p>\n
\n {
\n var q1 = new MessageQueue(@”.\\private$\\test_queue1″);
\n var q2 = new MessageQueue(@”.\\private$\\test_queue2″);<\/p>\n
\n var b = new byte[1500];
\n using (var msmqTx = new MessageQueueTransaction())
\n {
\n msmqTx.Begin();
\n for (int i = 0; i < NumberOfTests; i++)\n {\n q1.Send(b, msmqTx);\n }\n msmqTx.Commit();\n }\n\n q2.Purge();\n Console.WriteLine(\"Starting to move data from source queue to destination queue\");\n\n var sp = Stopwatch.StartNew();\n\n for (int i = 0; i < MaxDop; i++)\n {\n WaitForEmpty[i] = new ManualResetEvent(false);\n ThreadPool.QueueUserWorkItem(o => ProcessMsg(q1, q2, (ManualResetEvent)o), WaitForEmpty[i]);
\n }<\/p>\n
\n }<\/p>\n
\n {
\n while (true)
\n {
\n using (var msmqTx = new MessageQueueTransaction())
\n {
\n msmqTx.Begin();<\/p>\n
\n try
\n {
\n message = q1.Receive(TimeSpan.FromMilliseconds(0), msmqTx);
\n }
\n catch (MessageQueueException e)
\n {
\n Console.WriteLine(e);
\n w.Set();
\n break;
\n }<\/p>\n
\n }
\n }
\n }
\n }
\n}<\/p>\n
\n1. Az offline (disconnected) pessimistic lock<\/a> felold\u00f3dott, lehet szerkeszteni valamit.
\n2. Friss\u00edteni kell a kliens cache-ben valamit.
\n3. Email jelleg\u0171 \u00fczenetk\u00fcld\u00e9s az appok k\u00f6z\u00f6tt.<\/p>\n