在進行一些如發(fā)送短信、郵件的業(yè)務時,我們經常會使用一個表來存儲待發(fā)送的數據,由后臺多個線程不斷的從表中讀取待發(fā)送的數據進行發(fā)送,發(fā)送完成后再將數據轉移到歷史表中,這樣保證待發(fā)送表的數據一般情況下不會太多。如待發(fā)送表結構為:
Create Table SMS(ID int not null identity(1,1),Content varchar(1024),Status int not null,CreateTime datetime);
Status 取值:0未讀取 1已讀取
這樣設計的好處是,不會因為后端有時發(fā)送過慢導致前端接收發(fā)送消息的請求出現問題,如發(fā)送短信的業(yè)務,有時由于運營商的網關原因發(fā)送太慢,這樣前端可以先將用戶的發(fā)送請求全部放在待發(fā)送表中,由后端進行慢慢發(fā)送。
在后端發(fā)送進程一般使用
Select top 100 * From SMS Where Status=0;這樣的SQL取出未被讀取的數據。
為了提高后端發(fā)送能力,需要部署多個進程同時從待發(fā)送表中取出數據進行發(fā)送,這樣有時就會造成同一個記錄被多個進程同時取出來,并發(fā)送的情況。
今天查了一下SQL Server 的MSDN,發(fā)現可以通過先更新同時通過deleted表(就像是在觸發(fā)器中使用一樣)取出的方式,來保證每條記錄只會被讀取一次。
declare @Rowid table(rowid int);
BEGIN
set rowcount 100; --一次讀取的行數
--先將要讀取的記錄狀態(tài)更新
update Sms set [status]= 1 output deleted.ID into @Rowid Where [status] = 0;
--讀取剛更新狀態(tài)的記錄
select * from Sms where ID in (select Rowid from @Rowid);
END
北京 | 天津 | 上海 | 江蘇 | 山東 |
安徽 | 浙江 | 江西 | 福建 | 深圳 |
廣東 | 河北 | 湖南 | 廣西 | 河南 |
海南 | 湖北 | 四川 | 重慶 | 云南 |
貴州 | 西藏 | 新疆 | 陜西 | 山西 |
寧夏 | 甘肅 | 青海 | 遼寧 | 吉林 |
黑龍江 | 內蒙古 |