Lin's Blog

RocketMQ 消费端

本文介绍RocketMQ消费者;包括消费者启动,消费消息流程和其中的要点等。 关于rocketmq-client包 RocketMQ将producer,consumer和admin相关代码都放到rocketmq-client jar包里;RocketMQ的采用客户端拉的方式消费消息(PUSH也是通过客户端拉来实现的),拉取的时候要考虑负载均衡(rebalance),考虑消息至少消费一次(......

RocketMQ总体架构

本文介绍RocketMQ总体框架;包括系统构成,基本概念等。 总体架构 RocketMQ Apache RocketMQ是一款具有低延迟,高性能和可靠性,可灵活扩展的分布式消息平台。它由四部分组成:NameServer,Broker,生产者和消费者。它们中的每一个都可以在没有单点故障的情况下进行水平扩展。 核心系统 NameServer NameServer是一个轻量级的服务注册中心。......

MySQL事务与锁-2

锁的应用-MySQL悲观锁乐观锁,基于Redis的分布式锁

数据库锁的使用 锁的副作用 锁等待 12345678910#正在执行的事务SELECT * from information_schema.INNODB_TRX;#当前出现的锁等待SELECT * from information_schema.INNODB_LOCK_WAITS;#出现锁等待的锁的详细信息SELECT * from information_schema.INNODB_LOC......

MySQL事务与锁-1

MySQL-InnoDB引擎中的事务

介绍了事务的ACID特性,MySQL各个隔离级别下的实现方式。 数据库中事务 事务的ACID 原子性(Atomicity) 定义:事务作为一个整体被执行,包含在其中的对数据库的操作要么全部被执行,要么都不执行 一致性(Consistency) 定义:事务应确保数据库的状态从一个一致状态转变为另一个一致状态。一致状态的含义是数据库中的数据应满足完整性约束 隔离性(Isolation) 定义......

WL Lock

一种本地锁+分布式锁的实现

本文介绍了一种本地锁+分布式锁的实现,项目地址:https://github.com/adamswanglin/wllock 分布式锁相关 考虑分布式商品秒杀系统,库存量较少的商品,如何保证商品数量不超卖? 其实需要保证这种一致性:某个人点击秒杀后系统中查出来的库存量和实际扣减库存时库存量的一致性就可以。Java中有synchronize关键字,可以保证这种一致性,但这种一致性是单JVM......

Hosted by Coding Pages