Thông tin hàng đợi Hazelcast

Question

Tôi hiện đang viết một hệ thống phân tán bằng cách sử dụng hazelcast. Tôi có một vài câu hỏi liên quan đến Hàng đợi được triển khai bằng cách sử dụng hazelcast.

1. Cách tốt nhất để xử lý dữ liệu từ Hàng đợi là gì? Tôi hiện đang có chủ đề trên mỗi "nút" đọc ra khỏi hàng đợi ngăn chặn xử lý dữ liệu. Đây có phải là chính xác hoặc là có một số lớp tôi không nhận thức được rằng sẽ chăm sóc này như JMS hoặc messageListener?
2. Tôi thấy có cài đặt thời gian phát trực tiếp sẽ xóa mục nhập khỏi Hàng đợi sau khi hết hạn. Câu hỏi của tôi là ... có cách nào để phát hiện việc xóa một mục hết hạn khỏi Hàng đợi không? Tôi biết có người nghe nhưng điều này không giúp đỡ vì điều này được bắn vào tất cả các "nút" và không chỉ là một. Tôi đang tìm cách thực hiện mã cho mỗi thư đã hết hạn (tương tự như một hàng đợi chữ cái chết).

Bất kỳ đầu vào hoặc lời khuyên nào về vấn đề này sẽ được đánh giá cao.

Cảm ơn

Answer 1

1. Không có cách nào khác vào lúc này. Vì vậy, bạn sẽ có các chủ đề của bạn trên mỗi nút gọi queue.take(). Nhóm Hazelcast đang có kế hoạch thêm IQueue.addQueueConsumer (QueueConsumer) sẽ hoạt động tương tự như JMS MessageListener

2. Bạn nói đúng. Thêm người nghe không phải là cách tốt để làm điều đó vì nó hoạt động rất tốn kém. Bạn có thể muốn tạo sự cố cho số này tại http://code.google.com/p/hazelcast/issues. Nó là chắc chắn tốt đẹp để có tính năng.

-talip @ Hazelcast