是什么?

消息中间件。可以在分布式系统的不同服务之间进行消息的发送接收

它的出现解决什么问题?

可以让系统解耦
比如,使用消息中间件,某一个服务,可能依赖了其他好几个服务。比如课程里面的运营商后台依赖了4个服务,那不用mq就和4个服务耦合,用了mq,就只和1个mq耦合。参考下图:

 

同类型技术有哪些,如何选择?

RabbitMQ,Kafka ,ZeroMQ,MetaMQ,RocketMQ

1. 对比

关于消息队列的使用----ActiveMQ,RabbitMQ,ZeroMQ,Kafka,MetaMQ,RocketMQ
MQ选型对比RabbitMQ RocketMQ ActiveMQ Kafka
Kafka、RabbitMQ、RocketMQ消息中间件的对比—— 消息发送性能-转自阿里中间件
开源软件成熟度评测报告-分布式消息中间件

2. 结论

除了知道ActiveMQ,有必要知道Kafka的使用。需要Kafka资料的同学单独联系我。

大概介绍?

1. 1个标准

Jms标准,JMS(Java Messaging Service)是Java官方定义的技术规范
JMS 定义了五种不同的消息:

消息类型消息描述备注
TextMessage字符串常用
MapMessage值对 
ObjectMessage序列化的 Java 对象 
BytesMessage字节的数据流 
StreamMessage原始值的数据流 

2. 两个角色

Producer(生产者):发消息
Consumer(消费者):收消息

3. 两种消息模式

一对一消息(私聊),Queue消息,同时一个收。

 

一对多消息(群发),Topic消息,同时可以多个收。

 

具体使用?

1. 安装mq服务器

简单,就一个tar包。

2. 客户端使用spring-jms

通过maven添加jar包。
创建applicationContext-jms-producer-queue.xml,配置connectionFactory消息类型jmsTemplate(发消息)

创建applicationContext-jms-consumer-queue.xml,配置connectionFactory消息类型messageListener(收消息)

发送:

接收:

实际项目应用场景?

最重要,告知面试官实际使用情况

删除商品-》发送消息-》接收消息-》删除索引。
商品状态更新-》发送消息-》接收消息-》导入索引库。

拓展说说?

消息会不会丢?
消息丢了怎么办?
消息队列的其他特性:异步处理、数据同步、流量削峰、缓冲、限流等。

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐