程序员人生 网站导航

多线程下不重复读取SQL Server 表的数据

栏目:互联网时间:2014-11-17 08:41:50

在进行1些如发送短信、邮件的业务时,我们常常会使用1个表来存储待发送的数据,由后台多个线程不断的从表中读取待发送的数据进行发送,发送完成后再将数据转移到历史表中,这样保证待发送表的数据1般情况下不会太多。如待发送表结构为:

Create Table SMS(ID int not null identity(1,1),Content varchar(1024),Status int not null,CreateTime datetime);

Status 取值:0未读取 1已读取

这样设计的好处是,不会由于后端有时发送过慢致使前端接收发送消息的要求出现问题,如发送短信的业务,有时由于运营商的网关缘由发送太慢,这样前端可以先将用户的发送要求全部放在待发送表中,由后端进行渐渐发送。

在后端发送进程1般使用

Select top 100 * From SMS Where Status=0;这样的SQL取出未被读取的数据。

为了提高后端发送能力,需要部署多个进程同时从待发送表中取出数据进行发送,这样有时就会造成同1个记录被多个进程同时取出来,并发送的情况。

今天查了1下SQL Server 的MSDN,发现可以通过先更新同时通过deleted表(就像是在触发器中使用1样)取出的方式,来保证每条记录只会被读取1次。

declare @Rowid table(rowid int);
BEGIN
set rowcount 100; --1次读取的行数
--先将要读取的记录状态更新
update Sms set [status]= 1 output deleted.ID into @Rowid Where [status] = 0;
--读取刚更新状态的记录
select * from Sms where ID in (select Rowid from @Rowid);
END

------分隔线----------------------------
------分隔线----------------------------

最新技术推荐