消息rocketmq事务
万字长文讲透 RocketMQ 4.X 消费逻辑
RocketMQ 是笔者非常喜欢的消息队列，4.9.X 版本是目前使用最广泛的版本，但它的消费逻辑相对较重，很多同学学习起来没有头绪。 这篇文章，笔者梳理了 RocketMQ 的消费逻辑，希望对大家有所启发。  [Redis系列2：数据持久化提高可用性](https://www.cnblogs.com/w ......
vue消息订阅与发布
1.点一下加号： 2.安装第三方库：（pubsub-js，实现消息发布订阅也可以用其他库） 3.从收数据的人引入库“【引入之后的pubsub是一个对象，对象身上有很多有用的方法】 4.收数据的人订阅消息：【subscribe后面两个形参，第一个为消息名，第二个才是消息内容】 还需要注意订阅消息的人最 ......
分布式事务
一。首先复习下mysql事务 事务四特性： 原子性(A)：要么全运行，要么全不运行 一致性(C)：事务之前A有100块，B有100块，A给B转账，事务结束后A和B的余额总和必须也得是200块。这里除了代码逻辑上没有问题之外，其实还需要其他三个特性的支持。 隔离性(I)：事务之间互不影响。 持久性(D ......
4.消息的性质和集群
# 7.消息的性质 ## 7.1.消息可靠性 消息的可靠性投递就是要保证消息投递过程中每一个环节都要成功，那么这肯定会牺牲一些性能，性能与可靠性是无法兼得的 如果业务实时一致性要求不是特别高的场景，可以牺牲一些可靠性来换取性能。  Message Queue消息队列是一种应用程序对应用程序的通信方法, 可以是线程(Queue), 也可以是`进程之间`, 而`rabbitmq`是进程之间的消息队列 `生产者消费者模型`: 通过一个容器来解决生产者和消费者之间的强耦 ......
Redis的事务操作
Redis事务是一个单独的隔离操作：事务中的所有命令都会序列化、按顺序执行。事务在执行的过程中，不会被其它客户端发送来的命令请求所打断。 Redis事务的主要作用就是串联多个命令防止别的命令插队。 一、Redis事务三特性 Multi：开启事务，输入的命令都会依次进入命令队列中，但不会执行，直到输入 ......
事务的特性和简介
**1.原子性**：要么都成功，要么都失败 **2.一致性**：事务前后的数据完整性要保证一致 **3.持久性**：事务一旦提交则不可逆，被持久到数据库中 **4.隔离性**：多个用户并发访问数据库时，数据库为每一个用户开启事务，不能被其他事务的操作所干扰，事务之间相互隔离 事务不隔离会导致的问题： ......
RocketMQ启动和端口介绍【转】
关闭namesrv和broker 关闭namesrv服务 #进入bin sh mqshutdown namesrv 如图 关闭broker服务 sh mqshutdown broker 如图 通过jps验证下 如图 第五节：防火墙配置宿主机需要远程访问虚拟机的rocketmq服务和web服务，需要开 ......
react 实现聊天界面，发送消息自动到底部
<div style={{ float:"left", clear: "both" }} ref={(el) => { this.messagesEnd = el; }}> </div> scrollToBottom = () => { this.messagesEnd.scrollIntoView ......
事务隔离级别 transation isolation
JDBC 资料：java.sql.Connection Spring 资料：org.springframework.transaction.annotation.Isolation MySQL 资料：https://dev.mysql.com/doc/refman/8.0/en/innodb-tra ......
对隔离级别、事务并发问题、当前读和快照读、相关锁机制的思考
InnoDB存储引擎涉及事务的四大隔离级别（RU）读未提交、（RC）读已提交、（RR）可重复读、（Serializable）串行化 相对事务并发产生的问题：脏读、不可重复读、幻读 隔离级别对应事务：RU什么都解决不了，RC解决脏读、RR解决脏读和不可重复读、Serializable都解决 其中涉及的 ......
spring事务失效的场景
spring事务失效的场景 1.访问权限 在AbstractFallbackTransactionAttributeSource类的computeTransactionAttribute方法中有个判断，如果目标方法不是 public，则TransactionAttribute返回 null，即不支持 ......
rocketmq生产环境升级（干货）
方案一： 升级 K8s pod资源 交替清空其中一组 broker(m-s) 消息，重启pod 优点：操作简单，无需新增资源，在原有资源上扩容 缺点：只完成当前升级，最大只能升级到4C 8G，后续业务量起来有可能还需要升级（升级硬件） 操作： 1. 摘除写入流量 brokerPermission=2 ......
spring 事务传播属性 （propagation)
propagation /ˌprɒpəˈɡeɪʃn/ 传播 资料： https://www.cnblogs.com/zno2/p/4767565.html https://docs.spring.io/spring-framework/docs/4.2.x/spring-framework-refe ......
记一次spring 事务失效的解决
我们项目既有使用spring JPA也有使用spring JdbcTemplate，此次事务失效的原因是，项目之前配置的是spring jpa 的专门的事务管理器。 第一次尝试解决：添加spring JdbcTemplate 的事务管理器，并添加相应的注解驱动。不生效！！！ 第二次尝试解决：问了下c ......
MySQL 中的事务
## 事务 ### 特性 ACID：原子性、一致性、隔离性、持久性 ### 事务隔离解决的问题 #### 脏读 A 事务执行过程中读取到了 B 事务中未提交的数据 #### 不可重复读 由于在 A 事务两次查询的间隔 B 事务进行了提交，导致 A 事务执行过程中第一次查询的数据和第二次查询的数据不一 ......
分布式事务
# 分布式事务 ## 回顾事务 > 什么是事务 ？ > > - 一组对数据库的操作，整体要么一起成功，要么一起失败 > > 事务的特性？ > > - 一致性 > - 原子性 > > 在项目中做事务控制 ？ 怎么做 ？ > > - 在启动类上加@EnableTransactonManager > - ......
curl 通过webhook 地址发送消息
发送信息至群聊机器人#!/bin/bash curl -H "Content-Type: application/json" \ -X POST \ -d '{"msg_type": "text", "content": { "text": "测试信息" } }' \ https://webhook ......
Python 发送微信消息
# Python 发送微信消息 安装 ```shell pip install itchat ``` ## 1、基本使用 ```python # 使用微信接口给微信好友发送消息， import itchat nickname = "迪丽热巴" send_message = "测试消息" try: # ......
通过telegram机器人向群里自动发消息
1、添加 ①Telegram 添加 BotFather 进入聊天界面 ②点击输入框中 /start ③回复内容中点击 /newbot ④阅读提示分别输入 name 和 username，比如叫test_bot ⑤返回token 2、启用 在Telegram搜索@test_bot，进入聊天界面，在聊天 ......
分布式锁& 分布式事务
[toc] ## 分布式事务 ### 什么是分布式事务？ 分布式事务是指涉及多个参与方的事务操作，这些参与方可以位于不同的物理节点或不同的系统之间，需要保证所有参与方的操作要么全部成功，要么全部失败，保持数据的一致性。 ### 分布式事务的实现方式有哪些？ 常见的分布式事务实现方式包括两阶段提交（2 ......