#### 5.4 使用Zinx-V0.5完成應用程序 現在我們可以基于Zinx框架完成發送msg功能的測試用例了。 > Server.go ```go package main import ( "fmt" "zinx/ziface" "zinx/znet" ) //ping test 自定義路由 type PingRouter struct { znet.BaseRouter } //Test Handle func (this *PingRouter) Handle(request ziface.IRequest) { fmt.Println("Call PingRouter Handle") //先讀取客戶端的數據，再回寫ping...ping...ping fmt.Println("recv from client : msgId=", request.GetMsgID(), ", data=", string(request.GetData())) //回寫數據 err := request.GetConnection().SendMsg(1, []byte("ping...ping...ping")) if err != nil { fmt.Println(err) } } func main() { //創建一個server句柄 s := znet.NewServer() //配置路由 s.AddRouter(&PingRouter{}) //開啟服務 s.Serve() } ``` 當前Server端是先把客戶端發送來Msg解析，然后返回一個MsgId為1的消息，消息內容是"ping...ping...ping" > Client.go ```go package main import ( "fmt" "io" "net" "time" "zinx/znet" ) /* 模擬客戶端 */ func main() { fmt.Println("Client Test ... start") //3秒之后發起測試請求，給服務端開啟服務的機會 time.Sleep(3 * time.Second) conn,err := net.Dial("tcp", "127.0.0.1:7777") if err != nil { fmt.Println("client start err, exit!") return } for { //發封包message消息 dp := znet.NewDataPack() msg, _ := dp.Pack(znet.NewMsgPackage(0,[]byte("Zinx V0.5 Client Test Message"))) _, err := conn.Write(msg) if err !=nil { fmt.Println("write error err ", err) return } //先讀出流中的head部分 headData := make([]byte, dp.GetHeadLen()) _, err = io.ReadFull(conn, headData) //ReadFull 會把msg填充滿為止 if err != nil { fmt.Println("read head error") break } //將headData字節流 拆包到msg中 msgHead, err := dp.Unpack(headData) if err != nil { fmt.Println("server unpack err:", err) return } if msgHead.GetDataLen() > 0 { //msg 是有data數據的，需要再次讀取data數據 msg := msgHead.(*znet.Message) msg.Data = make([]byte, msg.GetDataLen()) //根據dataLen從io中讀取字節流 _, err := io.ReadFull(conn, msg.Data) if err != nil { fmt.Println("server unpack data err:", err) return } fmt.Println("==> Recv Msg: ID=", msg.Id, ", len=", msg.DataLen, ", data=", string(msg.Data)) } time.Sleep(1*time.Second) } } ``` 這里Client客戶端，模擬了一個MsgId為0的"Zinx V0.5 Client Test Message"消息，然后把服務端返回的數據打印出來。 我們分別在兩個終端運行 ``` $go run Server.go ``` ``` $go run Client.go ``` 服務端結果: ```bash $ go run Server.go Add Router succ! [START] Server name: zinx v-0.5 demoApp,listenner at IP: 127.0.0.1, Port 7777 is starting [Zinx] Version: V0.4, MaxConn: 3, MaxPacketSize: 4096 start Zinx server zinx v-0.5 demoApp succ, now listenning... Reader Goroutine is running Call PingRouter Handle recv from client : msgId= 0 , data= Zinx V0.5 Client Test Message Call PingRouter Handle recv from client : msgId= 0 , data= Zinx V0.5 Client Test Message Call PingRouter Handle recv from client : msgId= 0 , data= Zinx V0.5 Client Test Message ... ``` 客戶端結果: ```bash $ go run Client.go Client Test ... start ==> Recv Msg: ID= 1 , len= 18 , data= ping...ping...ping ==> Recv Msg: ID= 1 , len= 18 , data= ping...ping...ping ==> Recv Msg: ID= 1 , len= 18 , data= ping...ping...ping ... ``` 好了，我們的Zinx已經成功的集成消息的封裝功能了，這樣我們就有Zinx的通信的基本協議標準了。