代码拉取完成,页面将自动刷新
package main
import (
"encoding/json"
"github.com/gorilla/websocket"
"log"
"net/url"
"os"
"os/signal"
"time"
)
var max = 10
func main() {
interrupt := make(chan os.Signal, 1)
signal.Notify(interrupt, os.Interrupt)
// Path: "/echo"
u := url.URL{Scheme: "ws", Host: "192.168.1.24:7018"}
log.Println("connecting to ", u.String())
conn, _, err := websocket.DefaultDialer.Dial(u.String(), nil)
if err != nil {
log.Fatal("dial err:", err)
return
}
defer conn.Close()
go timeWriter(conn)
i := 0
for {
//第一个包
mt, msg, err := conn.ReadMessage()
if err != nil {
log.Fatal("read err:", err)
return
}
log.Println("main ReadMessage read server mt:", mt, " message:", string(msg[:]))
i++
}
//阻塞
// select {}
time.Sleep(60 * time.Second)
log.Println("client exit")
}
func timeWriter(conn *websocket.Conn) {
var i = 0
for {
//发第一个消息
msg := &Account{Name: "第一个包 hello,张三", Age: i, Passwd: "123456"}
jsonData, err := json.Marshal(msg)
if err != nil {
log.Println("client timeWriter Marshal err:", err, " msg:", msg)
break
}
conn.WriteMessage(websocket.TextMessage, jsonData)
//cpu阻塞下,等待读取完
time.Sleep(5 * time.Second)
i++
if i > max {
break
}
}
}
type Account struct {
Name string
Age int
Passwd string
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。