DBMS_PIPE 是Oracle提供的轻量级会话间单向内存通信机制，用于传递短小、低频、不保证送达的控制信号，如“刷新缓存”“暂停批处理”，不支持持久化、ACK、跨实例或大对象传输。
DBMS_PIPE 是什么，能用来干啥
它不是消息队列，也不是实时通知服务，而是一个轻量级的会话间单向通信通道，靠内存中的一块共享缓冲区运作。适合短小、低频、不保证送达的控制信号传递，比如“请刷新缓存”“暂停批处理”这类场景。别指望它传大对象或做事务协调——dbms_pipe 没有持久化、没有 ack、不支持跨实例，会话一断，管道里没读走的消息就丢了。
怎么创建和使用命名管道
必须显式调用 DBMS_PIPE.CREATE_PIPE 才能建一个命名管道；不调就直接 SEND_MESSAGE 会报 ORA-06502: PL/SQL: numeric or value error（实际是管道不存在，但错误不直观）。名字区分大小写，且全局唯一，建议加前缀避免冲突。
- 建管道：
DBMS_PIPE.CREATE_PIPE('my_app_signal', 8192, TRUE)—— 第二个参数是缓冲区字节上限，第三个TRUE表示私有（仅创建者可读），设FALSE才能被其他会话RECEIVE_MESSAGE - 发送端：先
PACK_MESSAGE（支持VARCHAR2、NUMBER、DATE等基本类型），再SEND_MESSAGE；每调一次只发一个“消息包”，不能拼接多次PACK后一次性发 - 接收端：必须匹配顺序调用
RECEIVE_MESSAGE→UNPACK_MESSAGE，中间不能穿插别的PACK操作，否则解包错位
为什么总是收不到消息或卡住
最常见原因是超时和权限。默认 RECEIVE_MESSAGE 超时是 0 秒（立即返回），收不到就直接报 ORA-06502 或返回 0（表示无消息）；设成 -1 才会阻塞等待，但得确保发送端真发了，否则一直挂起。
- 检查管道是否真为公用：
CREATE_PIPE('name', size, FALSE)，私有管道（TRUE）其他会话根本看不到 - 确认双方用的是完全相同的管道名，包括大小写和空格；
'signal'和'SIGNAL'是两个管道 - 接收端在
RECEIVE_MESSAGE前，别漏掉DBMS_PIPE.RESET_PACKAGE—— 如果之前异常退出过，内部状态可能混乱，导致后续收发失败 - 管道容量满时
SEND_MESSAGE会阻塞（除非设了超时），而默认缓冲区才 4KB，传长字符串极易满
DBMS_PIPE 在真实脚本里怎么写才不翻车
它不适合写进复杂业务逻辑主干，更适合做运维触发器或调试开关。例如 DBA 在另一个会话里发个指令让正在跑的存储过程提前退出，而不是等它自己扫完百万行。
- 发送端示例：
BEGIN DBMS_PIPE.PACK_MESSAGE('STOP_NOW'); DBMS_PIPE.SEND_MESSAGE('my_app_signal', 10); -- 10秒超时 END; - 接收端轮询示例（放在循环里）：
DECLARE r PLS_INTEGER; BEGIN r := DBMS_PIPE.RECEIVE_MESSAGE('my_app_signal', 1); -- 等1秒 IF r = 0 THEN DBMS_PIPE.UNPACK_MESSAGE(:msg); IF :msg = 'STOP_NOW' THEN RAISE_APPLICATION_ERROR(-20001, 'Stopped by pipe'); END IF; END IF; END; - 切记：每次
RECEIVE_MESSAGE成功后，必须紧接着UNPACK_MESSAGE，且变量类型要和发送时PACK的一致，否则ORA-06502会默默出现，不提示具体哪一步错了
管道名生命周期和实例绑定，数据库重启就清空；别把它当长期状态存储用。真正需要可靠通信，该上 Advanced Queuing 或外部消息队列。
