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

核心提示：在进行一些如发送短信、邮件的业务时，我们经常会使用一个表来存储待发送的数据，多线程下不重复读取SQL Server的数据，由后台多个线程不断的从表中读取待发送的数据进行发送，发送完成后再将数据转移到历史表中，今天查了一下SQL Server 的MSDN，发现可以通过先更新同时通过deleted表（就像是在触发器中使用一

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

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