एमएसएमक्यू नमूना आवेदन

Question

लिखने के लिए न्यूनतम न्यूनतम आवश्यक है, मैं एक घंटे से अधिक समय तक शोध कर रहा हूं और सी # में एमएसएमक्यू का उपयोग करने के तरीके और संदेश कतार के बारे में एक पुस्तक का एक पूरा अध्याय भी प्राप्त करने के महान नमूने ढूंढ रहा हूं ... लेकिन जल्दी के लिए टेस्ट को कवर करने की ज़रूरत है, यह एक परिदृश्य है, केवल एक त्वरित तरीके से नहीं, केवल एक त्वरित डेमो के लिए:

"एप्लिकेशन ए": संदेश कतार में एक संदेश लिखता है। (एप्लिकेशन ए एक सी # विंडोज सेवा है) अब मैं "एप्लिकेशन बी" खोलता हूं (यह एक सी # WinForms ऐप है) और मैं एमएसएमक्यू की जांच करता हूं और मुझे लगता है कि मेरे पास एक नया संदेश है।

यह है ... मुझे बस एक साधारण डेमो की आवश्यकता है।

क्या कोई इस के लिए कोड नमूना के साथ मेरी मदद कर सकता है? बहुत सराहना की।

Answer 1

//From Windows Service, use this code 
MessageQueue messageQueue = null; 
if (MessageQueue.Exists(@".\Private$\SomeTestName")) 
{ 
    messageQueue = new MessageQueue(@".\Private$\SomeTestName"); 
    messageQueue.Label = "Testing Queue"; 
} 
else 
{ 
    // Create the Queue 
    MessageQueue.Create(@".\Private$\SomeTestName"); 
    messageQueue = new MessageQueue(@".\Private$\SomeTestName"); 
    messageQueue.Label = "Newly Created Queue"; 
} 
messageQueue.Send("First ever Message is sent to MSMQ", "Title"); 

---

//From Windows application 
MessageQueue messageQueue = new MessageQueue(@".\Private$\SomeTestName"); 
System.Messaging.Message[] messages = messageQueue.GetAllMessages(); 

foreach (System.Messaging.Message message in messages) 
{ 
    //Do something with the message. 
} 
// after all processing, delete all the messages 
messageQueue.Purge(); 

अधिक जटिल परिदृश्य के लिए, आप संदेश इस्तेमाल कर सकते हैं, संदेश भेजने इसके अंदर अपने स्वयं के वर्ग वस्तु लपेट, और serializable के रूप में अपने वर्ग को चिह्नित करने के वस्तुओं। यह भी सुनिश्चित करें कि आपके सिस्टम पर MSMQ स्थापित है

Answer 2

शायद नीचे दिए गए कोड को MSMQ पर त्वरित परिचय प्राप्त करने के लिए उपयोगी होगा।

तो आपको समाधान 3 ऐप्स में बनाना होगा।

1. MessageTo (Windows Form) Add 1 button.
2. MessageFrom (Windows Form) Add 1 richtextbox.
3. MyMessage (Class Library) Add 1 class.

बस पिछले कोड की प्रतिलिपि बनाएँ और इसे आजमाएं। सुप्रीम करें कि एमएसएमक्यू आपके एमएस विंडोज़ पर स्थापित है और 1 और 2 के प्रोएक्ट्स System.Messaging पर रीफर्न्स हैं।

1. संदेश (विंडोज फॉर्म) 1 बटन जोड़ें।

using System; 
using System.Messaging; 
using System.Windows.Forms; 

namespace MessageTo 
{ 
    public partial class Form1 : Form 
    { 
     public Form1() 
     { 
      InitializeComponent(); 
     } 

     private void button1_Click(object sender, EventArgs e) 
     { 

      #region Create My Own Queue 

      MessageQueue messageQueue = null; 
      if (MessageQueue.Exists(@".\Private$\TestApp1")) 
      { 
       messageQueue = new MessageQueue(@".\Private$\TestApp1"); 
       messageQueue.Label = "MyQueueLabel"; 
      } 
      else 
      { 
       // Create the Queue 
       MessageQueue.Create(@".\Private$\TestApp1"); 
       messageQueue = new MessageQueue(@".\Private$\TestApp1"); 
       messageQueue.Label = "MyQueueLabel"; 
      } 

      #endregion 

      MyMessage.MyMessage m1 = new MyMessage.MyMessage(); 
      m1.BornPoint = DateTime.Now; 
      m1.LifeInterval = TimeSpan.FromSeconds(5); 
      m1.Text = "Command Start: " + DateTime.Now.ToString(); 

      messageQueue.Send(m1); 
     } 
    } 
} 

2. MessageFrom (विंडोज फार्म) 1 richtextbox जोड़ें।

using System; 
using System.ComponentModel; 
using System.Linq; 
using System.Messaging; 
using System.Windows.Forms; 

namespace MessageFrom 
{ 
    public partial class Form1 : Form 
    { 
     Timer t = new Timer(); 
     BackgroundWorker bw1 = new BackgroundWorker(); 
     string text = string.Empty; 

     public Form1() 
     { 
      InitializeComponent(); 

      t.Interval = 1000; 
      t.Tick += T_Tick; 
      t.Start(); 

      bw1.DoWork += (sender, args) => args.Result = Operation1(); 
      bw1.RunWorkerCompleted += (sender, args) => 
      { 
       if ((bool)args.Result) 
       { 
        richTextBox1.Text += text; 
       } 
      }; 
     } 

     private object Operation1() 
     { 
      try 
      { 
       if (MessageQueue.Exists(@".\Private$\TestApp1")) 
       { 
        MessageQueue messageQueue = new MessageQueue(@".\Private$\TestApp1"); 
        messageQueue.Formatter = new XmlMessageFormatter(new Type[] { typeof(MyMessage.MyMessage) }); 


        System.Messaging.Message[] messages = messageQueue.GetAllMessages(); 

        var isOK = messages.Count() > 0 ? true : false; 
        foreach (System.Messaging.Message m in messages) 
        { 
         try 
         { 
          var command = (MyMessage.MyMessage)m.Body; 
          text = command.Text + Environment.NewLine; 
         } 
         catch (MessageQueueException ex) 
         { 
         } 
         catch (Exception ex) 
         { 
         } 
        }     
        messageQueue.Purge(); // after all processing, delete all the messages 
        return isOK; 
       } 
      } 
      catch (MessageQueueException ex) 
      { 
      } 
      catch (Exception ex) 
      { 
      } 

      return false; 
     } 

     private void T_Tick(object sender, EventArgs e) 
     { 
      t.Enabled = false; 

      if (!bw1.IsBusy) 
       bw1.RunWorkerAsync(); 

      t.Enabled = true; 
     } 
    } 
} 

3. MyMessage (कक्षा लाइब्रेरी) 1 वर्ग जोड़ें।

using System; 

namespace MyMessage 
{ 
    [Serializable] 
    public sealed class MyMessage 
    { 
     public TimeSpan LifeInterval { get; set; } 

     public DateTime BornPoint { get; set; } 

     public string Text { get; set; } 
    } 
} 

:)