基本信息
源码名称: 多线程发送消息队列
源码大小:0.01M
文件格式:.zip
开发语言:C#
更新时间:2015-11-13
友情提示:(无需注册或充值,赞助后即可获取资源下载链接)
嘿,亲!知识可是无价之宝呢,但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下,绝对物超所值哦!如有下载和支付问题,请联系我们QQ(微信同号):78630559
本次赞助数额为: 1 元×
微信扫码支付:1 元
×
请留下您的邮箱,我们将在2小时内将文件发到您的邮箱
源码介绍
多线程发送消息
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)
{
}
}
}
}
}