Máy chủ SQL, sử dụng bảng dưới dạng hàng đợi

Question

Tôi đang sử dụng SQL Server 2008 R2 làm cơ chế xếp hàng. Tôi thêm các mục vào bảng và dịch vụ bên ngoài đọc và xử lý các mục này. Điều này làm việc tuyệt vời, nhưng thiếu một điều - tôi cần cơ chế theo đó tôi có thể cố gắng chọn một hàng duy nhất từ ​​bảng và, nếu không có một, chặn cho đến khi có (tốt nhất là trong một khoảng thời gian cụ thể).

Có ai có thể tư vấn về cách tôi có thể đạt được điều này không?

Answer 1

tôi cần cơ chế theo đó tôi có thể cố gắng để chọn một hàng duy nhất từ ​​bảng , và nếu không có một, cho đến khi khối có (tốt nhất là trong một thời gian cụ thể thời gian).

Bạn có thể lặp và kiểm tra hàng mới mỗi giây:

while not exists (select * from QueueTable) 
    begin 
    wait for delay '00:01' 
    end 

Disclaimer: đây không phải là mã tôi sẽ sử dụng cho một hệ thống sản xuất, nhưng nó làm những gì bạn yêu cầu.

Answer 2

Người nhận xét trước đã đề xuất sử dụng Nhà môi giới dịch vụ có thể có câu trả lời hay nhất. Dịch vụ môi giới cho phép bạn về cơ bản chặn trong khi chờ đợi thêm đầu vào.

Nếu môi giới dịch vụ quá mức cần thiết, bạn nên xem xét một cách tiếp cận khác cho vấn đề của mình. Bạn có thể cung cấp thêm chi tiết về những gì bạn đang cố gắng làm không?

Answer 3

Cách duy nhất để đạt được một dequeue chặn không gộp là WAITFOR (RECEIVE). Điều này ngụ ý hàng đợi Service Broker, với tất cả các chi phí bổ sung.

Nếu bạn đang sử dụng thông thường tables as queues, bạn sẽ không thể đạt được chặn không bỏ phiếu. Bạn phải thăm dò hàng đợi bằng cách yêu cầu một hoạt động dequeue, và nếu nó không trả về gì cả, hãy ngủ và thử lại sau.

Tôi sợ rằng tôi sẽ không đồng ý với Andomar ở đây: trong khi câu trả lời của anh ấy hoạt động như một câu hỏi chung 'có bất kỳ hàng nào trong bảng không?' khi nói đến xếp hàng, do tính chất bận rộn của việc enqueue chồng lên nhau/dequeue, kiểm tra các hàng như thế này là một (gần như) đảm bảo bế tắc dưới tải. Khi nói đến việc sử dụng các bảng như hàng đợi, người ta phải luôn luôn dính vào các hoạt động enqueue/dequeue cơ bản và không thử các công cụ ưa thích.

Answer 4

"vì SQL Server 2005 đã đưa ra mệnh đề OUTPUT, sử dụng các bảng làm hàng đợi không còn là vấn đề khó". Một bài đăng tuyệt vời về cách thực hiện điều này.

http://rusanu.com/2010/03/26/using-tables-as-queues/

Answer 5

Hãy để tôi chia sẻ kinh nghiệm của tôi với bạn trong lĩnh vực này, bạn có thể tìm thấy nó hữu ích.

Nhóm của tôi trước tiên đã sử dụng hàng đợi giao dịch MSMQ để cung cấp các dịch vụ không đồng bộ của chúng tôi (có thể là IIS được lưu trữ hoặc WS). Vấn đề lớn nhất chúng tôi gặp phải là vấn đề MS DTC dưới tải nặng, như 100 tin nhắn/giây tải; tất cả những gì cần làm là một hoạt động cơ sở dữ liệu chậm ở đâu đó để bắt đầu gây ra ngoại lệ thời gian chờ và MS DTC sẽ đưa ngôi nhà xuống để nói (giao dịch thực sự sẽ bị mất nếu mọi thứ trở nên tồi tệ) và mặc dù chúng tôi không chắc chắn 100% gốc gây ra cho đến ngày nay, chúng tôi nghi ngờ MS DTC trong một môi trường nhóm có một số vấn đề nghiêm trọng.

Vì lý do này, chúng tôi bắt đầu xem xét các giải pháp khác nhau. Dịch vụ xe buýt cho Windows Server (phiên bản tại chỗ của Azure Service Bus) trông đầy hứa hẹn, nhưng nó không giao dịch nên không phù hợp với yêu cầu của chúng tôi.

Cuối cùng, chúng tôi đã quyết định phương pháp tiếp cận theo cách riêng của bạn, một phương pháp được chúng tôi đề xuất cho những người đã tạo Xe buýt dịch vụ Azure, vì các yêu cầu giao dịch của chúng tôi. Về cơ bản, chúng tôi đã làm theo mô hình Vai trò Công nhân Azure cho vai trò công nhân sẽ được cung cấp thông qua một số hàng đợi; một mô hình chặn bỏ phiếu.

Thành thật mà nói, điều này tốt hơn nhiều so với bất kỳ điều gì khác mà chúng tôi đã sử dụng. Mã giả cho một dịch vụ như vậy là:

hasMsg = true 

while(true) 

    if(!hasMsg) 
     sleep 

    msg = GetNextMessage 

    if(msg == null) 
     hasMsg = false 
    else 
     hasMsg = true 

    Process(msg); 

Chúng tôi thấy rằng việc sử dụng CPU thấp hơn đáng kể theo cách này (thấp hơn các dịch vụ WCF truyền thống).

Phần khó khăn của khóa học là xử lý giao dịch. Nếu bạn muốn có nhiều phiên bản dịch vụ của bạn đọc từ hàng đợi, bạn sẽ cần sử dụng read-past/updlock trong sql của bạn, và cũng có dịch vụ .net của bạn tham gia vào các giao dịch theo cách sẽ cuộn trở lại nên dịch vụ không thành công. trong trường hợp này, bạn sẽ muốn đi với hàng đợi thử lại/độc như bảng ngoài hàng đợi thông thường của bạn.