多线程下不重复读取SQL Server 表的数据
在进行一些如发送短信、邮件的业务时,我们经常会使用一个表来存储待发送的数据,由后台多个线程不断的从表中读取待发送的数据进行发送,发送完成后再将数据转移到历史表中,这样保证待发送表的数据一般情况下不会太多。如待发送表结构为:
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://blog.csdn.net/fuyifang
最新文章
- 十DHT11
- 代理服务器(Proxy)原理
- SQL SERVER 数据库实用SQL语句
- DDL_数据库模式定义语言
- navagationController 的子控制器如何取消右滑返回
- c++学习笔记1(c++简介)
- jsp 2种include标签的区别
- C 运算符与表达式
- 随心所欲~我也做个集合遍历器吧(自己的foreach,委托的威力)
- osx下快捷键相应符号
- mybatis中$和#java代码演示
- 我的";Hello World!";之旅
- 201521123044 《Java程序设计》第6周学习总结
- win10 uwp 按下等待按钮
- [深度应用]·DC竞赛轴承故障检测开源Baseline(基于Keras 1D卷积 val_acc:0.99780)
- 深入详解美团点评CAT跨语言服务监控(五)配置与数据库操作
- maven 添加jetty 支持
- Jenkins git鬼畜集
- ubuntu 文档查看器/gedit查看txt中文乱码问题
- CF77E Martian Food(圆的反演or 笛卡尔定理+韦达定理)