多线程下不重复读取SQL数据库的数据_SQL SERVER数据库_黑客防线网安服务器维护基地--Powered by WWW.RONGSEN.COM.CN

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

作者:黑客防线网安SQL维护基地 来源:黑客防线网安SQL维护基地 浏览次数:0

本篇关键词:数据库数据读取重复
黑客防线网安网讯:  在进行一些如发送短信、邮件的业务时,我们经常会使用一个表来存储待发送的数据,由后台多个线程不断的从表中读取待发送的数据进行发送,发送完成后再将数据转移到历史表中,这样保证待...

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

  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

    黑客防线网安服务器维护方案本篇连接:http://www.rongsen.com.cn/show-10505-1.html
网站维护教程更新时间:2012-03-21 03:05:13  【打印此页】  【关闭
我要申请本站N点 | 黑客防线官网 |  
专业服务器维护及网站维护手工安全搭建环境,网站安全加固服务。黑客防线网安服务器维护基地招商进行中!QQ:29769479

footer  footer  footer  footer