RabbitMQ làm thế nào để chia công việc để công việc và xử lý kết quả

Question

Tôi có trường hợp sử dụng sau đây trên một ứng dụng Web mùa xuân dựa trên:

• tôi cần phải áp dụng các Cạnh tranh Người tiêu dùng EIP với xoắn sau: các thông điệp trong hàng đợi thực sự là phân chia nhiệm vụ thuộc cùng một công việc. Do đó, tôi cần phải theo dõi đúng khi tất cả các công việc của một công việc được hoàn thành và trạng thái hoàn thành của họ để lưu các kịch bản hoặc là HOÀN THÀNH hoặc FAILED, đăng nhập kết quả và thông báo bằng ví dụ: e-mail cho người sử dụng phù hợp

Vì vậy, đưa ra yêu cầu tôi trình bày ở trên, câu hỏi của tôi là:

1. này có thể được thực hiện với RabbitMQ và nếu có như thế nào?

Answer 1

Tôi đã tạo nhanh gist để hiển thị ví dụ rất thô sơ về cách người ta có thể làm điều đó. Trong ví dụ này, có một nhà sản xuất và 2 người tiêu dùng, 2 hàng đợi, một cho nhà sản xuất gửi ("SEND"), được người tiêu dùng tiêu thụ và ngược lại, người tiêu dùng xuất bản vào hàng đợi "RECV" và được nhà sản xuất tiêu thụ .

Bây giờ hãy nhớ đây là một ví dụ khá thô, vì nhà sản xuất trong trường hợp đó chỉ gửi một công việc (một số lượng nhiệm vụ ngẫu nhiên từ 0 đến 5) và chặn cho đến khi hoàn thành công việc. Một cách để vượt qua điều này sẽ là lưu trữ trong một bản đồ một id công việc và số lượng các nhiệm vụ, và mỗi lần kiểm tra rằng số lượng công việc được thực hiện được báo cáo cho mỗi id công việc.

Answer 2

Điều bạn đang cố gắng làm ngoài phạm vi của RabbitMQ. RabbitMQ là để gửi và nhận tin nhắn với khả năng xếp hàng chúng. Nó không thể theo dõi công việc của bạn cho bạn.

Bạn sẽ cần phải có dịch vụ "Bộ nhớ công việc". Bất cứ khi nào người tiêu dùng của bạn hoàn thành nhiệm vụ, nó sẽ cập nhật dịch vụ Job Storage, đánh dấu nhiệm vụ là xong. Dịch vụ lưu trữ công việc biết về số lượng công việc trong công việc và khi công việc cuối cùng được thực hiện, hoàn thành công việc như đã thành công. Có trong dịch vụ này, bạn cũng sẽ thực hiện tất cả các logic kinh doanh khác của bạn, chẳng hạn như khi nào để xử lý công việc là không thành công.