基本信息

---

下载

   友情提示：（无需注册或充值，赞助后即可获取资源下载链接）

---

     嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：813200300

本次赞助数额为： 1 元　

支付宝支付

微信支付

   源码介绍

---

 

多线程发送消息

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Messaging;
using System.Threading;

namespace MSMQUI
{
    public partial class Form1 : Form
    {
        private MessageQueue mq;
        private System.Messaging.Message msg;
 
        public Form1()
        {
            InitializeComponent();

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

        private void CreateButton_Click(object sender, EventArgs e)
        {
            if (MessageQueue.Exists(mqCreateTxt.Text))
                //creates an instance MessageQueue, which points 
                //to the already existing MyQueue
                mq = new System.Messaging.MessageQueue(mqCreateTxt.Text);
            else
                //creates a new private queue called MyQueue 
                mq = MessageQueue.Create(mqCreateTxt.Text);
        }

        private void SendButton_Click(object sender, EventArgs e)
        {
            int count = Convert.ToInt32(countTxt.Text);
            while (count > 0)
            {
                ThreadPool.QueueUserWorkItem(new WaitCallback(SendMessage), countTxt.Text);
                count--;
            }
        }

        private void SendMessage(object state)
        {
            if (mq != null)
            {
                try
                {
                    msg.Body = state.ToString();
                    mq.Send(msg);
                }
                catch (InvalidCastException ex)
                {
                }
            }
        }
    }
}