Cách quản lý yêu cầu đọc trong ứng dụng có nguồn gốc sự kiện

Question

Tôi được yêu cầu thực hiện một số khám phá trong tìm kiếm sự kiện. mục tiêu của tôi là tạo một lớp API nhỏ đáp ứng tất cả các hoạt động CRUD truyền thống. Bây giờ tôi đang sử dụng một gói có tên 'có nguồn gốc' và cố gắng chơi với nó (Sử dụng Nodejs).

Tuy nhiên, tôi đã nhận ra rằng sự kiện tìm nguồn cung ứng không hoàn toàn hữu ích khi nó được sử dụng một mình. thông thường, nó được kết hợp với CQRS.

Sự hiểu biết của tôi về CQRS là, khi giao diện người dùng gửi lệnh ghi tới máy chủ. ứng dụng thực hiện một số xác thực đối với dữ liệu. và lưu nó trong cửa hàng sự kiện (tôi đang sử dụng mongoDB), ví dụ: đây là cửa hàng sự kiện của tôi sẽ trông như thế nào:

{method:"createAccount",name:"user1", account:1} 
{method:"deposit",name:"user1",account: 1 , amount:100} 
{method:"deposit",name:"user1",account: 1 , amount:100} 
{method:"deposit",name:"user1",account: 1 , amount:100} 
{method:"withdraw",name:"user1",account1,amount:250} 

Nó chứa tất cả thông tin kiểm tra chứ không phải tình trạng cuối cùng. tuy nhiên, tôi bối rối làm thế nào tôi có thể xử lý các hoạt động đọc. nếu tôi muốn đọc số dư tài khoản. chính xác thì điều gì sẽ xảy ra? đây là câu hỏi của tôi:

1. Nếu chúng tôi không thể truy vấn sự kiện lưu trữ (cơ sở dữ liệu) trực tiếp cho hoạt động đọc, thì chúng ta nên truy vấn ở đâu? nó nên là một bộ nhớ đệm trong bộ nhớ?
2. Nếu chúng tôi truy vấn bộ nhớ. là trạng thái cuối cùng đã có hoặc tôi phải thực hiện thao tác phát lại (hoặc gấp trái) để tính kết quả. ví dụ: số dư của tài khoản 1 là 50.
3. Tôi đã tìm thấy một số blogger đã nói về 'đăng ký' hoặc 'phát'. chúng là gì và phát sóng cho ai?

Tôi sẽ thực sự đánh giá cao bất kỳ đề xuất nào và vui lòng sửa lỗi nếu hiểu biết của tôi sai.

Answer 1

Câu hỏi tuyệt vời Nick. Khái niệm bạn đang thiếu là 'Phép chiếu'. Khi một sự kiện được duy trì, bạn sẽ phát sự kiện. Bạn chiếu mã lắng nghe cho các sự kiện cụ thể và sau đó làm những việc như cập nhật và tạo ra một 'mô hình đọc'. Mô hình đọc là một phiên bản của trạng thái kết thúc (thường được duy trì nhưng có thể được thực hiện trong bộ nhớ).

Điều tuyệt vời là bạn có thể tối ưu hóa cao các mô hình đã đọc này để đọc. Nói lời tạm biệt với sự tham gia phức tạp và không hiệu quả, v.v.

Khi mô hình đọc không phải là nguồn gốc của sự thật và nó được thiết kế đặc biệt để đọc, bạn có thể sao chép dữ liệu trong đó. Chỉ cần chắc chắn rằng bạn quản lý nó khi nhận được sự kiện thích hợp.

Để biết thêm thông kiểm tra những bài viết này:

• Overview of a Typical CQRS and ES Application **
• How to Build a Master Details View when using CQRS and Event Sourcing
• Handling Concurrency Conflicts in a CQRS and Event Sourced system

Hy vọng bạn tìm thấy những hữu ích.

** Sơ đồ đề cập đến sự biến đổi hóa học, nơi nó nên nói về các phép chiếu.

Answer 2

Bạn có thể truy vấn cửa hàng sự kiện. Phương pháp truy vấn thực tế cụ thể cho mọi triển khai nhưng nói chung bạn có thể thăm dò ý kiến ​​cho các sự kiện hoặc đăng ký và được thông báo khi một sự kiện mới được duy trì.

Cửa hàng sự kiện chỉ là sự kiên trì đối với mặt viết đảm bảo tính nhất quán mạnh mẽ cho hoạt động ghi và tính nhất quán cuối cùng cho hoạt động đọc. Để "hiểu" một cái gì đó từ các sự kiện bạn cần để chiếu các sự kiện đó vào một mô hình đọc rồi truy vấn mô hình đọc. Ví dụ, bạn có thể có một mô hình đọc có chứa số dư hiện tại cho mỗi tài khoản như một bộ sưu tập MongoDB.