6.3 使用Zinx-V0.6完成应用程序

Server.go

  1. package main
  3. import (
  4.     "fmt"
  5.     "zinx/ziface"
  6.     "zinx/znet"
  7. )
  9. //ping test 自定义路由
  10. type PingRouter struct {
  11.     znet.BaseRouter
  12. }
  14. //Ping Handle
  15. func (this *PingRouter) Handle(request ziface.IRequest) {
  16.     fmt.Println("Call PingRouter Handle")
  17.     //先读取客户端的数据，再回写ping...ping...ping
  18.     fmt.Println("recv from client : msgId=", request.GetMsgID(), ", data=", string(request.GetData()))
  20.     err := request.GetConnection().SendMsg(0, []byte("ping...ping...ping"))
  21.     if err != nil {
  22.         fmt.Println(err)
  23.     }
  24. }
  26. //HelloZinxRouter Handle
  27. type HelloZinxRouter struct {
  28.     znet.BaseRouter
  29. }
  31. func (this *HelloZinxRouter) Handle(request ziface.IRequest) {
  32.     fmt.Println("Call HelloZinxRouter Handle")
  33.     //先读取客户端的数据，再回写ping...ping...ping
  34.     fmt.Println("recv from client : msgId=", request.GetMsgID(), ", data=", string(request.GetData()))
  36.     err := request.GetConnection().SendMsg(1, []byte("Hello Zinx Router V0.6"))
  37.     if err != nil {
  38.         fmt.Println(err)
  39.     }
  40. }
  42. func main() {
  43.     //创建一个server句柄
  44.     s := znet.NewServer()
  46.     //配置路由
  47.     s.AddRouter(0, &PingRouter{})
  48.     s.AddRouter(1, &HelloZinxRouter{})
  50.     //开启服务
  51.     s.Serve()
  52. }

Server端设置了2个路由，一个是MsgId为0的消息会执行PingRouter{}重写的Handle()方法，一个是MsgId为1的消息会执行HelloZinxRouter{}重写的Handle()方法。

我们现在写两个客户端，分别发送0消息和1消息来进行测试Zinx是否能够处理2个不同的消息业务。

Client0.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!")
  23.         return
  24.     }
  26.     for {
  27.         //发封包message消息
  28.         dp := znet.NewDataPack()
  29.         msg, _ := dp.Pack(znet.NewMsgPackage(0,[]byte("Zinx V0.6 Client0 Test Message")))
  30.         _, err := conn.Write(msg)
  31.         if err !=nil {
  32.             fmt.Println("write error err ", err)
  33.             return
  34.         }
  36.         //先读出流中的head部分
  37.         headData := make([]byte, dp.GetHeadLen())
  38.         _, err = io.ReadFull(conn, headData) //ReadFull 会把msg填充满为止
  39.         if err != nil {
  40.             fmt.Println("read head error")
  41.             break
  42.         }
  43.         //将headData字节流 拆包到msg中
  44.         msgHead, err := dp.Unpack(headData)
  45.         if err != nil {
  46.             fmt.Println("server unpack err:", err)
  47.             return
  48.         }
  50.         if msgHead.GetDataLen() > 0 {
  51.             //msg 是有data数据的，需要再次读取data数据
  52.             msg := msgHead.(*znet.Message)
  53.             msg.Data = make([]byte, msg.GetDataLen())
  55.             //根据dataLen从io中读取字节流
  56.             _, err := io.ReadFull(conn, msg.Data)
  57.             if err != nil {
  58.                 fmt.Println("server unpack data err:", err)
  59.                 return
  60.             }
  62.             fmt.Println("==> Recv Msg: ID=", msg.Id, ", len=", msg.DataLen, ", data=", string(msg.Data))
  63.         }
  65.         time.Sleep(1*time.Second)
  66.     }
  67. }

Client1.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!")
  23.         return
  24.     }
  26.     for {
  27.         //发封包message消息
  28.         dp := znet.NewDataPack()
  29.         msg, _ := dp.Pack(znet.NewMsgPackage(1,[]byte("Zinx V0.6 Client1 Test Message")))
  30.         _, err := conn.Write(msg)
  31.         if err !=nil {
  32.             fmt.Println("write error err ", err)
  33.             return
  34.         }
  36.         //先读出流中的head部分
  37.         headData := make([]byte, dp.GetHeadLen())
  38.         _, err = io.ReadFull(conn, headData) //ReadFull 会把msg填充满为止
  39.         if err != nil {
  40.             fmt.Println("read head error")
  41.             break
  42.         }
  43.         //将headData字节流 拆包到msg中
  44.         msgHead, err := dp.Unpack(headData)
  45.         if err != nil {
  46.             fmt.Println("server unpack err:", err)
  47.             return
  48.         }
  50.         if msgHead.GetDataLen() > 0 {
  51.             //msg 是有data数据的，需要再次读取data数据
  52.             msg := msgHead.(*znet.Message)
  53.             msg.Data = make([]byte, msg.GetDataLen())
  55.             //根据dataLen从io中读取字节流
  56.             _, err := io.ReadFull(conn, msg.Data)
  57.             if err != nil {
  58.                 fmt.Println("server unpack data err:", err)
  59.                 return
  60.             }
  62.             fmt.Println("==> Recv Msg: ID=", msg.Id, ", len=", msg.DataLen, ", data=", string(msg.Data))
  63.         }
  65.         time.Sleep(1*time.Second)
  66.     }
  67. }

分别执行服务端和两个客户端

  1. $go run Server.go
  1. $go run Client0.go
  1. $go run Client1.go

服务端显示结果

  1. $ go run Server.go 
  2. Add api msgId =  0
  3. Add api msgId =  1
  4. [START] Server name: zinx v-0.6 demoApp,listenner at IP: 127.0.0.1, Port 7777 is starting
  5. [Zinx] Version: V0.4, MaxConn: 3, MaxPacketSize: 4096
  6. start Zinx server   zinx v-0.6 demoApp  succ, now listenning...
  7. Reader Goroutine is  running
  8. Call PingRouter Handle
  9. recv from client : msgId= 0 , data= Zinx V0.6 Client0 Test Message
  10. Reader Goroutine is  running
  11. Call HelloZinxRouter Handle
  12. recv from client : msgId= 1 , data= Zinx V0.6 Client1 Test Message
  13. Call PingRouter Handle
  14. recv from client : msgId= 0 , data= Zinx V0.6 Client0 Test Message
  15. Call HelloZinxRouter Handle
  16. recv from client : msgId= 1 , data= Zinx V0.6 Client1 Test Message
  17. Call PingRouter Handle
  18. recv from client : msgId= 0 , data= Zinx V0.6 Client0 Test Message
  19. Call HelloZinxRouter Handle
  20. recv from client : msgId= 1 , data= Zinx V0.6 Client1 Test Message

客户端0显示结果

  1. $ go run Client0.go 
  2. Client Test ... start
  3. ==> Recv Msg: ID= 0 , len= 18 , data= ping...ping...ping
  4. ==> Recv Msg: ID= 0 , len= 18 , data= ping...ping...ping
  5. ==> Recv Msg: ID= 0 , len= 18 , data= ping...ping...ping

客户端1显示结果

  1. $ go run Client1.go 
  2. Client Test ... start
  3. ==> Recv Msg: ID= 1 , len= 22 , data= Hello Zinx Router V0.6
  4. ==> Recv Msg: ID= 1 , len= 22 , data= Hello Zinx Router V0.6
  5. ==> Recv Msg: ID= 1 , len= 22 , data= Hello Zinx Router V0.6