自己的web框架，封装各个模块，收集实现的实用性功能及技术点记录，api拦截，异步端口监听，多个httpserver同时服务，后台日志收集服务,websocekt为基础的消息功能，nsq消息队列，grpc外部服务，redis地理位置处理，ants和cron结合的任务机制，带房间的在线聊天平台等
功能核心，采用类多态的性质，引入工作元素的概念（以url和对应header进行划分），每一个工作元素将对应不同的业务类，实现功能划分。权限上将api分为内部调用和外部调用，来约束调用过程 将每个对应功能都分配一个业务类，对应业务类实现get，post方法，在init的时候，将所有业务类注册到对应全局注册中心，等待，将拦截到的请求，与全局注册中的类匹配成功后，指向该类的方法内部执行。 在进行拦截时，获取到所有url请求，进行url处理，获取到标识，对应到相应的工作元素。这里将保存request和ResponseWriter，工作元素信息，用户信息等。然后，获取控制器的标识与全局注册中心匹配，成功后将进入api调用，否之，则无效请求。
eg：@/modules/common/api_get_ecample.go
用户操作通过redis进行状态保存。登录后状态保持五分钟，每次活动都会重置活动时间。注册将用户信息保存至数据库中，期间，将获取部分用户信息，结合加密算法生成唯一salt,使用md5结合salt生成password密文,采用二进制存储。登录时，使用相同加密方式进行验证，即使代码加密方式泄密，第三方也无法获取唯一salt，保证密码的安全性。登录后，将用户信息注册入redis用户组，同时保存用户状态，反馈api请求token和权限信息。
eg：@/modules/common/register.go和login
使用了第三方logrus包，将信息输出分成多个收集，定向不同的文件句柄中。logrus中将定义一个每日log文件，记录基本的信息。而系统中的日记分两种，一个panic的异常信息，另一个为普通日志信息，这里调用了系统的dll方式，不同操作系统使用不用的编译文件，将panic的错误信息重定向至指定文件内，防止控制台因为行数的约束未能记录获取信息。
eg：@core/global中logrul的启动
聊天室以及消息功能，是以基于websocket为基础，使用改进了聊天室的框架搭建的。每个连接使用Sec-WebSocket-Protocol标记用户，也可以在发送的信息内标记用户，达到一对一和多对多的双向信息传输过程。后续新增了带房间的在线聊天平台，解决进入竞争和房间销毁过程中产生的连接问题等，详细请看下列说明。
eg：@/lib/ws和/load/websocket
内部调用了cron和ants两个包结合使用，达到了定时功能和线程池化的处理，同时，在处理过程中，使用redis标记任务，防止同类型同一用户多次重复提交，并执行后记录至数据库中。使用过程中，任务为定义的一个单独的对象，内部包含任务基本信息（定时信息及用户信息等）以及待处理逻辑，触发ants定时系统后，将该任务提交至ants协程池中实际处理。
eg：@/lib/task
使用redis记录实时信息及保值频繁的重复信息，生成验证码和状态标识。使用了reidsGeo的位置处理，反馈各个成员之间的位置信息和筛选功能。
eg：@/lib/rediser
引入grpc机制，在proto中写入需要外部调用的服务，编译生成对应go服务文件。在load中新启端口建立tcp监听。
eg: @/lib/external_service
封装了原始的nsq方法，快速构建生产者或者消费，达到消息通讯的目的
eg: @/lib/snsq---@/modules/common/nsq_send---@/modules/common/nsq_customer
builds 构建目录
core 核心功能目录
lib 功能列表目录
loader 启动目录
modules/common 功能实现和展示目录（实际api调用接口书写）
main.go 主函数入口
assets静态资源存放
log logrus每日日志记录（暂剔除，待定）
config 配置文件
err.txt panic定向文件
log.txt普通日志收集文件
核心功能模块，定义了主要的功能内容和全局引用，以及各个引用类型，或者引用功能列表实现项目逻辑（内部任务等）
功能列表，单独分开独立的功能工具
现有功能：
1.聊天室架构（基于websocket实现，详情请看下列说明）
2.信息加密过程
3.提取图片文字（基于baiduAPI实现）
4.task任务模块（ants+cron）
5.外服服务模块定制(grpc)
6.相关文件处理（excel、csv等）
7.nsq消息队列的构建
8.redis地理位置操作
9.redis信息保存和用户状态
10.文件传输（包含大文件传输）
11.文件内容比对（txt，csv和xlsx三种文件相互比对）
启动服务设定，开启项目基本依赖（数据库，redis连接，webocekt监听以及日志记录功能等），开启服务监听，拦截api请求等
实际业务实现模块
使用mysql作为基本数据支持容器,缓存使用redis用于注册中心和用户状态保持，以及一部分缓存形的展示数据。新引入了mogodb用于不定格式的数据收集
连接依旧选择websocket长连接的方式，数据存储使用mongodb，松散并且效率高
过程中解决的问题：
1.多人同时进入房间的竞争，业务对应：10个人同时进入只有人数五人限制的房间
2.房间解散过程中（服务端数据清理）新连接的处理，业务对应：解散房间的逻辑正在处理，其他客户端在临界情况点击加入
数据存储过程：
mongodb中存储类型关系为，user，roomid，roomtype，对应用户在哪个房间，以及房间类型。数据修改只有两种操作，进入房间和离开房间只需要插入和删除就行，数据之间不要有关系，不需要update，免得引起不必要关联逻辑错误。
这里不能存储每个房间的在线人数，查询人数只需要查询roomid的count就行，不存实时在线总数。
如果每个房间是一条数据的话，每次修改人数需要检查再修改，可能存在同时多个请求处理单条数据的情况，可能出现麻烦的脏读或者幻读问题。
虽然这样操作可能也会有一定的延时问题，但是相对来说能缓解。
第一种方法
使用chan线程安全的特性，自定义一个“分段锁”
type CustomizeLock struct {
cap int
locks map[string]bool
flag chan bool
}
其中 flag := make(chan bool, cap)，flag定义为缓存容量为cap的通道。
当连接前，只需在通道内获取一个值，直到限定cap的长度，其余的直接default中拒绝即可
//GetLock 从标识队列中获取一个锁,并加入使用对象
//关闭通道说明房间移除，临界情况为，过程中加入该连接
func (c *CustomizeLock) GetLock(user string) bool {
select {
case _, ok := <-c.flag:
if !ok {
return false
}
c.locks[user] = true
return true
default:
return false
}
}
第二种解决办法
使用redis的setnx机制,以及对应的lua脚本
使用该方法需要使用lua脚本，虽然setnx是可以保证唯一操作，
但是请求之间都是异步，可能第一句检查get是该usr，第二行set的时候，内容就已经被其他用户修改了；
所以这里引入lua脚本进行检查和设置的操作，不要想着事务，redis中的事务发生错误是不会回滚的，不保持一致性。
使用过程，当有人请求时，反馈一个唯一key，这个key对应该room的锁，连接时检查该锁的有效性。
当超过房间人数的请求时，检查该房间所有的锁是否有过期，过期则替换新的锁并反馈成功。
当用户成功连接时，需要保证该锁的有效期，就是给该锁续命，和用户连接保持同步。
注意这里的锁的检查和增加，需要使用lua脚本，不然可能会遇到使用get获取到的用户，下一句get或者重新setnx的时候，其实内容已经修改
因为你get和下一句代码发生的中间过程，可能其他异步操作了这个key
给每个房间加一个互斥锁，只有在房间的解散时才使用。
在执行房间的清理过程中，会将room属性值（房间标识，房主信息等）清理，并断开对应联系的连接，最后清除room
该操作前上锁，操作完成后释放。
而用户连接前获取该房间的锁，完成连接并加入room后释放。
如果在清理前加入，直接被清理，清理后加入，获取到该锁时，会判断该room对象内容，如果为空，标识这是一个已经被清理的对象room，就直接退出，不在连接，并释放锁。