消息rocketmq事务
Topic太多，RocketMQ炸了！
网上博客常说，kafka的topic数量过多会影响kafka，而RocketMQ不会受到topic数量影响。 但是，果真如此吗？ 最近排查一个问题，发现RocketMQ稳定性同样受到topic数量影响！！ 好了，一起来回顾下这次问题排查吧，最佳实践和引申思考放在最后，千万不要错过。 1、问题描述 我 ......
Redis从入门到放弃（5）：事务
## 1、事务的定义 Redis的事务提供了一种“将多个命令打包， 然后一次性、按顺序地执行”的机制。 redis事务的主要作用就是串联多个命令防止别的命令插队。 但是，事务并不具有传统数据库事务的特性，如回滚。 ## 2、事务命令 Redis中的事务可以通过以下命令来执行： * `MULTI`：用 ......
判断evpp的发送消息是post 还是get
struct evhttp_request结构体定义了HTTP请求的各个字段，如请求行、请求头、请求正文等。 struct evhttp_request { int major; // 主版本号 int minor; // 次版本号 enum evhttp_cmd_type type; // 请求方 ......
redis做消息队列学习
转自：https://juejin.cn/post/7094272373930590245#heading-9，https://zhuanlan.zhihu.com/p/344269737 1、消息队列基本 作用：应用解耦（作为中介）、削峰填谷。redis做mq的优点：轻量级，使用和运维成本低。 m ......
08-存储引擎和事务
08-存储引擎和事务课程目标掌握存储引擎的使用、常用的存储引擎、选择合适的存储引擎、 事务概述、事务的提交与回滚演示、自动提交模式、事务的隔离级别。8.1存储引擎的使用数据库中的各表均被（在创建表时）指定的存储引擎来处理。 服务器可用的引擎依赖于以下因素： MySQL的版本 服务器在开发时如何被配置 ......
从互联网到云时代，Apache RocketMQ 是如何演进的？
*作者：隆基* 2022 年，RocketMQ 5.0 的正式版发布。相对于 4.0 版本而言，架构走向云原生化，并且覆盖了更多业务场景。 ## 消息队列演进史 操作系统、数据库、中间件是基础软件的三驾马车，而消息队列属于最经典的中间件之一，已经有 30 多年的历史。消息队列的发展主要经历了以下几个 ......
springboot事务管理实现原理
事务在关系型数据库中是一非常重要的东西，spring中对事务的处理也很简单，也就是加个注解的事。为更进一步理解它是如何实现的，今天我们就来拆解下。 1. 几个核心问题 1. 事务的核心是什么？ 简单说其实就是底层数据库的使用方法，比如通常的sql begin; commit; rollback;.. ......
在同一个Java进程中连接多个RocketMQ集群
RocketMQ使用场景： 作为消费者：用户应用 --> MQ集群A --> 权益应用 消息内容:客户开户/销户相关消息 作为生产者：权益应用 --> MQ集群B --> 信贷应用 消息内容:卡券事件消息 问题现象： 一个Java进程要连接多个RocketMQ集群时，作为消费者功能无法正常使用，作为 ......
16_Spring_事务回顾
# 16_Spring_事务回顾 #### 1. 事务的概念 事务（Transaction）指的是一个操作序列，该操作序列中的多个操作要么都做，要么都不做，是一个不可分割的工作单位，是数据库环境中的逻辑工作单位，由DBMS 中的事务管理子系统负责事务的处理。 目前常用的存储引擎有InnoDB（M ......
17_Spring_事务环境搭建
# 17_Spring_事务环境搭建 通过张三给李四转账案例演示事务的控制 1 数据库中准备表格  2 声明式事务管理(掌握) 基于注解方式实现(掌握) XML方式实现(了解) Spring声明式事务的实现方式,底层就是AOP,AOP的底层 ......
20_Spring_零XML事务控制
# 20_Spring_零XML事务控制 创建配置类 1. package com.msb.config; 2. import com.alibaba.druid.pool.DruidDataSource; 3. import org.springframework.beans.factory. ......
19_Spring_事务管理XML配置方式
# 19_Spring_事务管理XML配置方式 applicationContext中,通过AOP实现事务的控制 1. 2. 22. 23. 24. 25. 26. 27. 28. 29. 30. 31. 32. 33. 34. 35. 36. 37. 38. 39. 40. 41. 42. 4 ......
二十、RocketMQ5.x消费重试
消费重试指的是，消费者在消费某条消息失败后，Apache RocketMQ 服务端会根据重试策略重新消费该消息，超过一次定数后若还未消费成功，则该消息将不再继续重试，直接被发送到死信队列中。Apache RocketMQ 的消费重试主要解决的是业务处理逻辑失败导致的消费完整性问题，是一种为业务兜底的 ......
十九、消息查询
RocketMQ支持按照下面两种维度（“按照Message Id查询消息”、“按照Message Key查询消息”）进行消息查询。在RocketMQ dashboard中：  # ......
使用 AlwaysOn 可用性组只读辅助副本执行事务日志备份 - 第 1 部分
什么是日志序列号 (LSN)？ 在对 AlwaysOn 可用性组进行故障排除时，有多个 DMV 引用各种 LSN（日志序列号）。此外，备份和恢复操作经常引用并输出LSN值。 那么什么是LSN呢？LSN 是一个序列号，用于维护数据库内的顺序和跟踪操作。LSN 可以是十进制形式或十六进制形式，具体取决于 ......
十六、RocketMQ5.0版本消费负载均衡
根据消费者类型的不同，消费者负载均衡策略分为以下两种模式： 1. 消息粒度负载均衡：RocketMQ5.x版本的PushConsumer和SimpleConsumer默认负载策略 2. 队列粒度负载均衡：PullConsumer默认负载策略 ### 消息粒度负载均衡 消息粒度负载均衡策略中，同一消费 ......
mysql系列03---事务
一、事务简介 事务是一组操作的集合，它是一个不可分割的工作单位，事务会把所有的操作作为一个整体一起向系统提交或撤销 操作请求，即这些操作要么同时成功，要么同时失败。 二、事物的四大特性 一个事务具有ACID特性，也就是（Atomicity、Consistency、Isolation、Durabili ......
EAS_在controllerBean中调用其他方法，发生异常后，事务没有回滚
首先列出例子如下：在一个方法中，执行了多个逻辑，第一部分是调用退票逻辑，第二部分是执行其他业务，这里我们遇到问题，退票逻辑执行成功，但是后面的代码异常，这时我们需要的是退回所有执行， 这时我们就需要认清facade中的事务属性： 就是EJB规范的6种事务属性：Required: 要求有事务： 如果已 ......
微信公众号模板消息源码实现，打破服务号群发推送次数限制
公众号服务号每个月只能群发推送四次文章，我们可以使用模板消息为公众号粉丝推送信息 下面是使用golang实现的模板消息发送类库封装，轻松实现模板消息发送 wechat.go package lib import ( "github.com/silenceper/wechat/v2" "github. ......
如何对接微信公众号模板消息
微信公众号的模板消息进行了更新，与之前比有了不少的变化，以前的一些类目也没有了，历史模板还是可以继续使用的，下面是新版模板消息的使用步骤 选择服务类目 前往【广告与服务】【模板消息】【模板库】【类目模板库】点击服务类目的详情，选择一个自己的服务类目 比如我选择的是：商业服务 > 软件/建站/技术开发 ......
十五、RocketMQ4.x消费者负载均衡策略
### 一、AllocateMessageQueueAveragely AllocateMessageQueueAveragely就是默认的负载均衡策略，在上个例子已经演示了，可以在[这里](https://www.cnblogs.com/shigongp/p/17575805.html)查看。先分 ......
异常处理与事务管理
## 一、异常处理方案 1.方案一：在Controller的方法中进行try...catch处理（代码臃肿）； 2.方案二：全局异常处理器（简单优雅）。 ## 二、全局异常处理器 @RestControllerAdvice = @ControllerAdvice + @ResponseBody ![ ......
Apache Kafka 事务机制
[TOC] # 为什么要进行交易呢？ 在 Kafka 中设计事务主要针对表现出 **“读取-处理-写入”**（read-process-write） 模式的应用程序，其中读取和写入来自异步数据流（例如 Kafka 主题），即事务中同时包含读取消息、处理消息和写入消息过程，此类应用程序更普遍地称为** ......
JDBC p3 事务
# 事务 - **基本介绍** 1. JDBC 程序中当一个Connection对象创建时，默认情况下是自动提交事务：每次执行一个 SQL 语句时，如果执行成功，就会向数据库自动提交，而不能回滚。 2. JDBC程序中为了多个SQL语句作为一个整体执行，需要==使用事务==。 3. 调用 Conne ......
Redis —— 事务
参考： 小林：https://xiaolincoding.com/redis/base/redis_interview.html shuxiaohua（集群）：https://huaweicloud.csdn.net/637f776ddacf622b8df84ee9.html java guide: ......
rabbitmq php 发送延迟消息 java 进行消费
// 延迟队列 php 需要安装好几个扩展 php 生产者 $connection = new AMQPStreamConnection('xxxxx', 5672, 'guest', 'guest'); $channel = $connection->channel(); // 发送消息到交换机， ......