activemq gt rabbitmq rocketmq
rabbitmq持久化
一:消息持久化 RabbitMQ并不是用来存储数据的，而是用来传输消息的中间件。因此，如果需要存储数据，应该使用数据库或者其他合适的工具，而不是RabbitMQ。 如果需要使用RabbitMQ来传输消息，并且希望消息能够被持久化存储，可以采取以下措施： 1. 使用持久化队列：在声明队列的时候设置du ......
elementUI <el-col>布局错乱
只需要在<el-row>中添加type类型flex，再设置flex-wrap:wrap即可 <el-row type="flex" style="flex-wrap: wrap"> ......
【RocketMQ】Rebalance负载均衡总结
消费者负载均衡，是指为消费组下的每个消费者分配订阅主题下的消费队列，分配了消费队列消费者就可以知道去消费哪个消费队列上面的消息，这里针对集群模式，因为广播模式，所有的消息队列可以被消费组下的每个消费者消费不涉及负载均衡，而集群模式一个消息队列同一时间只能分配给组内的一个消费者进行消费。 Rocket ......
RabbitMQ
MQ基本概念 概述 MQ全称 Message Queue(消息队列)，存储消息的中间件，是在消息的传输过程中保存消息的容器。多用于分布式系统之间进行通信。 分布式系统通信两种方式:直接远程调用和借助第三方完成间接通信；发送方称为生产者，接收方称为消费者 优势 应用解耦：提高系统容错性和可维护性（系统 ......
【1.0】RocketMQ初识
【一】什么是RocketMQ RocketMQ 是一款功能强大的分布式消息系统，广泛应用于多个领域，包括异步通信解耦、企业解决方案、金融支付、电信、电子商务、快递物流、广告营销、社交、即时通信、移动应用、手游、视频、物联网、车联网等。 RocketMQ 源码地址：https://github.com ......
RabbitMQ报错：Shutdown Signal: channel error; protocol method
Shutdown Signal: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - unknown delivery tag 1, class ......
【RocketMQ】事务实现原理总结
RocketMQ事务的使用场景 单体架构下的事务 在单体系统的开发过程中，假如某个场景下需要对数据库的多张表进行操作，为了保证数据的一致性，一般会使用事务，将所有的操作全部提交或者在出错的时候全部回滚。以创建订单为例，假设下单后需要做两个操作： 在订单表生成订单 在积分表增加本次订单增加的积分记录 ......
RocketMq发送消息之事务消息
概述 事务消息共有三种状态，提交状态、回滚状态、中间状态： TransactionStatus.CommitTransaction: 提交事务，它允许消费者消费此消息。 TransactionStatus.RollbackTransaction: 回滚事务，它代表该消息将被删除，不允许被消费。 Tr ......
RabbitMQ
RabbitMQ 1.安装nget包 DotNetCore.CAP 2.在program里写配置 //加入CAP builder.Services.AddCap(x => { //读取上下文 x.UseEntityFramework<MemberContext>(); // EF //读取数据库 x ......
GT考试 [矩乘系列]
前言： 应某人的要求，写一下题解。 这题折磨吗，不折磨，折磨吗，不折磨。所以宇宙万法的源头是什么？如如，所以折磨吗，如折。 题目传送门 解题思路： 首先，容易想到递推 $ n $ （矩乘不递推大的推什么？），枚举当前合法方案中的后缀再多出一个字符后是否会变的不合法。看到 $ m $ 的范围，尝试dp ......
RocketMq发送消息之过滤消息
过滤消息概述 在大多数情况下，TAG是一个简单而有用的设计，其可以来选择您想要的消息。例如： // 定义一个group1的消费者组 DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("group1"); // 订阅 TOPIC 主题 ......
深入理解RocketMQ 广播消费
这篇文章我们聊聊广播消费，因为广播消费在某些场景下真的有奇效。笔者会从基础概念、实现机制、实战案例、注意事项四个方面一一展开，希望能帮助到大家。 1 基础概念 RocketMQ 支持两种消息模式：集群消费（ Clustering ）和广播消费（ Broadcasting ）。 集群消费： 同一 To ......
RocketMq发送消息之批量消息
概述 批量发送消息能显著提高传递小消息的性能。限制是这些批量消息应该有相同的topic，相同的waitStoreMsgOK，而且不能是延时消息。此外，这一批消息的总大小不应超过4MB 发送批量消息 如果您每次只发送不超过4MB的消息，则很容易使用批处理，样例如下： String topic = "B ......
rabbitmq集群搭建-镜像模式
rabbitmq简介 RabbitMQ 采用 Erlang 语言开发，Erlang 语言由 Ericson 设计，Erlang 在分布式编程和故障恢复方面表现出色，电信领域被广泛使用。 Broker: 接收和分发消息的应用，RabbitMQ Server 就是Message Broker，一个Bro ......
RocketMq发送消息之延迟消息
延迟消息 比如电商里，提交了一个订单就可以发送一个延时消息，1h后去检查这个订单的状态，如果还是未付款就取消订单释放库存。 使用限制 对比于rabbitmq中的延迟消息来说，rockermq并不支持任意时间的延迟，需要设置几个固定的延时等级，从1s到2h分别对应着等级1到18级 // org/apa ......
RabbitMQ保姆级教程最佳实践
一、消息队列介绍 1、消息队列概念 1、MQ全称为Message Queue,消息队列（MQ）是⼀种应⽤程序对应⽤程序的通信⽅法。 应⽤程序通过读写出⼊队列的消息（针对应⽤程序的数据）来通信，⽽⽆需专⽤连接来 链接它们。 2、消息传递指的是程序之间通过在消息中发送数据进⾏通信，⽽不是通过直接调⽤彼此 ......
SpringCloud --> 什么是微服务？
微服务我们可以理解为是一种架构设计风格，就是将一个项目拆分成一个或者多个服务，每个服务都可以单独的运行，而且每个服务都会占用线程。 从字面意思上我们可以理解为 "微小的服务" ， 我们从微小、服务 来理解 微小 ：强调的是单一项目的体积小，一个微服务通常只提供单个业务的功能，一个微服务只专注于做好一 ......
RocketMQ发送消息之同步异步单向
官网教程：https://rocketmq.apache.org/zh/docs/quickStart/01quickstart 基于双主双从异步方式开启的前提下，在maven项目中引入下列依赖 <dependency> <groupId>org.apache.rocketmq</groupId> ......
! [rejected] master -> master (fetch first)
! [rejected] master -> master (fetch first) 原因 Git仓库中已经有一部分代码，所以它不允许你直接把你的代码覆盖上去。 远程仓库和本地仓库存在差异。 一般都是因为你在码云创建的仓库有ReadMe文件，而本地没有，造成本地和远程的不同步， 解决方法： 方法一 ......
Docker 部署 RabbitMQ
Docker 部署 RabbitMQ (35条消息) docker-compose安装RabbitMQ_rabbitmq dockerfile_嫣夜来的博客-CSDN博客 Docker系列之RabbitMQ安装部署教程 - 腾讯云开发者社区-腾讯云 (tencent.com) 拉取镜像 docker ......
docker-compose 部署 RabbitMQ
docker-compose 部署 RabbitMQ docker-compose.yml version: '3.5' services: rabbitmq: restart: always image: rabbitmq:management container_name: rabbitmq h ......
Max retries exceeded with url: / (Caused by NewConnectionError('<urllib3.connection.HTTPSConnection object at 0x000001A73833FD00>: Failed to establish a new connection: [WinError 10060]
报错 Max retries exceeded with url: / (Caused by NewConnectionError('<urllib3.connection.HTTPSConnection object at 0x000001A73833FD00>: Failed to establ ......
使用Object.defineProperty() 定义对象属性时，如已设置 set 或 get, 就不能设置 writable 和 value 中的任何一个了。TypeError: Invalid property descriptor. Cannot both specify accessors and a value or writable attribute, #<Object>
使用Object.defineProperty() 定义对象属性时，如已设置 set 或 get, 就不能设置 writable 和 value 中的任何一个了，不然会报如下错误。 TypeError: Invalid property descriptor. Cannot both specify ......
element中的<el-cascader>组件当值是0时不选中问题
在element中的组件中，如果当前值是0时，无法显示。 解决方法：将为0的值转换成字符串的0，即 "0"。 ......
[转]mysql或MariaDB的时间比较效率,用<,>,between..and..比date_format快
当然也是有代价的,就是对于不精确到最后秒的对比,比如查询某一天的,麻烦一点,需要写一个范围,比如 where a.create_time >= '2023-02-28 00:00:00' and where a.create_time <= '2023-02-28 23:59:59',到月和年的同理 ......
2023-09-22 uniapp canvas之ctx.draw没有回调 ==》ctx.draw(true, (() => {...})())
try catch 无法捕获到错误，没有回调，没有反应，宛如石化一般，孤寂无边。 原本写法： ctx.draw(false, () => { let a = setTimeout(async () => { const [err, res] = await uni.canvasToTempFileP ......
docker安装rabbitmq镜像
--拉取rabbitmq的镜像文件 docker pull rabbitmq:3.7.7-management --只有默认账号guest docker run -d -p 5672:5672 -p 15672:15672 --name rabbitmq --restart=always rabbi ......
Docker上运行RabbitMQ，无法访问管理页面
在CentOS 7中的Docker安装并运行了RabbitMQ，但是在访问管理页面http://IP:15672/却提示拒绝访问 这是因为在Docker上运行的RabbitMQ，默认情况下是没有启用管理插件和管理页面的 使用命令 docker exec -it 容器名 /bin/bash 进入 Ra ......
List<Float>转float[] List<Double>转double[]
1. 添加pom <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-lang3</artifactId> </dependency> 2. List<Float>转float[] List<Float> fe ......