多线程下不重复读取SQLServer的数据

来源:计算机等级考试    发布时间:2012-08-27    计算机等级考试视频    评论

  在进行一些如发送短信、邮件的业务时,我们经常会使用一个表来存储待发送的数据,由后台多个线程不断的从表中读取待发送的数据进行发送,发送完成后再将数据转移到历史表中,这样保证待发送表的数据一般情况下不会太多。如待发送表结构为:
  Create Table SMS(ID int not null identity(1,1),Content varchar(1024),Status int not null,CreateTime datetime);
  Status 取值:0未读取 1已读取
  这样设计的好处是,不会因为后端有时发送过慢导致前端接收发送消息的请求出现问题,如发送短信的业务,有时由于运营商的网关原因发送太慢,这样前端可以先将用户的发送请求全部放在待发送表中,由后端进行慢慢发送。
  在后端发送进程一般使用
  Select top 100 * From SMS Where Status=0;这样的SQL取出未被读取的数据。
  为了提高后端发送能力,需要部署多个进程同时从待发送表中取出数据进行发送,这样有时就会造成同一个记录被多个进程同时取出来,并发送的情况。
  今天查了一下SQL Server 的MSDN,发现可以通过先更新同时通过deleted表(就像是在触发器中使用一样)取出的方式,来保证每条记录只会被读取一次。
  declare @Rowid table(rowid int);
  BEGIN
  set rowcount 100; --一次读取的行数
  --先将要读取的记录状态更新
  update Sms set [status]= 1  output deleted.ID into @Rowid Where [status] = 0;
  --读取刚更新状态的记录
  select  * from Sms where ID in (select Rowid from @Rowid);
  END

  编辑特别推荐:

  用户关于桌面系统虚拟化应掌握和注意的事项

  考试大教育全国计算机等级考试在线测试平台

  全国计算机等级考试论坛

视频学习

我考网版权与免责声明

① 凡本网注明稿件来源为"原创"的所有文字、图片和音视频稿件,版权均属本网所有。任何媒体、网站或个人转载、链接转贴或以其他方式复制发表时必须注明"稿件来源:我考网",违者本网将依法追究责任;

② 本网部分稿件来源于网络,任何单位或个人认为我考网发布的内容可能涉嫌侵犯其合法权益,应该及时向我考网书面反馈,并提供身份证明、权属证明及详细侵权情况证明,我考网在收到上述法律文件后,将会尽快移除被控侵权内容。

最近更新

社区交流

考试问答