Ordering Service (hierachain/consensus/ordering/*)

Tổng quan

Ordering Service là thành phần trung tâm trong kiến trúc đồng thuận của HieraChain, chịu trách nhiệm nhận các sự kiện (Events) thô, sắp xếp chúng theo một thứ tự duy nhất và đóng thành khối (Blocks). Đây là cơ chế Crash Fault Tolerance (CFT), đảm bảo hệ thống vẫn hoạt động ổn định khi một số nút bị sập.

Kiến trúc Hệ thống

Ordering Service được thiết kế theo mô hình Facade, điều phối nhiều thành phần chuyên biệt:

Luồng xử lý Sự kiện (Ordering Pipeline)

graph TD
    A[Client Submit Event] --> B[Transaction Journal]
    B --> C[Event Pool]
    C --> D[Event Certifier]
    D -- Valid --> E[Ordering Processor]
    E --> F[Block Builder]
    F -- Batch Full / Timeout --> G[Block Creation]
    G --> H[Commit to Storage]
    H --> I[Notify Listeners]

Các tính năng cốt lõi

1. Persistence & Durability (Tính bền vững)

Trước khi đưa vào hàng đợi xử lý, mọi sự kiện đều được ghi vào Transaction Journal. Nếu service bị dừng đột ngột, module Recovery sẽ đọc lại Journal để tái thiết lập trạng thái, đảm bảo không có dữ liệu nào bị mất.

2. Batching Strategy

Để tối ưu hiệu năng, Ordering Service không đóng khối cho từng sự kiện đơn lẻ mà sử dụng chiến lược gom nhóm: * batch_size: Số lượng sự kiện tối đa trong một khối (Mặc định: 100). * batch_timeout: Thời gian tối đa chờ đợi trước khi buộc phải đóng khối (Mặc định: 2.0 giây).

3. Event Certification

Module Certifier tích hợp chặt chẽ với hệ thống Security để kiểm tra: * Định dạng dữ liệu (Schema Validation). * Chữ ký số của người gửi (Identity Verification). * Quyền truy cập vào kênh (Policy Enforcement).

Ví dụ sử dụng

from hierachain.consensus.ordering.service import OrderingService

# Khởi tạo với cấu hình doanh nghiệp
config = {
    "batch_size": 200,
    "batch_timeout": 1.5,
    "storage_dir": "/data/ordering"
}

service = OrderingService(config=config)

# Gửi sự kiện vào hàng đợi
event_id = service.receive_event(
    event_data={"item": "container_45", "status": "shipped"},
    channel_id="logistics_chain",
    submitter_org="ORG_SUPPLY"
)

Liên quan

• Hệ thống ghi nhật ký (Journal)
• Cấu trúc Khối (Block)
• Đồng thuận BFT