rabbitmq 的新特性 Streaming 可以用在什么业务上？

Question

https://www.rabbitmq.com/

You run a video platform. When a user uploads a new video, you have multiple tasks to complete when the video is safely stored: run some post-upload analysis, transcode lower quality copies of the video, notify other users subscribed to the author's creations, and so on.
您运营一个视频平台。当用户上传新视频时，在安全存储视频后您需要完成多项任务：运行一些上传后分析、对视频的低质量副本进行转码、通知订阅作者作品的其他用户等等。

The upload service appends “New video” events to a RabbitMQ stream. Multiple backend applications can subscribe to that stream and read new events independently of each other. Users must be notified right away, but the post-upload analysis can wait and run once a day.
上传服务将“新视频”事件附加到 RabbitMQ 流。多个后端应用程序可以订阅该流并彼此独立地读取新事件。必须立即通知用户，但上传后分析可以等待并每天运行一次。

看了上面 rabbitmq 的介绍，感觉这个 Streaming 就是一个 topic 交换机？

新的 Streaming 能实现旧版本 rabbitmq 不能实现的某些功能吗？

Answer 1

RabbitMQ 的 Streaming 插件确实为消息队列提供了新的特性和使用场景。针对您提出的问题：

RabbitMQ 的 Streaming 可以用在什么业务上？

RabbitMQ Streaming 插件特别适用于需要处理大量实时事件流、且这些事件需要被多个独立消费者处理的业务场景。它非常适合微服务架构，其中不同的服务需要独立地消费相同的事件流，并根据自己的业务逻辑进行处理。在您给出的例子中，视频平台就非常适合使用 RabbitMQ Streaming。当有新的视频上传时，可以通过 Streaming 插件发布事件，然后多个后端服务（如分析服务、转码服务、通知服务等）可以独立地订阅并处理这些事件。

新的 Streaming 能实现旧版本 rabbitmq 不能实现的某些功能吗？

是的，RabbitMQ Streaming 相对于旧版本的 RabbitMQ 提供了一些新的功能和优势：

1. 持久化流：Streaming 插件支持将消息流持久化到磁盘，从而确保在系统故障或重启后消息不会丢失。
2. 消费者组：Streaming 允许创建消费者组，这样多个消费者可以共同处理同一个消息流，实现消息的负载均衡和容错。
3. 独立的消息确认：每个消费者可以独立地确认自己处理的消息，这使得消息的处理更加灵活和可靠。
4. 简单的API和集成：Streaming 插件提供了一个简洁直观的API，使得与其他系统和服务的集成变得更加容易。

虽然 Streaming 插件在某些方面与 RabbitMQ 的 Topic 交换机有相似之处（例如，它们都允许将消息发布到一个或多个队列以供消费者处理），但 Streaming 插件提供了更高级别的抽象和功能，特别是针对处理大量实时事件流的场景。

需要注意的是，RabbitMQ Streaming 并不是要完全替代 RabbitMQ 的其他功能或插件，而是为特定使用场景提供了额外的选项和优势。在选择是否使用 Streaming 插件时，需要根据具体的业务需求和技术栈进行权衡和决策。