如何统计FIFO/命名管道的消息写入数量及触发读取逻辑？

嘿，针对你关于命名管道（FIFO）的两个问题，我来分享下实际开发中的可行思路——毕竟这俩需求在原生FIFO里都没有直接的系统调用支持，得自己做些额外处理：

1. 如何确定FIFO上已写入的消息数量？ #

首先得明确：原生FIFO本质是字节流管道，系统不会帮你划分“消息”的边界，所以没有直接的接口能返回“已写入的消息条数”。具体怎么处理分几种情况：

• 如果读写两端的代码都是你可控的：
  • 可以给每条消息约定一个明确的分隔符（比如换行符\n，或者自定义的特殊字节序列如0x00），写入时每条消息末尾加上分隔符。读取的时候，你只能边读边按分隔符拆分内容，同时统计条数——没法提前知道管道里攒了多少条，只能实时解析计数。
  • 要是每条消息的字节长度是固定的，你可以先用ioctl(FIONREAD)获取管道当前的未读字节数，然后除以单条消息的长度，就能算出消息数量。但这个方法只适用于消息长度完全一致的场景。
• 如果读写端没法统一格式，或者你需要提前获取计数：
  • 可以借助共享内存或本地文件来维护计数器。写入进程每成功写入一条消息，就把计数器加1；读取进程则读取这个计数器的值。但一定要加同步机制（比如互斥锁、信号量），避免多个写入/读取进程同时操作计数器导致竞态问题。

2. 需监控命名管道，当从其他进程接收满5条消息时读取其内容，是否存在统计管道消息写入次数的方法？ #

同样，原生FIFO没有自带的消息计数功能，得自己实现，这里有几个常用方案：

• 约定消息格式+读取端实时计数
  这是最常用的方式：写入端每条消息末尾加分隔符，读取端持续监听管道（阻塞或非阻塞模式都行），每解析出一条完整消息就把本地计数器加1。当计数器达到5时，就可以批量处理这5条消息（或者一次性读取管道内的所有内容再拆分）。注意如果用阻塞模式，读取端会一直等待数据；非阻塞模式要处理EAGAIN错误，避免空轮询。
• 共享内存计数器+同步通知
  用共享内存存一个计数器，写入进程每写一条消息就原子性地递增计数器，同时用信号量或者条件变量通知读取端。读取端等待计数器达到5时，就去读取管道内容，读完后重置计数器。这种方式适合多写入进程的场景，能保证计数准确，但要注意同步逻辑的正确性，避免死锁。
• 结合inotify监控写入事件（辅助手段）
  你可以用inotify监控FIFO的IN_MODIFY事件，这样能知道什么时候有新数据写入，但inotify只能告诉你“有写入”，没法直接知道是几条消息，所以还是得结合消息分隔符来解析计数，本质是减少读取端的空轮询次数。

另外要提个小细节：如果写入的消息字节数小于系统的PIPE_BUF值（一般是4096字节），系统会保证写入操作是原子的，不会被其他写入进程的内容打断，这样读取时拆分消息会更可靠。

内容的提问来源于stack exchange，提问作者Ju Bc