面试题：进程管理之消息队列在分布式进程通信中的基础应用

消息发送：
- 发送进程将需要传递的消息按照一定的格式（如包含消息体、消息类型等）封装好，然后通过消息队列提供的接口（如在操作系统层面可能是系统调用，在应用层面可能是SDK方法）将消息发送到指定的消息队列中。例如在RabbitMQ中，生产者使用AMQP协议相关的客户端库将消息发布到指定的队列。
消息存储：
- 消息队列系统接收到消息后，会将其存储在相应的存储介质（如内存、磁盘等）中。对于持久化队列，消息会被写入磁盘以保证可靠性；非持久化队列则可能只存储在内存中以提高性能。比如Kafka使用日志文件将消息持久化到磁盘上。
消息接收：
- 接收进程通过消息队列提供的接口，从消息队列中获取消息。通常可以设置一些参数，如是否阻塞等待新消息，每次获取消息的数量等。例如在ActiveMQ中，消费者可以通过订阅队列的方式，从队列中拉取消息进行处理。

解耦：
- 发送方和接收方不需要直接依赖对方的接口、状态或可用性。例如在电商系统中，下单模块（发送方）将订单消息发送到消息队列，库存更新模块（接收方）从消息队列获取消息进行库存处理，即使库存更新模块暂时不可用，下单模块依然可以正常发送订单消息，不会影响整个下单流程。
异步处理：
- 发送方发送消息后不需要等待接收方处理完成，可以继续执行其他任务。比如在一个图片上传并处理的系统中，用户上传图片后，上传模块将图片处理任务消息发送到消息队列，然后立即返回给用户上传成功的响应，图片处理模块在后台从消息队列中获取任务并进行处理，提高了系统的响应速度。
流量削峰：
- 当有大量请求瞬间到达时，消息队列可以作为缓冲区存储这些请求，避免后端服务因压力过大而崩溃。例如在秒杀活动中，大量用户的请求涌入，消息队列可以接收这些请求消息，然后后端服务按照一定的速率从消息队列中获取消息进行处理，防止数据库等后端资源被压垮。
可扩展性：
- 可以方便地增加或减少接收方的实例数量来应对不同的业务负载。例如在一个日志处理系统中，随着业务量的增长，产生的日志量增多，可以增加日志处理的消费者实例，从消息队列中并行获取日志消息进行处理。

系统复杂度增加：
- 引入消息队列后，需要额外关注消息队列的部署、维护、监控等问题。例如要确保消息队列的高可用性，就需要考虑集群部署、数据备份等；同时，消息队列本身也可能出现故障，如网络问题导致消息发送或接收失败，增加了系统排查和解决问题的难度。
数据一致性问题：
- 由于消息是异步处理的，可能会出现消息处理顺序与发送顺序不一致的情况，这对于一些对数据一致性要求严格的业务场景可能会产生问题。比如在银行转账业务中，如果涉及多个账户的资金变动消息，消息处理顺序错误可能导致账户金额出现差错。
性能开销：
- 虽然消息队列在一定程度上可以提高系统整体性能，但消息的封装、发送、存储和接收都存在一定的性能开销。尤其是对于一些对性能要求极高、处理非常简单快速的场景，使用消息队列可能会带来不必要的性能损耗。例如在一个简单的本地进程间的快速数据传递场景中，消息队列的复杂机制反而不如直接的函数调用高效。

知识考点