PetShop 4.0学习笔记：消息队列MSMQ

在PetShop4.0的ReadMe.html中有如下配置步骤：

Asynchronous Order Placement Setup Instructions

1.     Add a new private queue for Pet Shop called “PSOrders”

2.     Modifyweb.config:

a.     Change theOrderStrategyClass key to OrderAsynchronous
<add key="OrderStrategyClass" value="PetShop.BLL.OrderAsynchronous"/>

b.     Change theMachineName in the following line to your MSMQ computer name.
<add key="OrderQueuePath" value="FormatName:DIRECT=OS:MachineName\Private$\PSOrders"/>

3.     Modifyapp.config in the OrderProcessor project:

a.     Change theMachineName in the OrderQueuePath key:
<add key="OrderQueuePath" value="FormatName:DIRECT=OS:MachineName\Private$\PSOrders"/>

 

 

注意：

1、第1步，建立一个新的专用队列“PSOrders”，队列是“事务性”的。建立时，要勾选“事务性”，如图示：

2、为数据库添加登录名mspetshop，密码为pass@word1，并设置服务器角色为sysadmin。当然你也可以修改app.config中的连接字符串中的用户名和密码。

1、先安装Message Queuing Services

通过Control Panel，“Add/Remove Programs” – “Add/Remove Windows Components”步骤安装MSMQ。

MSMQ可以安装为工作组模式或域模式。如果安装程序没有找到一台运行提供目录服务的消息队列的服务器，则只可以安装为工作组模式，此计算机上的“消息队列”只支持创建专用队列和创建与其他运行“消息队列”的计算机的直接连接。

2、配置MSMQ

打开Computer Management – Message Queuing，在Private Queues下创建MSMQDemo队列

3、编写代码－简单演示MSMQ对象

注意：

添加引用：System.Messaging

代码页：

// Send Message
    protected void btnSendMessage_Click(object sender, System.EventArgs e)
    {

        // Open queue

        System.Messaging.MessageQueue queue = new System.Messaging.MessageQueue(".\\Private$\\MSMQDemo");



        // Create message

        System.Messaging.Message message = new System.Messaging.Message();

        message.Body = txtMessage.Text.Trim();

        message.Formatter = new System.Messaging.XmlMessageFormatter(new Type[] { typeof(string) });



        // Put message into queue

        queue.Send(message);

    }


    // Receive Message
    protected void btnReceiveMessage_Click(object sender, System.EventArgs e)
    {

        // Open queue

        System.Messaging.MessageQueue queue = new System.Messaging.MessageQueue(".\\Private$\\MSMQDemo");



        // Receive message, 同步的Receive方法阻塞当前执行线程，直到一个message可以得到 

        System.Messaging.Message message = queue.Receive();

        message.Formatter = new System.Messaging.XmlMessageFormatter(new Type[] { typeof(string) });

        txtReceiveMessage.Text = message.Body.ToString();

    }

 

页面布局：

<table>
            <tr>
                <td style=" 100px">
                    <asp:TextBox ID="txtMessage" runat="server"></asp:TextBox></td>
                <td style=" 76px">
                    <asp:Button ID="btnSendMessage" runat="server" OnClick="btnSendMessage_Click" Text="Send Message"
                        Width="132px" /></td>
            </tr>
            <tr>
                <td style=" 100px">
                    <asp:TextBox ID="txtReceiveMessage" runat="server"></asp:TextBox></td>
                <td style=" 76px">
                    <asp:Button ID="btnReceiveMessage" runat="server" OnClick="btnReceiveMessage_Click"
                        Text="Receive Message" Width="130px" /></td>
            </tr>
        </table>