在点对点模式中,消息的生产者和消费者之间是一对一的关系,这种模式可以实现简单的异步通信和任务分配,适用于需要处理一些不需要广播的任务,如任务调度、订单处理等。
2.订阅发布模式
在订阅发布模式中,生产者将消息发布到一个主题(Topic)中,消费者可以订阅该主题并接收其中的消息。
在这种模式中,消息队列会将消息广播给所有订阅了该主题的消费者,也就是说,一个消息可以被多个消费者同时处理。这种模式也称为主题模式(Topic Mode)。
如下图所示:
消息中间件有哪些下面是一些常见的消息中间件:
1.Apache Kafka
Kafka是一个分布式的高吞吐量的消息系统,最初由LinkedIn开发,现在是Apache软件基金会的顶级开源项目之一。
Kafka广泛应用于多种用例,例如实时数据流处理、日志聚合、监控、指标和日志收集、消息队列等。
Kafka的基本模型是生产者向主题(Topic)发布消息,消费者从主题订阅消息。
消息通过一个或多个Kafka集群的代理(Broker)进行传输和存储,如下图所示:
2.RabbitMQ