CentOS 消息队列工作原理
在 CentOS 上，消息队列主要有两条技术路线：一是内核提供的 System V 消息队列 与 POSIX 消息队列（进程间通信 IPC），二是用户态运行的 AMQP 消息中间件（如 RabbitMQ）。前者通过内核对象在本地进程间传递带类型的消息，后者通过网络在分布式系统间解耦与异步通信。
System V 消息队列工作原理
- 存储与生命周期：消息在内核中以“消息链表”形式存在，由 消息队列标识符 msqid 标识；它是随内核持续的，只有内核重启或显式删除队列时才会消失。内核维护全局结构 struct ipc_ids msg_ids 来管理所有队列；每个队列在内核侧对应 struct msg_queue，用户侧通过 struct msqid_ds 查询与控制属性（如当前消息数、权限、最近发送/接收时间等）。
- 核心接口与流程：
- 用 ftok() 生成键值或用 IPC_PRIVATE 创建私有队列；
- 用 msgget(key, msgflg) 获取或创建队列，返回 msqid；
- 发送用 msgsnd(msqid, &msgp, msgsz, msgflg)，消息必须包含正的长整型类型 mtype，可设 IPC_NOWAIT 非阻塞；
- 接收用 msgrcv(msqid, &msgp, msgsz, type, msgflg)，按类型读取：type=0 取队首；type>0 取指定类型首个；type<0 取类型值≤|type|且最小者；可设 IPC_NOWAIT、IPC_EXCEPT、IPC_NOERROR；
- 管理用 msgctl(msqid, cmd, &buf)，支持 IPC_STAT/SET/…。
- 典型特性与差异：支持按类型随机访问（不必严格 FIFO），发送与接收可异步进行；与管道相比，队列可在无接收者时仍写入，且不依赖打开/关闭同步；消息内容由用户自定义，内核不解释载荷。POSIX 消息队列与之类似，但使用 mq_open/mq_send/mq_receive 等接口，并支持通过 mq_attr 配置 mq_maxmsg/mq_msgsize 等属性。
RabbitMQ 在 CentOS 的工作机制
- 基本角色与链路：以 **Broker（RabbitMQ 服务）**为中心，包含 Exchange（交换机）、**Queue（队列）**与 Binding（绑定）；Producer 将消息发往 Exchange 并携带 Routing Key，Exchange 按绑定与路由规则投递到 Queue，Consumer 从 Queue 拉取并处理消息。
- 交换机类型与路由：
- Direct Exchange：精确匹配 Routing Key = Binding Key；
- Topic Exchange：按模式匹配，“*”匹配1个词，“#”匹配0个或多个词；
- Fanout Exchange：忽略路由键，广播到所有绑定队列。
- 可靠性与运维要点：支持消息确认 ACK、持久化（队列/消息）、预取 prefetch 控制消费节奏；通过 虚拟主机 vhost 做多租隔离；常见部署为单节点或集群/镜像队列以提升可用性；管理端可通过 rabbitmq-plugins enable rabbitmq_management 启用 Web 控制台。
如何选择
- 需要本地进程解耦、少量数据、按类型选择性接收：优先用 System V/POSIX 消息队列（轻量、内核态、无需额外服务）。
- 跨主机、跨语言、需要高可用与丰富路由、削峰填谷：选择 RabbitMQ 等 AMQP 中间件（网络透明、可持久化、可监控与集群）。