9.5 使用Zinx-V0.9完成应用程序

    写一个服务端:

    我们这里注册了两个Hook函数一个是链接初始化之后和链接停止之前DoConnectionLost()。

    DoConnectionBegin()会发给客户端一个消息2的文本，并且在服务端打印一个调试信息"DoConnecionBegin is Called … "

    客户端：

    Client.go

    1. package main
    3. import (
    4.     "fmt"
    5.     "io"
    6.     "net"
    7.     "time"
    8.     "zinx/znet"
    9. )
    11. /*
    12.     模拟客户端
    13.  */
    14. func main() {
    16.     fmt.Println("Client Test ... start")
    17.     //3秒之后发起测试请求，给服务端开启服务的机会
    18.     time.Sleep(3 * time.Second)
    20.     conn,err := net.Dial("tcp", "127.0.0.1:7777")
    21.     if err != nil {
    22.         fmt.Println("client start err, exit!")
    24.     }
    25.     for {
    26.         //发封包message消息
    27.         dp := znet.NewDataPack()
    28.         msg, _ := dp.Pack(znet.NewMsgPackage(0,[]byte("Zinx V0.8 Client0 Test Message")))
    29.         _, err := conn.Write(msg)
    30.         if err !=nil {
    31.             fmt.Println("write error err ", err)
    32.             return
    33.         }
    35.         //先读出流中的head部分
    36.         headData := make([]byte, dp.GetHeadLen())
    37.         _, err = io.ReadFull(conn, headData) //ReadFull 会把msg填充满为止
    38.         if err != nil {
    39.             fmt.Println("read head error")
    40.             break
    41.         }
    42.         //将headData字节流 拆包到msg中
    43.         msgHead, err := dp.Unpack(headData)
    44.         if err != nil {
    45.             fmt.Println("server unpack err:", err)
    46.             return
    47.         }
    49.             //msg 是有data数据的，需要再次读取data数据
    50.             msg := msgHead.(*znet.Message)
    51.             msg.Data = make([]byte, msg.GetDataLen())
    53.             //根据dataLen从io中读取字节流
    54.             _, err := io.ReadFull(conn, msg.Data)
    55.             if err != nil {
    56.                 fmt.Println("server unpack data err:", err)
    57.                 return
    58.             }
    60.             fmt.Println("==> Recv Msg: ID=", msg.Id, ", len=", msg.DataLen, ", data=", string(msg.Data))
    61.         }
    63.         time.Sleep(1*time.Second)
    64.     }
    65. }

    代码不变。

    启动服务端

    1. $go run Client.go

    服务端结果:

    客户端结果：

    1. $ go run Client0.go 
    2. Client Test ... start
    3. ==> Recv Msg: ID= 2 , len= 21 , data= DoConnection BEGIN...
    4. ==> Recv Msg: ID= 0 , len= 18 , data= ping...ping...ping
    5. ==> Recv Msg: ID= 0 , len= 18 , data= ping...ping...ping
    6. ==> Recv Msg: ID= 0 , len= 18 , data= ping...ping...ping
    7. ^Csignal: interrupt

    客户端创建成功，回调Hook已经执行，并且Conn被添加到ConnManager 中， conn num = 1，

    当我们手动CTRL+C 关闭客户端的时候， 服务器ConnManager已经成功将Conn摘掉，conn num = 0.