rocketmq概览
【1.0】RocketMQ初识
【一】什么是RocketMQ RocketMQ 是一款功能强大的分布式消息系统，广泛应用于多个领域，包括异步通信解耦、企业解决方案、金融支付、电信、电子商务、快递物流、广告营销、社交、即时通信、移动应用、手游、视频、物联网、车联网等。 RocketMQ 源码地址：https://github.com ......
【RocketMQ】事务实现原理总结
RocketMQ事务的使用场景 单体架构下的事务 在单体系统的开发过程中，假如某个场景下需要对数据库的多张表进行操作，为了保证数据的一致性，一般会使用事务，将所有的操作全部提交或者在出错的时候全部回滚。以创建订单为例，假设下单后需要做两个操作： 在订单表生成订单 在积分表增加本次订单增加的积分记录 ......
RocketMq发送消息之事务消息
概述 事务消息共有三种状态，提交状态、回滚状态、中间状态： TransactionStatus.CommitTransaction: 提交事务，它允许消费者消费此消息。 TransactionStatus.RollbackTransaction: 回滚事务，它代表该消息将被删除，不允许被消费。 Tr ......
RocketMq发送消息之过滤消息
过滤消息概述 在大多数情况下，TAG是一个简单而有用的设计，其可以来选择您想要的消息。例如： // 定义一个group1的消费者组 DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("group1"); // 订阅 TOPIC 主题 ......
深入理解RocketMQ 广播消费
这篇文章我们聊聊广播消费，因为广播消费在某些场景下真的有奇效。笔者会从基础概念、实现机制、实战案例、注意事项四个方面一一展开，希望能帮助到大家。 1 基础概念 RocketMQ 支持两种消息模式：集群消费（ Clustering ）和广播消费（ Broadcasting ）。 集群消费： 同一 To ......
RocketMq发送消息之批量消息
概述 批量发送消息能显著提高传递小消息的性能。限制是这些批量消息应该有相同的topic，相同的waitStoreMsgOK，而且不能是延时消息。此外，这一批消息的总大小不应超过4MB 发送批量消息 如果您每次只发送不超过4MB的消息，则很容易使用批处理，样例如下： String topic = "B ......
RocketMq发送消息之延迟消息
延迟消息 比如电商里，提交了一个订单就可以发送一个延时消息，1h后去检查这个订单的状态，如果还是未付款就取消订单释放库存。 使用限制 对比于rabbitmq中的延迟消息来说，rockermq并不支持任意时间的延迟，需要设置几个固定的延时等级，从1s到2h分别对应着等级1到18级 // org/apa ......
RocketMQ发送消息之同步异步单向
官网教程：https://rocketmq.apache.org/zh/docs/quickStart/01quickstart 基于双主双从异步方式开启的前提下，在maven项目中引入下列依赖 <dependency> <groupId>org.apache.rocketmq</groupId> ......
基于开源模型搭建实时人脸识别系统（三）：人脸关键点、对齐模型概览与模型选型
续 基于开源模型搭建实时人脸识别系统（二）：人脸检测概览与模型选型_CodingInCV的博客-CSDN博客 摘要 人脸对齐（face alignment）或者人脸关键点（face alignment）是定位人脸上的关键点，是很多基于人脸的任务的前置步骤，比如人脸识别、表情分析、人脸变装（makeu ......
【专题】2022中国奢侈品与时尚洞察概览报告PDF合集分享（附原数据表）
原文链接：https://tecdat.cn/?p=33672 2022年，中国的奢侈品消费市场一直处于不断变化和挑战之中，但随着2023年的到来，中国正在全面复苏，市场也充满了机遇和想象空间。自2019年以来，奢侈品品牌一直在中国尝试本地化和数字化策略，将中国的奢侈品消费者与国内市场更加紧密地联系 ......
【专题】2023中国消费市场洞察概览：奢侈品与时尚报告PDF合集分享（附原数据表）
原文链接：https://tecdat.cn/?p=33672 2022年，中国的奢侈品消费市场一直处于不断变化和挑战之中，但随着2023年的到来，中国正在全面复苏，市场也充满了机遇和想象空间。自2019年以来，奢侈品品牌一直在中国尝试本地化和数字化策略，将中国的奢侈品消费者与国内市场更加紧密地联系 ......
RocketMQ源码(六)：RocketMQ消费者启动流程
RocketMQ通过Consumer消费消息，可并发和顺序的处理消息，这里以并发消费普通消息为例，分析消息下佛诶的整体流程。Consumer的示例代码如下： 1 import com.snails.rmq.common.RMQConstant; 2 import org.apache.rocketm ......
Ansible专栏文章之二：初入Ansible世界，用法概览和初体验
回到：Ansible系列文章 各位读者，请您：由于Ansible使用Jinja2模板，它的模板语法{% raw %} {{}} {% endraw %}和{% raw %} {%%} {% endraw %}和我博客系统hexo的模板使用的符号一样，在渲染时会产生冲突，尽管我尽我努力地花了大量时间做 ......
CentOS7 安装RocketMQ5.1.3
安装JDK 1.要求jdk1.8以上，官网下载地址：https://www.oracle.com/cn/java/technologies/downloads/ 2.下载完成后放到/home/downloadfile 没有目录手动创建 3.解压JDK文件到/usr/lib/jvm目录中 tar -x ......
【RocketMQ】顺序消息实现总结
全局有序 在RocketMQ中，如果使消息全局有序，可以为Topic设置一个消息队列，使用一个生产者单线程发送数据，消费者端也使用单线程进行消费，从而保证消息的全局有序，但是这种方式效率低，一般不使用。 局部有序 假设一个Topic分配了两个消息队列，生产者在发送消息的时候，可以对消息设置一个路由I ......
RocketMQ
https://blog.csdn.net/weixin_44981707/article/details/124138939 https://zhuanlan.zhihu.com/p/528956421?utm_id=0 ......
博主近期概览~
2023年3月初换了一份工作，依然在网络安全领域，不过具体的攻防技术牵扯的少一点。 在这里给大家推荐一下很不错的学习网站。 burp 工具的官网 portswigger 推出的 web 漏洞安全，web安全入门首推！ https://portswigger.net/web-security/gett ......
【RocketMQ】消息的消费总结
消费者从Broker拉取到消息之后，会将消息提交到线程池中进行消费，RocketMQ消息消费是批量进行的，如果一批消息的个数小于预先设置的批量消费大小，直接构建消费请求ConsumeRequest将消费请求提交到线程池处理，否则需要分批构建进行提交。 消息消费 在消息被提交到线程池后进行处理时，会调 ......
每天一个linux命令（19）：find 命令概览
Linux下find命令在目录结构中搜索文件，并执行指定的操作。Linux下find命令提供了相当多的查找条件，功能很强大。由于find具有强大的功能，所以它的选项也很多，其中大部分选项都值得我们花时间来了解一下。即使系统中含有网络文件系统( NFS)，find命令在该文件系统中同样有效，只你具有相 ......
RocketMQ 消息重试与死信队列
RocketMQ 消息重试与死信队列 RocketMQ 前面系列文章如下： RocketMQ系列(一) 基本介绍 RocketMQ 系列(二) 环境搭建 RocketMQ 系列(三) 集成 SpringBoot RocketMQ 系列(四) 消息存储 RocketMQ 系列(五）高可用与负载均衡 消 ......
RocketMQ 入门实战(4)--Java 操作 RocketMQ
本文主要介绍使用 Java 来操作 RocketMQ，文中所使用到的软件版本：Java 1.8.0_341、RocketMQ 5.1.3、rocketmq-client-java 5.0.5。 1、引入依赖 <dependency> <groupId>org.apache.rocketmq</gro ......
【RocketMQ】【源码】延迟消息实现原理
RocketMQ设定了延迟级别可以让消息延迟消费，延迟消息会使用SCHEDULE_TOPIC_XXXX这个主题，每个延迟等级对应一个消息队列，并且与普通消息一样，会保存每个消息队列的消费进度（delayOffset.json中的offsetTable）： public class MessageSt ......
springboot整合rocketMQ——消费者
依赖 <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi ......
springboot整合rocketMQ——生产者
依赖 <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi ......
RocketMQ 系列(五）高可用与负载均衡
RocketMQ 系列(五）高可用与负载均衡 RocketMQ 前面系列文章如下： RocketMQ系列(一) 基本介绍 RocketMQ 系列(二) 环境搭建 RocketMQ 系列(三) 集成 SpringBoot RocketMQ 系列(四) 消息存储 上一篇讲了 RocketMQ 的消息存储 ......
基于开源模型搭建实时人脸识别系统（二）：人脸检测概览与模型选型
续 基于开源模型的实时人脸识别系统 进行人脸识别首要的任务就是要定位出画面中的人脸，这个任务就是人脸检测。人脸检测总体上算是目标检测的一个特殊情况，但也有自身的特点，比如角度多变，表情多变，可能存在各类遮挡。早期传统的方法有Haar Cascade、HOG等，基本做法就是特征描述子+滑窗+分类器，随 ......
RabbitMQ、RocketMQ和Kafka的不同之处
RabbitMQ、RocketMQ和Kafka是三种常见的消息队列系统，它们在设计和使用方面有一些不同之处： 架构设计： RabbitMQ：RabbitMQ是一个基于AMQP（高级消息队列协议）的开源消息队列系统，采用的是传统的Broker架构模式，其中包括生产者、消费者和中间件（Broker）。 ......
RocketMQ 系列(四) 消息存储
RocketMQ 系列(四) 消息存储 本文是 RocketMQ 系列的第四篇，下面是前面几篇的文章，不清楚的话点击看一下吧。 RocketMQ系列(一) 基本介绍 RocketMQ 系列(二) 环境搭建 RocketMQ 系列(三) 集成 SpringBoot RocketMQ 作为一款优秀的分布 ......
RocketMQ源码(五)：RocketMQ消息存储流程
在RocketMQ源码(四)：RocketMQ生产者发送消息流程中已经对生产者同步发送消息的源码做了分析，下面继续分析，消息发送到Broker做了哪些处理。 一、Broker处理请求消息的入口 在RocketMQ源码(三)：RocketMQ服务端启动流程中提到，在启动BrokerControler流 ......
【RocketMQ】消息的拉取总结
在上一讲中，介绍了消息的存储，生产者向Broker发送消息之后，数据会写入到CommitLog中，这一讲，就来看一下消费者是如何从Broker拉取消息的。 RocketMQ消息的消费以组为单位，有两种消费模式： 广播模式：同一个消息队列可以分配给组内的每个消费者，每条消息可以被组内的消费者进行消费。 ......