使用 MSMQ,将数据串行化后丢到消息队列中,然后再用一个 Windows 服务定时从消息队列中取出数据,插入数据库,保存在内存中毕竟不安全,如果程序挂了,没存的数据就丢了,而 MSMQ 就不会存在这些问题。
解决方案 »
- c# winForm
- [[[00983C34]+1C]+24]+260]。。求[]的个数
- DataTable 中的TableNewRow事件如何取消刚刚新建的行?
- 在C#中如何将日期时间分别转化为byte[]
- 请问如何获取某个程序(如QQ)与外部网络通信的信息
- 关于泛型,如何调用泛型的方法?
- 你打算今年跳槽吗?
- 如何用代码删除RichTextBox中选中的文字?
- 关于windows phone 8.0连接sqlite数据库的问题,跪求大神救命。。。
- VS2010 C# 怎样实现统计数据时,可以同时显示表格在datagridview中,还显示图表
- 火狐中js怎样调用web服务,解决送100分
- 在windows上不显示u盘的盘符
然后用个timer控件,设置定时
将内存中列表的数据插入数据库
插入成功后,将这条数据从内存列表充删除,避免重复定时执行就好了啊
2、using System.messagiong 命名空间
3、创建/建立自己需要的队列(这里监测专有队列)string queuename=".\\private$\\testQueue";
MessageQueue q;
if(MessageQueue.Exists(queuename) )
{
q=new System.Messaging.MessageQueue (queuename);
}
else
{
q=MessageQueue.Create(queuename);
}这代代码执行后,会在消息队列中的专有队列看到名为testQueue的队列。具体为管理工具--〉计算机管理--〉服务和应用程序--〉消息队列--〉专用队列
可以看到队列中存在的消息
4、向队列发送消息
两种发送消息的方式:
简单消息,直接利用q.send("....");的方式发送,复杂消息(譬如一个特定对象,当然是可序列化的)采用Message m=new Message();
m.Label ="msg1";
m.Body ="test body";
q.Send (m);发送。消息会采用缺省的XML格式编码送到队列中
5、消息接收
主动方式,会同步阻塞当前线程
Message m=Receive(); //接收同时,从队列中删除消息
or
Message m=Peek(); //不删除接收到的消息
被动方式,异步调用方式,不会阻塞当前线程
q.ReceiveCompleted +=new ReceiveCompletedEventHandler( ReceivedEvt); //事件
q.BeginReceive();
其中ReceivedEvt要么为静态函数,要么必须是属于实例化的对象的可访问函数private static void ReceivedEvt(object source, ReceiveCompletedEventArgs asyncResult)
{
try
{
MessageQueue mq = (MessageQueue)source;
Message m = mq.EndReceive(asyncResult.AsyncResult);
//此事m为异步接收到的消息
//在此插入处理消息的代码
Console.WriteLine("接收到消息"+m.Label );
mq.BeginReceive();//接收下一次事件
}
catch(MessageQueueException)
{}
return;
}大体上就这些,完整的应用你可以看一下 PetShop 的异步订单处理,另外,注意一点,消息队列是 Windows 的一一项服务,默认并没有安装,需要在“新增/删除程序项”里添加该服务。其实 MSMQ 是一项分布式处理技术,作为 WinForm 应用,你可以将所有客户端的学生记录全部发送到服务器的消息队列中,由服务器统一完成数据库的插入,当然,是否有必要这样做,你可以根据自己的情况取舍。