java分布式面试题之消息队列ActiveMQ部分，java反序列化原理

在互联网应用中&＃xff0c;基本都会有用户注册的功能。在注册的同时&＃xff0c;我们会做出如下操作&＃xff1a;

• 收集用户录入信息&＃xff0c;保存到数据库

• 向用户的手机或邮箱发送验证码

如果是传统的集中式架构&＃xff0c;实现这个功能非常简单&＃xff1a;开启一个本地事务&＃xff0c;往本地数据库中插入一条用户数据&＃xff0c;发送验证码&＃xff0c;提交事物。但是在分布式架构中&＃xff0c;用户和发送验证码是两个独立的服务&＃xff0c;它们都有各自的数据库&＃xff0c;那么就不能通过本地事物保证操作的原子性。这时我们就需要用到ActiveMQ&＃xff08;消息队列&＃xff09;来为我们实现这个需求。在用户进行注册操作的时候&＃xff0c;我们为该操作创建一条消息&＃xff0c;当用户信息保存成功时&＃xff0c;把这条消息发送到消息队列。验证码系统会监听消息&＃xff0c;一旦接受到消息&＃xff0c;就会给该用户发送验证码。

2、如何防止消息重复发送&＃xff1f;

解决方法很简单&＃xff1a;增加消息状态表。通俗来说就是一个账本&＃xff0c;用来记录消息的处理状态&＃xff0c;每次处理消息之前&＃xff0c;都去状态表中查询一次。如果已经有相同的消息存在&＃xff0c;那么不处理&＃xff0c;可以防止重复发送。

3、了解哪些消息队列&＃xff1f;

ActiveMQ、RabbitMQ、kafka。

RabbitMQ是使用Erlang编写的一个开源的消息队列&＃xff0c;本身支持很多的协议&＃xff1a;AMQP&＃xff0c;XMPP&＃xff0c;SMTP&＃xff0c;STOMP&＃xff0c;也正因如此&＃xff0c;它非常重量级&＃xff0c;更适合于企业级的开发。同时实现了Broker构架&＃xff0c;这意味着消息在发送给客户端时先在中心队列排队。对路由&＃xff0c;负载均衡或者数据

《一线大厂Java面试题解析&＃43;后端开发学习笔记&＃43;最新架构讲解视频&＃43;实战项目源码讲义》

【docs.qq.com/doc/DSmxTbFJ1cmN1R2dB】 完整内容开源分享

持久化都有很好的支持。

ActiveMQ是Apache下的一个子项目。类似于ZeroMQ&＃xff0c;它能够以代理人和点对点的技术实现队列。同时类似于RabbitMQ&＃xff0c;它少量代码就可以高效地实现高级应用场景。

Kafka是Apache下的一个子项目&＃xff0c;是一个高性能跨语言分布式发布/订阅消息队列系统&＃xff0c;而Jafka是在Kafka之上孵化而来的&＃xff0c;即Kafka的一个升级版。具有以下特性&＃xff1a;快速持久化&＃xff0c;可以在O(1)的系统开销下进行消息持久化&＃xff1b;高吞吐&＃xff0c;在一台普通的服务器上既可以达到10W/s的吞吐速率&＃xff1b;完全的分布式系统&＃xff0c;Broker、Producer、Consumer都原生自动支持分布式&＃xff0c;自动实现负载均衡&＃xff1b;支持Hadoop数据并行加载&＃xff0c;对于像Hadoop的一样的日志数据和离线分析系统&＃xff0c;但又要求实时处理的限制&＃xff0c;这是一个可行的解决方案。Kafka通过Hadoop的并行加载机制统一了在线和离线的消息处理。Apache Kafka相对于ActiveMQ是一个非常轻量级的消息系统&＃xff0c;除了性能非常好之外&＃xff0c;还是一个工作良好的分布式系统。

MQ选型对比图