Đánh dấu nguyên tử và trả về một nhóm hàng trong cơ sở dữ liệu

Question

Tôi đang viết một dịch vụ nền cần xử lý một loạt công việc, được lưu trữ dưới dạng bản ghi trong bảng sqlserver. Dịch vụ cần tìm 20 công việc lâu đời nhất cần được làm việc (where status = 'new'), đánh dấu chúng (set status = 'processing'), chạy chúng và cập nhật công việc sau đó.

Đó là phần đầu tiên tôi cần trợ giúp. Có thể có nhiều chuỗi truy cập cơ sở dữ liệu cùng một lúc và tôi muốn đảm bảo rằng truy vấn "đánh dấu & trả về" chạy nguyên tử hoặc gần như vậy.

Dịch vụ này sẽ dành ít thời gian truy cập cơ sở dữ liệu và không phải là kết thúc của thế giới nếu công việc được chạy hai lần, vì vậy tôi có thể chấp nhận một xác suất nhỏ của công việc chạy nhiều lần trong mã.

Cách tốt nhất để làm điều này là gì? Tôi đang sử dụng linq-to-sql cho lớp dữ liệu của tôi, nhưng tôi giả sử tôi sẽ phải thả xuống t-sql cho việc này.

Answer 1

bảng của bạn công việc là hàng đợi. Việc viết các hàng đợi của các bảng người dùng được sao lưu là một lỗi nổi tiếng vì nó dẫn đến các sự cố và các vấn đề đồng thời.

Điều đơn giản nhất là thả bảng người dùng và sử dụng đúng queue để thay thế. Điều này sẽ cung cấp cho bạn hàng đợi miễn phí sự cố đồng thời miễn phí trên hệ thống mã được kiểm tra và xác nhận hợp lệ. Vấn đề là toàn bộ mô hình xung quanh hàng đợi thay đổi từ INSERT và DELETE/UPDATE thành SEND/RECEIVE. Mặt khác với hàng đợi được tích hợp sẵn, bạn sẽ nhận được một số tiện ích miễn phí rất mạnh mẽ, cụ thể là Activation và correlated items locking.

Nếu bạn muốn tiếp tục xuống con đường của bảng sử dụng hàng đợi sao lưu sau đó thứ hai lừa quan trọng nhất bằng văn bản hàng đợi sử dụng bảng là sử dụng CẬP NHẬT ... OUTPUT:

WITH cte AS (
    SELECT TOP(20) status, id, ... 
    FROM table WITH (ROWLOCK, READPAST, UPDLOCK) 
    WHERE status = 'new' 
    ORDER BY enqueue_time) 
UPDATE cte 
    SET status = 'processing' 
OUTPUT 
    INSERTED.id, ... 

Cú pháp CTE là chỉ để thuận tiện cho việc đặt TOP và ORDER BY đúng cách, truy vấn có thể được viết bằng cách sử dụng các bảng có nguồn gốc như một cách thuận tiện. Bạn không thể sử dụng UPDATE thẳng ...TOP vì UPDATE không hỗ trợ ORDER BY và bạn yêu cầu điều này để đáp ứng phần 'lâu đời nhất' theo yêu cầu của bạn. Các gợi ý khóa là cần thiết để tạo thuận lợi cho sự đồng nhất cao giữa các luồng xử lý song song.

Tôi đã nói đây là mẹo quan trọng thứ hai. Điều quan trọng nhất là cách bạn tổ chức bảng. Đối với hàng đợi, phải được nhóm theo (status, enqueue_time). Nếu bạn không tổ chức bảng đúng cách bạn sẽ kết thúc với deadlocks. Nhận xét trước emptive: phân mảnh là không thích hợp trong kịch bản này.

Answer 2

Vui lòng xem câu trả lời của tôi tại đây: SQL Server Process Queue Race Condition cũng quản lý 20 hàng trong một lần.

Về cơ bản, nó khá đơn giản trong SQL Server để quản lý đồng thời và bỏ phiếu bằng cách sử dụng các gợi ý ROWLOCK, READPAST và UPDLOCK.

Tôi không thể bình luận về LINQ, nhưng giao dịch vẫn còn để bạn mở đến vấn đề đồng thời: bạn cần phải sử dụng các gợi ý tôi đã đề cập

Answer 3

Tôi biết đó là off topic nhưng đối với điều này, bạn có thể sử dụng MSMQ. Một hàng đợi tin nhắn sẽ đặt công việc của bạn theo trình tự và chuỗi của nó an toàn. Bạn cũng có thể gán quyền ưu tiên MSMQ cho chính nó. Bạn có thể sử dụng tính năng đọc hoặc xem để xóa thư khỏi hàng đợi hoặc chỉ xem những gì ở đó. Bạn có thể sử dụng mẫu thiết kế lệnh để giúp bạn với điều này.

Answer 4

Nó không chỉ đơn giản như chạy T-SQL của bạn trong một giao dịch, hoặc tôi thiếu một cái gì đó?

Answer 5

xây dựng trên gbn's answer ...

Nếu bạn đang sử dụng SQL Server 2005 hoặc mới hơn, bạn có thể trả lại hàng được cập nhật nguyên tử bằng cách sử dụng một OUTPUT clause trong UPDATE tuyên bố của bạn:

UPDATE TOP (20) your_table 
SET status = 'processing' 
OUTPUT INSERTED.* 
FROM your_table WITH (ROWLOCK, READPAST, UPDLOCK) 
WHERE status = 'new'