Минимум, необходимый для написания примера приложения MSMQ

112

Я исследовал более часа и нашел отличные образцы того, как использовать MSMQ в C #, и даже одну полную главу книги об очереди сообщений ... Но для быстрого теста все, что мне нужно, это охватить этот сценарий, даже не идеальным образом, просто для быстрой демонстрации:

«Приложение A»: записывает сообщение в очередь сообщений. (Приложение A - это служба Windows C #). Теперь я открываю «Приложение B» (это приложение WinForms C #), проверяю MSMQ и вижу, что у меня новое сообщение.

Вот и все ... Все, что мне нужно для простой демонстрации.

Может ли кто-нибудь помочь мне с образцом кода для этого? Очень признателен.

Бон
источник
14
за что голосует против? Если вы что-то знаете по теме, хорошо, научите остальных.
Bohn
4
@Sascha: прочтите начало моего поста: «Я занимаюсь исследованием больше часа и нахожу отличные образцы того, как использовать MSMQ в C #, и даже одну полную главу книги об очереди сообщений ... Но для быстрого тестирования все Мне нужно осветить этот сценарий, даже не в идеальном виде, просто для быстрой демонстрации »
Бон
Возникла проблема в MSMQ stackoverflow.com/questions/29225601/…
Джитендра Панчоли
Также проверьте эту статью MSDN msdn.microsoft.com/en-us/library/…
Разработчик

Ответы:

131
//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();

Для более сложного сценария вы можете использовать объекты Message для отправки сообщения, заключить в него свой собственный объект класса и пометить свой класс как сериализуемый. Также убедитесь, что в вашей системе установлен MSMQ.

Ананд
источник
1
Вопрос: в верхней части, где вы создаете MessageQueue, нам нужны оба? MessageQueue.Create (@ ". \ Private $ \ SomeTestName"); messageQueue = new MessageQueue (@ ". \ Private $ \ SomeTestName");
Bohn
3
Да, вам нужны оба оператора: один фактически создает MSMQ, а другой просто инициализирует MSMQ с помощью пути
Ананд
6
работал как шарм ... Надеюсь, одно из ваших желаний сегодня сбудется ... Сегодня вы решили для меня большую вещь.
Bohn
2
Небольшая опечатка: messageQueue = new MessageQueue (@ ". \ Private $ \ SomeTestName"); System.Messaging.Message [] messages = queue.GetAllMessages (); Должно быть messageQueue = new MessageQueue (@ ". \ Private $ \ SomeTestName"); System.Messaging.Message [] messages = messageQueue.GetAllMessages ();
Kjensen
4
Чтобы вывести вывод очереди на консоль, в теле цикла вывода добавьте "message.Formatter = new XmlMessageFormatter (new String [] {" System.String, mscorlib "}); Console.Write (message.Body .Нанизывать());". Поскольку MSMQ передает вещи как сериализованные объекты, вы должны указать ему, как десериализовать полученные объекты в их исходную форму.
Contango
16

Возможно, приведенный ниже код будет полезен для кого-то, чтобы просто быстро познакомиться с MSMQ .

Итак, для начала я предлагаю вам создать 3 приложения в решении:

  1. MessageTo (Windows Form) Добавить 1 кнопку.
  2. MessageFrom (Windows Form) Добавьте 1 richtextbox.
  3. MyMessage (библиотека классов) Добавьте 1 класс.

Просто скопируйте прошлый код и попробуйте. Убедитесь, что MSMQ установлен в вашей MS Windows и проекты 1 и 2 имеют ссылку на System.Messaging.

1. MessageTo (Windows Form) Добавить 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 (Windows Form) Добавьте 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; }
    }
}

Наслаждаться :)

Разработчик
источник
1
MSQueue потокобезопасный? Несколько приложений EXE используют один и тот же MSQueue? Что насчет GetAllMessages и Purgue?
Kiquenet
@Kiquenet quora.com/… Надеюсь, это поможет вам
Разработчик