如何在Golang中实现并发读写分离_石家庄创泽智能科技有限公司

新闻中心 NEWS CENTER

您当前位置：首页 > 新闻中心 > 网络学院

如何在Golang中实现并发读写分离

2025-10-29

浏览次数：次

返回列表

使用 sync.RWMutex 可高效实现 Go 中的并发读写分离，允许多个读操作同时进行，写操作独占锁，适用于读多写少场景如缓存、配置中心。示例中 SafeMap 通过 RLock 和 Lock 控制 map 的并发访问，保障数据安全。RWMutex 默认偏向读，避免写饥饿，但频繁写或长时持锁影响性能。进阶方案可用 channel 实现请求串行化管理，适合需精细控制的场景，但增加延迟。sync.RWMutex 基本能满足大多数需求，简单高效。

如何在golang中实现并发读写分离

在Go语言中实现并发读写分离，核心是解决多个协程同时访问共享资源时的数据竞争问题。当多个读操作和少量写操作并存时，使用 sync.RWMutex 是最常见且高效的方式。它允许多个读操作同时进行，但写操作独占访问权限。

使用 sync.RWMutex 实现读写分离

sync.RWMutex 提供了读锁（RLock/RLocker）和写锁（Lock）。读锁可以被多个goroutine同时持有，而写锁是排他的。

适用场景：配置中心、缓存服务、状态监控等读多写少的结构。

示例代码：

package main
<p>import (
"fmt"
"sync"
"time"
)</p><p>type SafeMap struct {
data map[string]string
mu   sync.RWMutex
}</p><p>func (sm *SafeMap) Get(key string) (string, bool) {
sm.mu.RLock()
defer sm.mu.RUnlock()
val, exists := sm.data[key]
return val, exists
}</p><p>func (sm *SafeMap) Set(key, value string) {
sm.mu.Lock()
defer sm.mu.Unlock()
sm.data[key] = value
}</p><p>func main() {
sm := &SafeMap{data: make(map[string]string)}</p><pre class="brush:php;toolbar:false;">var wg sync.WaitGroup

// 启动多个读协程
for i := 0; i < 5; i++ {
    wg.Add(1)
    go func(id int) {
        defer wg.Done()
        for j := 0; j < 3; j++ {
            if val, ok := sm.Get("key"); ok {
                fmt.Printf("Reader %d got: %s\n", id, val)
            } else {
                fmt.Printf("Reader %d found no value\n", id)
            }
            time.Sleep(100 * time.Millisecond)
        }
    }(i)
}

// 启动一个写协程
wg.Add(1)
go func() {
    defer wg.Done()
    for i := 0; i < 2; i++ {
        sm.Set("key", fmt.Sprintf("value-%d", i))
        fmt.Println("Writer set new value")
        time.Sleep(300 * time.Millisecond)
    }
}()

wg.Wait()

}

读写优先级与性能考虑

RWMutex 默认偏向读操作，即只要还有读锁存在，后续的读请求可以立即获得锁。但如果写操作已经在等待，新的读请求会被阻塞，避免写饥饿。

注意以下几点：

PHP与MySQL程序设计3

本书是全面讲述PHP与MySQL的经典之作，书中不但全面介绍了两种技术的核心特性，还讲解了如何高效地结合这两种技术构建健壮的数据驱动的应用程序。本书涵盖了两种技术新版本中出现的最新特性，书中大量实际的示例和深入的分析均来自于作者在这方面多年的专业经验，可用于解决开发者在实际中所面临的各种挑战。本书内容全面深入，适合各层次PHP和MySQL开发人员阅读，既是优秀的学习教程，也可用作参考手册。