• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>

    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>

            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>
            

    
            

            




            







												


        

            
	
            
		
			

            

            
	
            
		
			
            Prayer
            
			在一般中尋求卓越
		            		
	
            

            

            

            
	
            

            posts - 1256, comments - 190, trackbacks - 0, articles - 0
            
	
 
C++博客 ::
首頁(yè) ::
新隨筆 ::
聯(lián)系 ::
聚合
 ::
管理


            
		            		
	
            
	
            
		
			
            
			
            
		            		
		
			
            
				
					
	
            
		
		
            如何讓多進(jìn)程多線程訪問(wèn)數(shù)據(jù)庫(kù)，而不會(huì)選擇相同的數(shù)據(jù)，這在設(shè)計(jì)分布式程序的時(shí)候經(jīng)常用到，多臺(tái)機(jī)器的多個(gè)進(jìn)程，每個(gè)進(jìn)程都有多個(gè)線程，每個(gè)線程要從數(shù)據(jù)庫(kù)里取數(shù)據(jù)來(lái)處理，要實(shí)現(xiàn)不能漏取數(shù)據(jù)，也不能重復(fù)取數(shù)據(jù)，這里給出答案
            創(chuàng)建一個(gè)數(shù)據(jù)表，如下，一個(gè)自增列，一個(gè)表示rss鏈接地址
            CREATE TABLE [dbo].[Rss_RssSources](
                         [SourceId] [int] IDENTITY(1,1) NOT NULL            ,
                         [Link] [varchar](1024) NOT NULL
            )             ON [PRIMARY]

            先放1w條數(shù)據(jù)
            declare @i int
            set @i = 1
            while @i < 10000
            begin
                         select @i = @i +1
                         insert into [Rss_RssSources] values(newid())
            end

            再創(chuàng)建一個(gè)鎖表，一個(gè)字段表示是否已經(jīng)鎖定的資源，另一個(gè)表示已經(jīng)讀取的rss源的最大id
            create table Rss_RssSourceLock
            (
            IsLock             bit            ,
            MaxSourceId             int
            )
            初始化數(shù)據(jù)
            insert into Rss_RssSourceLock values (0,0) 
            下面我們要設(shè)計(jì)一個(gè)存儲(chǔ)過(guò)程，讓這個(gè)存儲(chǔ)過(guò)程每次返回10個(gè)rss源，知道返回所有的rss源，要求無(wú)遺漏，無(wú)重復(fù)返回。如下
            CREATE PROCEDURE [dbo].[USP_GetRssSources]
            AS
            BEGIN
            if exists(select * from Rss_RssSourceLock with(READPAST) where IsLock = 0)
            begin
                         declare @select_count int
                         begin tran
                         update Rss_RssSourceLock set IsLock = 1
                         if object_id('tempdb..#t') is not null             
                         drop table             #t
                         select top 10 a.* into #t from [Rss_RssSources] as             a
                         inner join Rss_RssSourceLock as             b
                         on a.SourceId >             b.MaxSourceId
                         order by a.[SourceId]
                         select @select_count = count(*) from #t
                         update Rss_RssSourceLock set IsLock = 0,MaxSourceId = MaxSourceId + @select_count
                         select * from #t commit tran
                         end
            END


            1、如果鎖表里顯示沒(méi)有進(jìn)程正在讀取rss源（IsLock = 0），那么就返回從最大的rss源id往后的10個(gè)rss源，否則返回空。
            2、 用with(READPAST)表示忽略鎖住的行，如果另一個(gè)進(jìn)程正在執(zhí)行update Rss_RssSourceLock的語(yǔ)句，并且在事務(wù)提交前，update語(yǔ)句會(huì)鎖住這些要更新的行，而Rss_RssSourceLock表就一行數(shù) 據(jù)，這時(shí)候select Rss_RssSourceLock表并且忽略被鎖的行肯定是沒(méi)數(shù)據(jù)的，所以本次存儲(chǔ)過(guò)程執(zhí)行會(huì)返回空。
            3、begin tran和commit tran保證了即使本次存儲(chǔ)過(guò)程出錯(cuò)，也不會(huì)讓Rss_RssSourceLock表處于IsLock = 1的臟數(shù)據(jù)狀態(tài)，如果處于這種狀態(tài)，后面的進(jìn)程執(zhí)行存儲(chǔ)過(guò)程就永遠(yuǎn)也返回不了數(shù)據(jù)了。
            4、因?yàn)橛袝r(shí)候一次選取的記錄可能不夠10條，所以這里用了個(gè)臨時(shí)表來(lái)暫存記錄，再算出來(lái)選取的條數(shù)，最后更新Rss_RssSourceLock表的MaxSourceId字段。但用臨時(shí)表肯定會(huì)增加數(shù)據(jù)庫(kù)的壓力，這里不知道用表變量是不是會(huì)改善性能，暫時(shí)先這樣了。
            5、應(yīng)用里調(diào)用這個(gè)存儲(chǔ)過(guò)程，如果返回了數(shù)據(jù)，就進(jìn)行處理，如果沒(méi)返回?cái)?shù)據(jù)，就sleep幾秒才執(zhí)行，直到返回?cái)?shù)據(jù)。            

            
	
            


            
	    
    




            






            

				
			
            
		            		
	
            
	
            
		
			


		
	
            

            

    
    







            
	   
	



精品无码久久久久久午夜|
久久99精品国产99久久6男男|
国内精品久久久久久久亚洲|
精品久久久久中文字幕一区|
亚洲国产成人精品女人久久久|
国产成人精品三上悠亚久久|
狠狠狠色丁香婷婷综合久久俺|
久久久久久毛片免费看|
精品国产青草久久久久福利|
国产精品久久久久久久|
伊人久久五月天|
久久免费精品视频|
人妻无码αv中文字幕久久琪琪布
人妻无码精品久久亚瑟影视
|
94久久国产乱子伦精品免费|
欧美日韩精品久久久久|
久久婷婷国产麻豆91天堂|
狠狠色狠狠色综合久久|
九九久久精品无码专区|
97久久国产亚洲精品超碰热|
国内精品伊人久久久久妇|
欧美久久精品一级c片片|
少妇人妻88久久中文字幕|
欧美午夜A∨大片久久|
久久伊人精品青青草原高清|
日本欧美久久久久免费播放网|
亚洲欧美日韩久久精品|
国产午夜精品久久久久九九|
大伊人青草狠狠久久|
久久一日本道色综合久久|
热久久最新网站获取|
亚洲精品WWW久久久久久|
久久精品成人免费国产片小草
|
亚洲精品午夜国产va久久|
久久伊人五月天论坛|
欧美日韩精品久久久免费观看|
久久国产成人午夜aⅴ影院|
久久线看观看精品香蕉国产|
久久精品国产影库免费看|
久久久久综合网久久|
国产99久久久国产精免费|
A级毛片无码久久精品免费|