背景：
我们有一个用go做的项目，其中用到了zmq4进行通信，一个简单的rpc过程，早期远端是使用一个map去做ip和具体socket的映射。
问题
大概是这样
struct SocketMap {
sync.Mutex
sockets map[string]*zmq4.Socket
}
然后调用的时候的代码大概就是这样的：
func (pushList *SocketMap) push(ip string, data []byte) {
pushList.Lock()
defer pushList.UnLock()
socket := pushList.sockets[string]
if socket == nil {
socket := zmq4.NewSocket()
//do some initial operation like connect
pushList.sockets[ip] = socket
}
socket.Send(data)
}
相信大家都能看出问题：当push被并发访问的时候（事实上push会经常被并发访问），由于这把大锁的存在，同时只能有一个协程在临界区工作，效率是会被大大降低的。
解决方案：会带来crash的优化
所以我们决定使用sync.Map来替代这个设计，然后出了第一版代码，写的非常简单，只做了简单的替换：
struct SocketMap {
sockets sync.Map
}
func (pushList *SocketMap) push(ip string, data []byte) {
var socket *zmq4.Socket
socketInter, ok = pushList.sockets.Load(ip)
if !ok {
socket = zmq4.NewSocket()
//do some initial operation like connect
pushList.sockets.Store(ip, socket)
} else {
socket = socketInter.(*zmq4.Socket)
}
socket.Send(data)
}
乍一看似乎没什么问题？但是跑起来总是爆炸，然后一看log，提示有个非法地址。后来在github上才看到，zmq4.Socket不是线程安全的。上面的代码恰恰会造成多个线程同时拿到socket实例，然后就crash了。
解决方案2： 加一把锁也挡不住的冲突
然后怎么办呢？看来也只能加锁了，不过这次加锁不能加到整个map上，否则还会有性能问题，那就考虑减小锁的粒度吧，使用锁包装socket。这个时候我们的代码也就呼之欲出了：
struct SocketMutex{
sync.Mutex
socket *zmq4.Socket
}
struct SocketMap {
sockets sync.Map
}
func (pushList *SocketMap) push(ip string, data []byte) {
var socket *SocketMutex
socketInter, ok = pushList.sockets.Load(ip)
if !ok {
socket = &{
socket: zmq4.NewSocket()
}
//do some initial operation like connect
pushList.sockets.Store(ip, newSocket)
} else {
socket = socketInter.(*SocketMutex)
}
socket.Lock()
defer socket.Unlock()
socket.socket.Send(data)
}
但是这样还是有问题，相信经验比较丰富的老哥一眼就能看出来，问题处在socketInter, ok = pushList.sockets.Load(ip)这行代码上，如果map中没有这个值，且有多个协程同时访问到这行代码，显然这几个协程的ok都会置为false，然后都进入第一个if代码块，创建多个socket实例，并且争相覆盖原有值。
单纯解决这个问题也很简单，就是使用sync.Map.LoadOrStore(key interface{}, value interface{}) (v interface{}, loaded bool)
