pgmb

pig build pkg pgmb         # 构建 RPM / DEB 包

pig repo add pgsql -u          # 添加仓库并更新缓存

CREATE EXTENSION pgmb CASCADE;  -- 依赖: pg_cron, http

CREATE EXTENSION pgmb;  -- 需要 pg_cron 和 http 扩展

SELECT pgmb.worker(
    'order_processor',                     -- 工作进程名称
    'http://localhost:8080/process',       -- 端点 URL
    100                                    -- 每秒请求数限制
);
-- 返回: 工作进程 UUID

SELECT pgmb.create(
    'order_queue',                         -- 队列名称
    'order.*',                             -- 绑定键模式（支持 * 通配符）
    5,                                     -- 最大重试次数
    '550e8400-e29b-41d4-a716-446655440000' -- 工作进程 UUID
);
-- 返回: 队列 UUID

-- 简单消息
SELECT pgmb.send(
    gen_random_uuid(),
    'order.created',
    '{"order_id": 123, "amount": 45.67}'::jsonb
);

-- 带自定义头部
SELECT pgmb.send(
    gen_random_uuid(),
    'order.created',
    '{"order_id": 123}'::jsonb,
    '{"source": "web", "priority": "high"}'::jsonb
);

-- 延迟消息（按时间戳或秒数）
SELECT pgmb.send(
    gen_random_uuid(),
    'order.created',
    '{"order_id": 123}'::jsonb,
    '{}'::jsonb,
    now() + interval '10 minutes'
);

SELECT * FROM pgmb.workers;
SELECT * FROM pgmb.queues;
SELECT COUNT(*) FROM pgmb.order_queue WHERE acknoledge = false;
SELECT * FROM pgmb.order_dead_letter_queue;