云消息队列 MQ消息队列的相关内容

文章 2022-05-29 来自：开发者社区

【消息队列系列6】RabbitMQ使用姿势

主要讲述RabbitMQ常用的使用姿势。基本使用姿势公共代码封装封装工厂类：public class RabbitUtil { public static ConnectionFactory getConnectionFactory() { //创建连接工程，下面给出的是默认的case ConnectionFactory factory = new Con...

文章 2022-05-29 来自：开发者社区

主要讲述RabbitMQ环境部署，以及简单的测试用例。前言我于4月份写过消息队列系列文章，当时只讲解了消息队列的选型，以及RabbitMQ、Kafka、RocketMQ的基本原理，现在选择RabbitMQ进行实战方面的讲解，其实主要是为了将之前的“债”给还上。RabbitMQ环境搭建因为我用的是Mac，所以直接可以参考官网：https://www.rabbitmq.com/install-hom....

文章 2022-05-28 来自：开发者社区

消息队列系列4 - 原理初探之RocketMQ

RocketMQ是一个纯Java、分布式、队列模型的开源消息中间件，前身是MetaQ，是阿里参考Kafka特点研发的一个队列模型的消息中间件，后开源给apache基金会成为了apache的顶级开源项目，具有高性能、高可靠、高实时、分布式特点。4.1 基本概念先对常用的词汇有个基本认识，相关词汇后面会再详细介绍：NameServer：一个功能齐全的服务器，其角色类似Dubbo中的Zookeeper....

文章 2022-05-28 来自：开发者社区

消息队列系列3 - 原理初探之RabbitMQ

RabbitMQ是使用Erlang语言来编写的，并且RabbitMQ是基于AMQP协议的。Erlang语言在数据交互方面性能优秀，有着和原生Socket一样的延迟，这也是RabbitMQ高性能的原因所在。可谓“人如其名”，RabbitMQ像兔子一样迅速。3.1 基本概念提到RabbitMQ，就不得不提AMQP协议。AMQP协议是具有现代特征的二进制协议。是一个提供统一消息服务的应用层标准高级消息....

文章 2022-05-22 来自：开发者社区

消息队列---RabbitMQ深入研究(含Springboot+RabbitMQ整合)（三）

3.4.2.代码案例：根据用户的通知设置去通知用户，设置接收Email的用户只接收Email，设置接收sms的用户只接收sms，设置两种通知类型都接收的则两种通知都有效。1、生产者声明交换机，指定topic类型：/** * 声明交换机 * param1：交换机名称 * param2:交换机类型四种交换机类型：direct、fanout、topic、headers */ channel...

文章 2022-05-22 来自：开发者社区

消息队列---RabbitMQ深入研究(含Springboot+RabbitMQ整合)（二）

3.工作模式RabbitMQ有以下几种工作模式：1、Work queues2、Publish/Subscribe3、Routing4、Topics5、Header6、RPC3.1.Work queueswork queues与入门程序相比，多了一个消费端，两个消费端共同消费同一个队列中的消息。应用场景：对于任务过重或任务较多情况使用工作队列可以提高任务处理的速度。测试：1、使用入门程序，启动....

文章 2022-05-22 来自：开发者社区

消息队列---RabbitMQ深入研究(含Springboot+RabbitMQ整合)（一）

1.介绍1.1.RabbitMQMQ全称为Message Queue，即消息队列， RabbitMQ是由erlang语言开发，基于AMQP（Advanced MessageQueue 高级消息队列协议）协议实现的消息队列，它是一种应用程序之间的通信方法，消息队列在分布式系统开发中应用非常广泛。RabbitMQ官方地址：添加链接描述开发中消息队列通常有如下应用场景：1、任务异步处理。将不需要同步处....

文章 2022-05-17 来自：开发者社区

springboot整合阿里云的消息队列MQ

1、概述公司使用的阿里云消息队列MQ服务，框架是springboot。做了一个demo，记录整合过程。2、步骤第一步：配置配置工作基本上就是按照阿里云消息队列MQ的文档所述那样，在控制台的消息队列MQ里面进行配置.快速入门概述这里有一点注意的点：我们的topic在授权的时候，可以授权给子账号的。（阿里的rocketmq 支持子账号）第二步：编码这里涉及到两个知识点：spring中bean的生命周....

文章 2022-05-16 来自：开发者社区

PHP+Laravel+RabbitMQ实现异步延迟消息队列(库存归还)

一、前言需求：电商秒杀场景中，如果用户下单10分钟未支付，需要进行库存归还本篇是用PHP+Laravel+RabbitMQ来实现异步延迟消息队列二、场景在电商项目中，当我们下单之后，一般需要 20 分钟之内或者 30 分钟之内付款，否则订单就会进入异常处理逻辑中，被取消，那么进入到异常处理逻辑中，就可以当成是一个延迟队列公司的会议预定系统，在会议预定成功后，会在会议开始前半小时通知所有预定该会议....

文章 2022-05-11 来自：开发者社区

消息队列之事务消息，RocketMQ 和 Kafka 是如何做的？（下）

就是来了波狸猫换太子，其实延时消息也是这么实现的，最终将换了皮的消息入盘。Broker 处理提交或者回滚消息的处理方法是 EndTransactionProcessor#processRequest，我们来看一看它做了什么操作。可以看到，如果是提交事务就是把皮再换回来写入真正的topic所属的队列中，供消费者消费，如果是回滚则是将半消息记录到一个 half_op 主题下，到时候后台服务扫描半消息....