저는 한 시간 넘게 연구를 해왔고 C #에서 MSMQ를 사용하는 방법에 대한 훌륭한 샘플을 찾고 Message Queue에 대한 책의 한 장 전체를 찾았습니다 …하지만 빠른 테스트를 위해 필요한 것은이 시나리오뿐입니다. 간단한 데모를 위해 완벽한 방법으로 :
“응용 프로그램 A”: 메시지 큐에 메시지를 씁니다. (응용 프로그램 A는 C # Windows 서비스입니다.) 이제 “응용 프로그램 B”(C # winForms 응용 프로그램)를 열고 MSMQ를 확인하면 새 메시지가 있습니다.
그게 다야 … 간단한 데모에 필요한 모든 것.
누구든지 이것에 대한 코드 샘플로 나를 도울 수 있습니까? 매우 감사.
답변
//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가 시스템에 설치되어 있는지 확인하십시오.
답변
아마도 아래 코드는 누군가 MSMQ를 빠르게 소개하는 데 유용 할 것 입니다.
시작하려면 솔루션에 3 개의 앱을 만드는 것이 좋습니다.
- MessageTo (Windows Form) 추가 1 단추.
- MessageFrom (Windows Form) 리치 텍스트 상자 1 개를 추가합니다.
- 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 개를 추가합니다.
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; }
}
}
즐겨 🙂