消息队列5种模式

(一) 简单模式

　　 特点: 一个消费者

　　

(二) 工作模式

　　特点:多个消费者,每个消费者处理的信息是不一样的,用在高并发.

　　

(三) 订阅模式

　　特点:每个消费者得到的消息是一样的

　　

(四) 路由模式

　　说明:路由模式是发布订阅模式的升级,通过定义不用的路由key使得程序将消息发送到不同的队列中

　　 每个消费者得到信息不一样的,信息有routingkey,消费者执行select where routingkey=mobile

　　

(五) 主题模式

　　说明:可以通过路由key将消息发送到一类相同的key中 使用通配符实现

　　 消息分类，消费者取消息时用mobile.*能取到routingKey为mobile.cart和mobile.order的信息。

　　


　　　　　　　　　　要勇敢,易安静

原文地址：https://www.cnblogs.com/misscai/p/9989276.html

时间： 2024-08-30 07:01:29

消息队列5种模式的相关文章

JMS消息队列ActiveMQ(点对点模式)

生产者(producer)->消息队列(message queue) package com.java1234.activemq; import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.Destination; import javax.jms.JMSException; import javax.jms.MessageProducer; import javax.jms.Session

RABBIT MQ 消息队列的工作模式

1.RABBIT MQ的工作模式https://blog.csdn.net/fysuccess/article/details/70265889 2.ACTIVE MQ的订阅模式3.https://blog.csdn.net/qq_26504875/article/details/51802316 原文地址:http://blog.51cto.com/a1liujin/2094130

进程-IPC 共享内存和消息队列 (三)

详见:https://github.com/ZhangzheBJUT/linux/blob/master/IPC(%E4%B8%89).md 五 共享内存 5.1. 共享内存简介 共享内存指多个进程共享同一块物理内存,它只能用于同一台机器上的两个进程之间的通信.在进程的逻辑地址空间中有一段地址范围是用来进行内存映射使用的,该段逻辑地址空间可以映射到共享的物理内存地址上(进程空间介绍:http://blog.csdn.net/zhangzhebjut/article/details/3906025

MQ的几种模式

MQ的几种模式: Producer消息产生者,红色队列,Customer消息消费者,蓝色交换机exchange 简单模式:消息产生者产生消息,消息的消费者进行消费 工作模式:消息消费产生消息,将消息发送到消息队列中,这是竞争,消费者1和消费者2都监听消息队列,当队列中有消息,一起来抢消息.谁抢到谁处理. 消息发布和订阅:消息产生者产生消息,将消息发送到交换机中.多个消息队列绑定到交换机上.交换机将消息发送到多个队列中.消费者1监听自己的队列,如果有消息就进行消费.消费者2监听自己的队列,如果有消

消息队列属性及常见消息队列介绍

什么是消息队列?消息队列是在消息的传输过程中保存消息的容器,用于接收消息并以文件的方式存储,一个队列的消息可以同时被多个消息消费者消费.分布式消息服务DMS则是分布式的队列系统,消息队列中的消息分布存储,且每条消息存储多个副本,以实现高可用性,如下图所示. 一般来说,消息队列具有如下属性: 消息顺序普通队列支持"分区有序"和"全局队列"两种模式,ActiveMQ队列和Kafka队列均为分区有序. 分区有序的队列通过分布式处理,支持更高的并发,但由于队列的分布式特性,

消息队列的简单理解

消息队列,MessageQueue,简称MQ. 消息队列有什么用? 解耦 .削峰 .异步 解耦:将消息写入消息队列,需要消息的系统自己从消息队列中订阅,从而系统不需要做任何修改. 异步:将消息写入消息队列,非必要的业务逻辑以异步的方式运行,加快响应速度.削峰:系统慢慢的按照数据库能处理的并发量,从消息队列中慢慢拉取消息. 消息队列的通讯模式 1) 点对点通讯:点对点方式是最为传统和常见的通讯方式,它支持一对一.一对多.多对多.多对一等多种配置方式,支持树状.网状等多种拓扑结构. 2) 多点广播:

消息队列——kafka（待续）

原文:再过半小时,你就能明白kafka的工作原理了 会出现什么情况呢? 1.为了这个女朋友,我请假回去拿(老板不批). 2.小哥一直在你楼下等(小哥还有其他的快递要送). 3.周末再送(显然等不及). 4.这个女朋友我不要了(绝对不可能)! 在上面例子中,“快递小哥”和“买女朋友的我”就是需要交互的两个系统,小芳便利店就是我们本文要讲的-“消息中间件”.总结下来小芳便利店(消息中间件)出现后有如下好处: 1. 解耦 快递小哥手上有很多快递需要送,他每次都需要先电话一一确认收货人是否有空.哪个时间

系统学习消息队列分享（二） 为什么需要消息队列？

消息队列是最古老的中间件之一,从系统之间有通信需求开始,就自然产生了消息队列.但是给消息队列下一个准确的定义却不太容易.我们知道,消息队列的主要功能就是收发消息,但是它的作用不仅仅只是解决应用之间的通信问题这么简单. 我们举个例子说明一下消息队列的作用.话说小袁是一家巧克力作坊的老板,生产出美味的巧克力需要三道工序:首先将可可豆磨成可可粉,然后将可可粉加热并加入糖变成巧克力浆,最后将巧克力浆灌入模具,撒上坚果碎,冷却后就是成品巧克力了. 最开始的时候,每次研磨出一桶可可粉后,工人就会把这桶可可粉

消息队列rabbitmq的五种工作模式（go语言版本）

前言:如果你对rabbitmq基本概念都不懂,可以移步此篇博文查阅消息队列RabbitMQ 一.单发单收 二.工作队列Work Queue 三.发布/订阅 Publish/Subscribe 四.路由Routing 五.Topic类型的exchange 六.rabbitmq部分封装代码及装备工作 一.单发单收 在下图中,“ P”是我们的生产者,“ C”是我们的消费者.中间的框是一个队列-RabbitMQ代表使用者保留的消息缓冲区. 单发单收模式下:一发一收 发送端只需要创建队列,然后向队列发送消