Go协程间共享Redis/Kafka客户端是否安全？

go-redis Client 部分 #

• 单个Client可安全在多协程间共享：go-redis的Client原生支持并发，内部自带连接池机制。多协程调用Get、Set、Del等方法时，会自动从连接池获取空闲连接，用完放回，不会出现请求丢失、阻塞这类问题。
• 你的代码存在一个小问题：当前代码中传递的是*cache（Client的值拷贝），建议直接传递指针cache，避免不必要的内存拷贝，并发场景下更高效。修正后的调用代码如下：

go doThings(ctx, cache)
go doOtherThings(ctx, cache)

同时函数参数可调整为接收指针类型：

func doThings(ctx context.Context, cache *redis.Client) {
  // ...
}

• 无需为每个协程创建独立Client：每个Client对应一个连接池，创建过多Client会导致Redis服务端连接数过载，反而引发性能问题。如果并发量较高，可通过redis.Options中的PoolSize参数调整连接池大小，默认值足以应对多数场景。

kafka-go Reader/Writer 部分 #

• Reader不可多协程共享：kafka-go的Reader不是并发安全的，多个协程共用同一个Reader会导致消费逻辑混乱、消息重复或丢失。如果需要多协程消费，应为每个协程创建独立Reader，或者使用Consumer Group模式实现分布式消费。
• Writer可安全多协程共享：kafka-go的Writer是并发安全的，内部已处理批量发送、连接复用等逻辑，多协程调用其Write方法不会产生冲突，无需为每个协程单独创建Writer。

内容的提问来源于stack exchange，提问作者kev