环境：Win10 + Go1.9.2
1.先下载并引用golang的websocket库
①golang的官方库都在https://github.com/golang下，而websocket库在/net下。
②如果没有安装Git，需要先安装Git。
③使用go get -u github.com/golang/net/websocket下载代码，将安装在环境变量GOPATH配置的路径中。
代码中使用路径为 "golang.org/x/net/websocket"，在对应路径下没有代码的话则引用出错，可将对应代码放在GOPAHT/golang.org/x/net下。
2.服务端Go代码
package mainimport ( ???"fmt" ???"golang.org/x/net/websocket" ???"net/http" ???"os" ???"time")//错误处理函数func checkErr(err error, extra string) bool { ???if err != nil { ???????formatStr := " Err : %s\n"; ???????if extra != "" { ???????????formatStr = extra + formatStr; ???????} ???????fmt.Fprintf(os.Stderr, formatStr, err.Error()); ???????return true; ???} ???return false;}func svrConnHandler(conn *websocket.Conn) { ???request := make([]byte, 128); ???defer conn.Close(); ???for { ???????readLen, err := conn.Read(request) ???????if checkErr(err, "Read") { ???????????break; ???????} ???????//socket被关闭了 ???????if readLen == 0 { ???????????fmt.Println("Client connection close!"); ???????????break; ???????} else { ???????????//输出接收到的信息 ???????????fmt.Println(string(request[:readLen])) ???????????time.Sleep(time.Second); ???????????//发送 ???????????conn.Write([]byte("World !")); ???????} ???????request = make([]byte, 128); ???}}func main() { ???http.Handle("/echo", websocket.Handler(svrConnHandler)); ???err := http.ListenAndServe(":6666", nil); ???checkErr(err, "ListenAndServe"); ???fmt.Println("Func finish.");}3.
①客户端Go代码
package mainimport ( ???"fmt" ???"golang.org/x/net/websocket" ???"os" ???"sync")var gLocker sync.Mutex; ???//全局锁var gCondition *sync.Cond; //全局条件变量var origin = "http://127.0.0.1:6666/"var url = "ws://127.0.0.1:6666/echo"//错误处理函数func checkErr(err error, extra string) bool { ???if err != nil { ???????formatStr := " Err : %s\n"; ???????if extra != "" { ???????????formatStr = extra + formatStr; ???????} ???????fmt.Fprintf(os.Stderr, formatStr, err.Error()); ???????return true; ???} ???return false;}//连接处理函数func clientConnHandler(conn *websocket.Conn) { ???gLocker.Lock(); ???defer gLocker.Unlock(); ???defer conn.Close(); ???request := make([]byte, 128); ???for { ???????readLen, err := conn.Read(request) ???????if checkErr(err, "Read") { ???????????gCondition.Signal(); ???????????break; ???????} ???????//socket被关闭了 ???????if readLen == 0 { ???????????fmt.Println("Server connection close!"); ???????????//条件变量同步通知 ???????????gCondition.Signal(); ???????????break; ???????} else { ???????????//输出接收到的信息 ???????????fmt.Println(string(request[:readLen])) ???????????//发送 ???????????conn.Write([]byte("Hello !")); ???????} ???????request = make([]byte, 128); ???}}func main() { ???conn, err := websocket.Dial(url, "", origin); ???if checkErr(err, "Dial") { ???????return; ???} ???gLocker.Lock(); ???gCondition = sync.NewCond(&gLocker); ???_, err = conn.Write([]byte("Hello !")); ???go clientConnHandler(conn); ???//主线程阻塞，等待Singal结束 ???for { ???????//条件变量同步等待 ???????gCondition.Wait(); ???????break; ???} ???gLocker.Unlock(); ???fmt.Println("Client finish.")}②如果客户端不使用Go代码，可以使用Cocos Creator的js代码
cc.Class({ ???extends: cc.Component, ???properties: { ???}, ???ctor: function () { ???????this.ws = null; ???}, ???onLoad: function () { ???????var self = this; ???????this.ws = new WebSocket("ws://127.0.0.1:6666/echo"); ???????this.ws.onopen = function (event) { ???????????console.log("Send Text WS was opened."); ???????????if (self.ws.readyState === WebSocket.OPEN) { ???????????????self.ws.send("Hello !"); ???????????} ???????????else{ ???????????????console.log("WebSocket instance wasn‘t ready..."); ???????????} ???????}; ???????this.ws.onmessage = function (event) { ???????????console.log("response text msg: " + event.data); ???????????self.ws.send("Hello !"); ???????}; ???????this.ws.onerror = function (event) { ???????????console.log("Send Text fired an error"); ???????}; ???????this.ws.onclose = function (event) { ???????????console.log("WebSocket instance closed."); ???????}; ???}, ???// called every frame ???update: function (dt) { ???},});以上。
Golang websocket
原文地址：https://www.cnblogs.com/chevin/p/8086999.html