?????????????С????????????????У?????????????????????????￡????????????????????????
???????????????????????????????????С????????????????????????????Socket????????????????????????????????????????????????????????Щ??????д?????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????? ????????????? ?????????????????????????????δ??????????????????????????????????????????????????е?????
???????????￡????MSMQ???????????????????????У?
??????VS????? Messaging????????????MessageQueue????????????????????????????????????????????????????????е????????????????????????У????е?????????????????????ū????????вο????Щд?ò???????????????????????????????????????????????????????????1????δ??????? 2?????????з?????? 3?? ??λ???????е????
????????????????У??????????????????Socket?????????????????????????????????????????????????????????????????????????????????????
MessageQueue myqueue = null;
string queuepath = @".private$queuedemo";
if (!MessageQueue.Exists(queuepath))
{
myqueue = MessageQueue.Create(queuepath);
}
myqueue = new MessageQueue(queuepath);
????????????????????????????????????queuedemo????????У????????????????????????????????????????????????->?????????μ?????????п?????????queuedemo???У?private$????????????????????У????????????????????????????????????鷳?????????????????????“.”???????????????????????????????????????????????????????????????????????????д????????У??????????е??????????????????queuepath·???????д??
????string queuepath = @"FormatName:Direct=TCP:192.168.1.153private$queuedemo";
????????д????????????????????????н??з????????MessageQueue??Create()??Exisit()?????????????????FormatName??????????????Create()???????????????????MessageQueue???????????????????????е??????????
???????????У?????з????????
????string s = "???????????????????");
????System.Messaging.Message msg = new System.Messaging.Message();
????msg.Body = s;
????msg.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });
????MessageQueue mq = new MessageQueue(@"FormatName:Direct=TCP:192.168.1.153private$queuedemo");
????mq.Send(msg);
???????????У??????MessageQueue?????????????????????????·?????????MessageQueue?????????????·????????FormatName??????????TCP??????HTTP????Machine??????????????????????Send()???????????д?????У???????????????????л?????д??????????????formatter???????????XmlMessageFormatter ????BinaryMessageFormatter??? ???????????? ?????Body??Object????? ?????????д???κ?????????????????????
????????????н??????????
MessageQueue mq = new MessageQueue(@".private$queuedemo");
mq.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });
Thread th = new Thread(() =>
{
while (true)
{
System.Messaging.Message msg = mq.Receive();
if (msg != null)
{
MessageBox.Show(msg.Body.ToString());
}
}
});
th.IsBackground = true;
th.Start();
???????????????′??????????????????????У????????????????л?????????л????????????μ?????????foarmatter??????????????formatter?????????????????????????Receive()???????壬?????????????????????????????????????????????е???????????μ????д????????????????