[Go] 實現websocket服務端


直接使用官方子包可以實現websocket協議,

golang.org/x/net/websocket
如果在這個目錄沒有這個包就去github下載net庫,放進這個目錄$GOPATH/src/golang.org/x/net就行了
服務端代碼:
package main

import (
    "time"
    "log"
    "net/http"
    "golang.org/x/net/websocket"
)
func main(){
    http.HandleFunc("/",index)
    http.Handle("/websocket",websocket.Handler(instantMessage))
    log.Println("start server")
    err:=http.ListenAndServe(":1234",nil)
    log.Println(err)
}
func index(res http.ResponseWriter,req *http.Request){
    res.Write([]byte("hello world"))
}
func instantMessage(w *websocket.Conn)  {
    var error error
    for {
        var reply string
        if  error= websocket.Message.Receive(w,&reply);error!=nil{
            log.Println("接受消息失敗",error)
            break
        }
        log.Println("客戶端:",reply)
        
        msg:="服務端:"+reply+time.Now().String()
        log.Println(msg)
        if error = websocket.Message.Send(w, msg); error != nil {
            log.Println("發送消息失敗")
            break
        }
    }
}

客戶端代碼:

<html>
<head>
    <title>好好學習</title>
</head>
<body>
<script type="text/javascript">
    var sock = null;
    // var wsuri = "wss://127.0.0.1:8080"; //本地的地址 是可以改變的哦
     var wsuri = "ws://localhost:1234/websocket"; //本地的地址 是可以改變的哦


    window.onload = function() {
        //可以看到客戶端JS,很容易的就通過WebSocket函數建立了一個與服務器的連接sock,當握手成功后,會觸發WebScoket對象的onopen事件,告訴客戶端連接已經成功建立。客戶端一共綁定了四個事件。
        console.log("開始了 onload");
        sock = new WebSocket(wsuri);
        //建立連接后觸發
        sock.onopen = function() {
            console.log(" 建立連接后觸發 connected to " + wsuri);
        }
        // 關閉連接時候觸發
        sock.onclose = function(e) {
            console.log("關閉連接時候觸發 connection closed (" + e.code + ")");
        }
        // 收到消息后觸發
        sock.onmessage = function(e) {
            console.log("收到消息后觸發 message received: " + e.data);
            document.getElementById('receive').innerHTML=e.data;
        }
        //發生錯誤的時候觸發
        sock.onerror=function (e) {
            console.log("發生錯誤時候觸發"+wsuri)
        }
    };
     //如果sock被關閉掉了 這里 也會報錯的啊
    function send() {
        var msg = document.getElementById('message').value;
        sock.send(msg);
    };
</script>
<h1>客戶端</h1>
<form>
    <p>發送: </p>
    <textarea id="message" >我是陶士涵</textarea>
    <p>接收: </p>
    <textarea id="receive" ></textarea>
</form>
<button onclick="send();">給服務器發送消息</button>
</body>
</html>

 

 

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM