Go实现可重入锁

2023-11-12

Go语言原生支持的Lock(sync.Mutex)不是可重入的，同个协程重复获得锁会panic

package sync

import (
	"sync"
	"testing"
)

func TestLock(t *testing.T) {
	lock := sync.Mutex{}
	lock.Lock()
	t.Log("get lock 1")
	lock.Lock()
	t.Log("get lock 2")
	lock.Unlock()
}

1
2
3

=== RUN   TestLock
    lock_test.go:11: get lock 1
fatal error: all goroutines are asleep - deadlock!

如何实现类似Java语言提供的ReentrantLock,支持可重入呢?
more >>

展开全文 >>

初识Pulsar

2023-11-11

Apache Pulsar 是 Apache 软件基金会顶级项目，是下一代云原生分布式消息流平台，集消息、存储、轻量化函数式计算为一体，采用计算与存储分离架构设计，支持多租户、持久化存储、多机房跨区域数据复制，具有强一致性、高吞吐、低延时及高可扩展性等流数据存储特性，被看作是云原生时代实时消息流传输、存储和计算最佳解决方案。

主要特性:

具备高一致、高可靠、高并发特性
采用服务和存储分离架构，支持水平动态扩容
支持百万级消息主题
非常低的消息发布和端到端的延迟
支持多种订阅模式：独占（exclusive）、共享（shared）、灾备（failover）
一个 Serverless 的轻量级计算框架 Functions 提供了原生的流数据处理
支持多集群，能够无缝的基于地理位置进行跨集群的备份

more >>

展开全文 >>

ZAB协议

2023-05-13

ZAB(Zookeeper Atomic Broadcast)协议是一个能保证操作顺序性的，基于主备模式的原子广播协议。

为什么不采用Paxos协议和Raft协议

Multi-Paxos，虽然能保证达成共识后的值不再改变，但它不关心达成共识的值是什么，也无法保证各值（也就是操作）的顺序性。而这就是 Zookeeper 没有采用 Multi-Paxos 的原因

Raft 出来的比较晚，直到 2013 年才正式提出，而ZooKeeper是在2007年开发的

ZAB 是如何实现操作的顺序性的？

more >>

展开全文 >>

Raft算法

2023-05-09

Raft算法是通过一切以领导者为准的方式，实现一系列值的共识和各节点日志的一致。

简介

Raft 算法属于 Multi-Paxos 算法，它是在兰伯特 Multi-Paxos 思想的基础上，做了一些简化和限制，比如增加了日志必须是连续的，只支持领导者、跟随者和候选人三种状态，在理解和算法实现上都相对容易许多。

Raft 算法是现在分布式系统开发首选的共识算法。绝大多数选用 Paxos 算法的系统（比如 Cubby、Spanner）都是在 Raft 算法发布前开发的，当时没得选；而全新的系统大多选择了 Raft 算法（比如 Etcd、Consul、CockroachDB）。

角色

Raft 算法支持领导者（Leader）、跟随者（Follower）和候选人（Candidate） 3 种状态。

跟随者：就相当于普通群众，默默地接收和处理来自领导者的消息，当等待领导者心跳信息超时的时候，就主动站出来，推荐自己当候选人。
候选人：候选人将向其他节点发送请求投票（RequestVote）RPC 消息，通知其他节点来投票，如果赢得了大多数选票，就晋升当领导者。
领导者：蛮不讲理的霸道总裁，一切以我为准，平常的主要工作内容就是 3 部分，处理写请求、管理日志复制和不断地发送心跳信息，通知其他节点“我是领导者，我还活着，你们现在不要发起新的选举，找个新领导者来替代我。”