golang project exp01

golang开发的工程经验积累（一）

1，自定义结构体维护用户和对应的tcp链接
可以使用map来维护这个信息，但这样一旦连接的用户数目较多，则map会过大而降低查询的效率，所以可以自定义结构体：

type User struct {
    uid          int64
    conn       *CConn
    ticked      bool // 多次连接导致当前连接被踢下
    beatTimeOut    bool // 心跳检测超时
    ...
}

type CConn struct{
    conn      net.Conn  // 网络连接
    lastTime time.Time  // 最近一次通信时间
    addr       string  // 连接的唯一标识符
    user       *User // User与CConn一一映射
}

然后在建立连接时

func CListenAndServe(net, addr string) {
    tcpAddr, err := net.ResolveTCPAddr(net,addr)
    if err != nil {
        // error handling
    }
    listener, err := net.listenTCP(net, tcpAddr)
    if err != nil {
        //error handling
    }
    go accept() //因为go协程的创建开销非常小
}

func accpet() {
    for {
        conn, err := listener.AcceptTCP()
        if err == nil {
            // 发包频率统计，避免频繁连接
            // 黑白名单
            newconn := NewCConn(conn) // 创建CConn
            newconn.Run()
        } else {
            // error handling
        }
    }
}

func (conn *CConn) Run() {
    conn.onConnect()
    go func() {
        tickerRecv := time.NewTicker(time.Second * time.Duration(rateStatInterval))
        for {
            select {
            case <- conn.StopChan:
                tickerRecv.Stop()
                return
            case <- tickerRecv.c:
                conn.packetRecv = 0
            default:
                conn_closed := conn.parseAndHandlePdu()
                if conn_closed{
                    tickerRecv.Stop()
                    return
                }
            }
        }
    }()
}

func (conn *CConn) onConnect() *User {
    user := &User{conn:conn, ... // 其他初始化内容}
}

每个连接都用一个go协程来处理，这样就能将每个连接都独立起来，当然还需要注意一点，每个服务节点的连接数应该有限时策略。

2，拿来即用的单例模式

import  "github.com/dropbox/godropbox/singleton"
var singleSrv = singleton.NewSingleton(func() (interface{}, error) {
    cluster, _ := cache.GetRedisCluster("singlecache")
    return &SingleMsgProxy{
        Cluster: cluster,
        MsgModel: msg.MsgModel,
    }, nil
})

3，泛型

type MyInterface interface {
    Len() int
    Less(i, j int) bool
    Swap(i, j int)
}
func CustomSort(d MyInterface) {
    ...
}

不管使用CustomeSort的d是什么类型，只要按照接口的要求实现了Len() Less() Swap()就可以使用CustomSort函数。

4，当定义的struct中存在map或者slice时，一定注意这两者是引用
如
type MyObject struct {
olist []string
}

func (m *MyObject) SetList(src []string) {
m.olist = src
}
如果传入之后，你再对src进行变更，那么MyObject中的olist也会受到影响，
正确的做法应该使用copy。

5，go实现并发非常容易，但不要因此滥用。
遇到要做的事情，直接go someFunc()，当go协程创建后，就由底层进行调度，这时我们便失去了对这些执行体的控制。
所以要么使用管道传递信号，要么使用context包，推荐使用后者来构建一个调用链，可以从外层终止go程（go程内部使用for select 监听）