go语言本地缓存 golang channel 有缓存但是close掉( 二 )


池pool和缓存cache的区别 。池的意思是 , 池内对象是可以互换的,不关心具体值,甚至不需要区分是新建的还是从池中拿出的 。缓存指的是KV映射,缓存里的值互不相同 , 清除机制更为复杂 。缓存清除算法如LRU、LIRS缓存算法 。
池空间回收的几种方式 。一些是GC前回收,一些是基于时钟或弱引用回收 。最终确定在GC时回收Pool内对象 , 即不回避GC 。用java的GC解释弱引用 。GC的四种引用:强引用、弱引用、软引用、虚引用 。虚引用即没有引用 , 弱引用GC但有空间则保留,软引用GC即清除 。ThreadLocal的值为弱引用的例子 。
regexp 包为了保证并发时使用同一个正则,而维护了一组状态机 。
fmt包做字串拼接,从sync.pool拿[]byte对象 。避免频繁构建再GC效率高很多 。
基于go的websocket消息推送的集群实现目前websocket技术已经很成熟,选型Go语言,当然是为了节省成本以及它强大的高并发性能 。我使用的是第三方开源的websocket库即gorilla/websocket 。
由于我们线上推送的量不?。?推送后端需要部署多节点保持高可用,所以需要自己做集群,具体架构方案如图:
【go语言本地缓存 golang channel 有缓存但是close掉】 Auth Service:鉴权服务,根据Token验证用户权限 。
Collect Service:消息采集服务 , 负责收集业务系统消息,存入MongoDB后 , 发送给消息分发服务 。
Dispatch Service:消息分发服务,根据路由规则分发至对应消息推送服务节点上 。
Push Service:消息推送服务,通过websocket将消息推送给用户 。
集群推送的关键点在于,web端与服务端建立长连接之后,具体跟哪个推送节点保持长连接的,如果我们能够找到对应的连接节点,那么我们就可以将消息推送出去 。下面讲解一下集群的大致流程:
1. web端用户登录之后,带上token与后端推送服务(Push Service)保持长连接 。
2. 推送服务收到连接请求之后,携带token去鉴权服务(Auth Service)验证此token权限,并返回用户ID 。
3. 把返回的用户ID与长连接存入本地缓存,保持用户ID与长连接绑定关系 。
4. 再将用户ID与本推送节点IP存入redis,建立用户(即长连接)与节点绑定关系,并设置失效时间 。
5. 采集服务(Collect Service)收集业务消息,首先存入mongodb , 然后将消息透传给分发服务(Dispatch Service) 。
6. 分发服务收到消息之后,根据消息体中的用户ID,从redis中获取对应的推送服务节点IP , 然后转发给对应的推送节点 。
7. 推送服务节点收到消息之后 , 根据用户ID,从本地缓存中取出对应的长连接 , 将消息推送给客户端 。
其他注意事项:
go语言本地缓存的介绍就聊到这里吧,感谢你花时间阅读本站内容,更多关于golang channel 有缓存但是close掉、go语言本地缓存的信息别忘了在本站进行查找喔 。

推荐阅读