golang網(wǎng)絡(luò)編程學(xué)習(xí)-websocket
網(wǎng)絡(luò)編程主要的內(nèi)容是：
1.TCP網(wǎng)絡(luò)編程
2.http服務(wù)
3.rpc服務(wù)
4.websocket服務(wù)
?一、websocket編程
1.1服務(wù)端，代碼來自網(wǎng)絡(luò)，僅限于學(xué)習(xí)研究
package main
import (
"fmt"
"net/http"
"os"
"reflect"
"time"
"unsafe"
"github.com/gorilla/websocket"
)
type HttpHandler struct {
http.Handler
}
func main() {
var httpHandler HttpHandler
http.Handle("/connect", httpHandler)
if err := http.ListenAndServe(":9999", nil); err != nil {
fmt.Println("程序退出")
os.Exit(1)
}
}
func (httpHandler HttpHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
fmt.Println("程序進(jìn)入監(jiān)聽>>")
var upgrader = websocket.Upgrader{
//解決跨域問題
CheckOrigin: func(r *http.Request) bool {
return true
},
}
conn, err := upgrader.Upgrade(w, r, nil)
if err != nil {
fmt.Println("upgrade error:", err)
return
}
defer conn.Close()
conn.SetReadDeadline(time.Now().Add(6 * time.Second))
conn.SetPongHandler(func(string) error {
fmt.Println("接收心跳響應(yīng)<<")
conn.SetReadDeadline(time.Now().Add(6 * time.Second))
return nil
})
ticker := time.NewTicker(2 * time.Second)
go func() {
for {
//從定時器中獲取數(shù)據(jù)
_ = <-ticker.C
fmt.Println("發(fā)送心跳包>>")
conn.WriteMessage(websocket.PingMessage, []byte{})
}
}()
defer ticker.Stop()
for {
messageType, message, err := conn.ReadMessage()
if err != nil {
fmt.Println("接收異常：", err)
break
}
fmt.Println(fmt.Sprintf("接收消息內(nèi)容 >>%s", message))
respMessage := fmt.Sprintf("I am Server, %s.", time.Now().Format("2006-01-02 15:04:05"))
err = conn.WriteMessage(messageType, String2Bytes(respMessage))
if err != nil {
fmt.Println("發(fā)送異常：", err)
break
}
}
}
func String2Bytes(s string) []byte {
sh := (*reflect.StringHeader)(unsafe.Pointer(&s))
bh := reflect.SliceHeader{
Data: sh.Data,
Len: sh.Len,
Cap: sh.Len,
}
return *(*[]byte)(unsafe.Pointer(&bh))
}
?文章來源地址http://www.zghlxwxcb.cn/news/detail-583645.html
服務(wù)端截圖
?
1.2客戶端，代碼來自網(wǎng)絡(luò)，僅限于學(xué)習(xí)研究
<html>
<head>
<meta charset="UTF-8"/>
</head>
<body>
<div>
<button onclick="start()" style="width:80px;height:30px;line-height:24px;">開始</button>
<button onclick="stop()" style="width:80px;height:30px;line-height:24px;">停止</button>
<button onclick="reset()" style="width:80px;height:30px;line-height:24px;">重置</button>
</div>
<div id="connect-show">未連接</div>
<div id="rec-show"></div>
</body>
<script type="text/javascript">
var ws;
var interval;
function rewebsocket() {
//ws = new WebSocket("ws://127.0.0.1:9999/connect");
ws = new WebSocket("ws://127.0.0.1:9999/connect");
//連接建立時觸發(fā)
ws.onopen = function() {
document.getElementById("connect-show").innerHTML = "連接成功";
send(ws);
}
//連接關(guān)閉時觸發(fā)
ws.onclose = function() {
document.getElementById("connect-show").innerHTML = "連接已關(guān)閉";
}
//通信發(fā)生錯誤時觸發(fā)
ws.onerror = function() {
document.getElementById("connect-show").innerHTML = "連接通訊成功";
}
//客戶端接收服務(wù)端數(shù)據(jù)時觸發(fā)
ws.onmessage = function(e) {
var recMsg = e.data;
var element = document.getElementById("rec-show");
var nodes = element.childNodes;
if (nodes && nodes.length >= 20) {
element.removeChild(nodes[nodes.length-1])
}
element.innerHTML = ("<div>" + recMsg + "</div>" + element.innerHTML);
}
}
//啟動
function start() {
if (ws == undefined || ws.readyState >= 2) {
rewebsocket();
}
}
//停止
function stop() {
clearInterval(interval);
closeWebsocket(ws);
interval = undefined;
ws = undefined;
}
//重置
function reset() {
stop();
document.getElementById("connect-show").innerHTML = "未連接";
document.getElementById("rec-show").innerHTML = "";
start();
}
//消息發(fā)送策略
function send(ws) {
interval = setInterval(() => {
ws.send("I am client, " + getTime() + ".")
},1000);
}
//獲取客戶端年月日時分秒
function getTime() {
return new Date( +new Date() + 8 * 3600 * 1000 ).toJSON().substr(0,19).replace("T"," ");
}
//關(guān)閉websocket連接
function closeWebsocket(ws) {
try {
if (ws != undefined && ws.readyState < 2) {
ws.close();
}
} catch (err){}
}
</script>
</html>
?
?
?客戶端瀏覽器運(yùn)行內(nèi)容信息
?
文章來源：http://www.zghlxwxcb.cn/news/detail-583645.html
?
到了這里，關(guān)于golang網(wǎng)絡(luò)編程學(xué)習(xí)-websocket的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
