#### 6.3 使用Zinx-V0.6完成應用程序 > Server.go ```go package main import ( "fmt" "zinx/ziface" "zinx/znet" ) //ping test 自定義路由 type PingRouter struct { znet.BaseRouter } //Ping 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(0, []byte("ping...ping...ping")) if err != nil { fmt.Println(err) } } //HelloZinxRouter Handle type HelloZinxRouter struct { znet.BaseRouter } func (this *HelloZinxRouter) Handle(request ziface.IRequest) { fmt.Println("Call HelloZinxRouter Handle") //先讀取客戶端的數據，再回寫ping...ping...ping fmt.Println("recv from client : msgId=", request.GetMsgID(), ", data=", string(request.GetData())) err := request.GetConnection().SendMsg(1, []byte("Hello Zinx Router V0.6")) if err != nil { fmt.Println(err) } } func main() { //創建一個server句柄 s := znet.NewServer() //配置路由 s.AddRouter(0, &PingRouter{}) s.AddRouter(1, &HelloZinxRouter{}) //開啟服務 s.Serve() } ``` Server端設置了2個路由，一個是MsgId為0的消息會執行PingRouter{}重寫的`Handle()`方法，一個是MsgId為1的消息會執行HelloZinxRouter{}重寫的`Handle()`方法。 我們現在寫兩個客戶端，分別發送0消息和1消息來進行測試Zinx是否能夠處理2個不同的消息業務。 > Client0.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.6 Client0 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) } } ``` > Client1.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(1,[]byte("Zinx V0.6 Client1 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) } } ``` 分別執行服務端和兩個客戶端 ``` $go run Server.go ``` ``` $go run Client0.go ``` ``` $go run Client1.go ``` 服務端顯示結果 ```bash $ go run Server.go Add api msgId = 0 Add api msgId = 1 [START] Server name: zinx v-0.6 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.6 demoApp succ, now listenning... Reader Goroutine is running Call PingRouter Handle recv from client : msgId= 0 , data= Zinx V0.6 Client0 Test Message Reader Goroutine is running Call HelloZinxRouter Handle recv from client : msgId= 1 , data= Zinx V0.6 Client1 Test Message Call PingRouter Handle recv from client : msgId= 0 , data= Zinx V0.6 Client0 Test Message Call HelloZinxRouter Handle recv from client : msgId= 1 , data= Zinx V0.6 Client1 Test Message Call PingRouter Handle recv from client : msgId= 0 , data= Zinx V0.6 Client0 Test Message Call HelloZinxRouter Handle recv from client : msgId= 1 , data= Zinx V0.6 Client1 Test Message ``` 客戶端0顯示結果 ```bash $ go run Client0.go Client Test ... start ==> Recv Msg: ID= 0 , len= 18 , data= ping...ping...ping ==> Recv Msg: ID= 0 , len= 18 , data= ping...ping...ping ==> Recv Msg: ID= 0 , len= 18 , data= ping...ping...ping ``` 客戶端1顯示結果 ```bash $ go run Client1.go Client Test ... start ==> Recv Msg: ID= 1 , len= 22 , data= Hello Zinx Router V0.6 ==> Recv Msg: ID= 1 , len= 22 , data= Hello Zinx Router V0.6 ==> Recv Msg: ID= 1 , len= 22 , data= Hello Zinx Router V0.6 ```