关于golang:golang-网络连接库-cellnet1

cellnet是一个组件化、高扩展性、高性能的开源服务器网络库。它的次要概念如下

队列
队列应用NewEventQueue创立，应用.StartLoop()开启队列事件处理循环，所有投递到队列中的函数回调会在队列自在的goroutine中被调用，逻辑在此时被解决

个别在main goroutine中调用queue.Wait阻塞期待队列完结。

队列在cellnet中应用cellnet.Queue接口, 底层由带缓冲的channel实现

端(Peer)
peer是客户端和服务端的封装
cellnet应用Acceptor接管多个连贯，Acceptor是一种Peer（端），连贯到Acceptor的Peer叫做Connector。

一个Peer领有很多属性（名称，地址，队列），peer.NewGenericPeer函数封装了属性的设置过程。

peer.NewGenericPeer创立好的Peer不会产生任何socket操作，对于Acceptor来说，调用Acceptor的Start办法后，才会真正开始socket的侦听

应用如下代码创立一个接受器(Acceptor)：

  queue := cellnet.NewEventQueue()

    // NewGenericPeer参数顺次是: peer类型, peer名称(日志中不便查看), 侦听地址，事件队列
    peerIns := peer.NewGenericPeer("tcp.Acceptor", "server", "127.0.0.1:8801", queue)

    peerIns.Start()

Connector也是一种Peer，与Acceptor很很多相似的中央，因而创立过程也是相似的。

应用如下代码创立一个连接器(Connector)：

queue := cellnet.NewEventQueue()

    peerIns := peer.NewGenericPeer("tcp.Connector", "client", "127.0.0.1:8801", queue)

    peerIns.Start("127.0.0.1:8801")

处理器（proc）
cellnet应用Processor解决音讯的收发过程。

应用proc.BindProcessorHandler函数，将一个Peer绑定到某个Processor上，且设置用户音讯解决回调。

上面代码尝试将peerIns的Peer，绑定”tcp.ltv”处理器，回调函数为func(ev cellnet.Event) { … }

proc.BindProcessorHandler(peerIns, "tcp.ltv", func(ev cellnet.Event) {

    switch msg := ev.Message().(type) {
    // 有新的连贯连到8801端口
    case *cellnet.SessionAccepted:
        log.Debugln("server accepted")
    // 有连贯从8801端口断开
    case *cellnet.SessionClosed:
        log.Debugln("session closed: ", ev.Session().ID())
    // 收到某个连贯的ChatREQ音讯
    case *proto.ChatREQ:

        // 筹备回应的音讯
        ack := proto.ChatACK{
            Content: msg.Content,       // 聊天内容
            Id:      ev.Session().ID(), // 应用会话ID作为发送内容的ID
        }

        // 在Peer上查问SessionAccessor接口，并遍历Peer上的所有连贯，并发送回应音讯（即播送音讯）
        p.(cellnet.SessionAccessor).VisitSession(func(ses cellnet.Session) bool {

            ses.Send(&ack)

            return true
        })

    }

})

callnet 通过这三种封装将网络连接和解决音讯解耦开，下篇文章将要介绍callnet对于peer源码的解析，不同的协定（http，tcp, protobuf）都有对应的peer我将取其中（tcp）解析，其它的协定下的内容都差不多。