2. PostgreSQL 在异步架构中的角色：作为消息队列、状态存储、事件溯源数据库的三种典型角色

在异步任务编排系统中，PostgreSQL 早已超越了传统关系型数据库的边界。凭借其强大的事务保证、灵活的数据类型（如 JSONB、UUID、ARRAY）以及 LISTEN/NOTIFY 机制，PostgreSQL 可以同时扮演三种截然不同的中间件角色。理解这三种角色的职责边界与实现模式，是构建可靠异步架构的基础。

2.1 角色一：消息队列（Message Queue）

PostgreSQL 作为消息队列的核心思路是：将任务记录存储在数据库表中，通过事务性写入和原子性状态变更来保证消息不丢失、不重复。相比专用消息队列（如 RabbitMQ、Kafka），这种方案牺牲了部分吞吐量，但换来了与业务数据严格一致的事务边界。

2.1.1 表结构设计

CREATE TABLE task_queue (
    id              BIGSERIAL PRIMARY KEY,
    task_type       VARCHAR(64) NOT NULL,
    payload         JSONB NOT NULL,
    status          VARCHAR(16) NOT NULL DEFAULT 'pending',
    created_at      TIMESTAMPTZ NOT NULL DEFAULT NOW(),
    scheduled_at    TIMESTAMPTZ NOT NULL DEFAULT NOW(),
    retry_count     INT NOT NULL DEFAULT 0,
    max_retries     INT NOT NULL DEFAULT 3,
    version         INT NOT NULL DEFAULT 1
);

CREATE INDEX idx_task_queue_status_scheduled
    ON task_queue (status, scheduled_at)
    WHERE status = 'pending';

2.1.2 生产者与消费者模式

2.1.3 基于 LISTEN/NOTIFY 的实时推送

PostgreSQL 内置的 LISTEN/NOTIFY 机制允许消费者进程订阅频道，当新任务插入时由触发器或应用层发送通知，避免频繁轮询。

-- 触发器示例
CREATE OR REPLACE FUNCTION notify_new_task()
RETURNS TRIGGER AS $$
BEGIN
    PERFORM pg_notify('task_channel', NEW.id::TEXT);
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER trg_task_insert
    AFTER INSERT ON task_queue
    FOR EACH ROW
    EXECUTE FUNCTION notify_new_task();

2.2 角色二：状态存储（State Store）

在异步工作流中，每个任务实例通常需要经历多个阶段（如：初始化 → 执行中 → 等待回调 → 完成/失败）。PostgreSQL 作为状态存储，负责持久化每个工作流的当前状态、上下文数据、版本号，并支持高并发下的乐观锁更新。

2.2.1 状态机表设计

CREATE TABLE workflow_state (
    workflow_id     UUID PRIMARY KEY,
    current_state   VARCHAR(64) NOT NULL,
    context         JSONB NOT NULL DEFAULT '{}',
    version         INT NOT NULL DEFAULT 1,
    created_at      TIMESTAMPTZ NOT NULL DEFAULT NOW(),
    updated_at      TIMESTAMPTZ NOT NULL DEFAULT NOW()
);

-- 乐观锁更新示例
UPDATE workflow_state
SET current_state = 'awaiting_callback',
    context = jsonb_set(context, '{callback_url}', '"https://..."'),
    version = version + 1,
    updated_at = NOW()
WHERE workflow_id = $1
  AND version = $2
RETURNING version;

2.2.2 状态存储的核心能力对比

2.3 角色三：事件溯源数据库（Event Sourcing Database）

事件溯源（Event Sourcing）是一种将状态变更记录为不可变事件流的架构模式。PostgreSQL 凭借其事务性追加写入、时间点恢复（PITR）和 JSONB 的灵活性，成为事件溯源数据库的理想载体。

2.3.1 事件表设计

CREATE TABLE event_store (
    event_id        UUID PRIMARY KEY DEFAULT gen_random_uuid(),
    aggregate_type  VARCHAR(64) NOT NULL,
    aggregate_id    VARCHAR(128) NOT NULL,
    event_type      VARCHAR(128) NOT NULL,
    event_data      JSONB NOT NULL,
    metadata        JSONB NOT NULL DEFAULT '{}',
    version         INT NOT NULL,
    created_at      TIMESTAMPTZ NOT NULL DEFAULT NOW(),

    UNIQUE (aggregate_type, aggregate_id, version)
);

CREATE INDEX idx_event_store_aggregate
    ON event_store (aggregate_type, aggregate_id, version);

2.3.2 事件追加与投影

2.3.3 与消息队列的协同

在异步任务编排中，事件溯源数据库通常与消息队列配合使用：事件写入 event_store 后，通过 NOTIFY 或触发器将事件 ID 推送到消息队列，由下游消费者异步更新投影。

-- 事件写入后触发通知
CREATE OR REPLACE FUNCTION notify_event_written()
RETURNS TRIGGER AS $$
BEGIN
    PERFORM pg_notify('event_channel', json_build_object(
        'event_id', NEW.event_id,
        'aggregate_type', NEW.aggregate_type,
        'aggregate_id', NEW.aggregate_id,
        'event_type', NEW.event_type
    )::TEXT);
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER trg_event_insert
    AFTER INSERT ON event_store
    FOR EACH ROW
    EXECUTE FUNCTION notify_event_written();

2.4 三种角色的协同关系

在实际的异步任务编排系统中，这三种角色并非互斥，而是互补共存的。一个典型的架构如下：

• 消息队列角色：负责任务的分发与调度，保证每个任务至少被消费一次。
• 状态存储角色：跟踪每个工作流实例的当前阶段，支持超时重试和人工干预。
• 事件溯源角色：记录所有状态变更的完整历史，提供审计、回放和调试能力。

三者共享同一个 PostgreSQL 实例（或集群），通过事务保证数据一致性，避免了跨系统的分布式事务难题。