) var upgrader = websocket.Upgrader{ CheckOrigin: func(r *http.Reques"> ) var upgrader = websocket.Upgrader{ CheckOrigin: func(r *http.Reques">
117.info
人生若只如初见

怎么使用Go语言实现WebSocket通信

在Go语言中实现WebSocket通信,可以使用标准库中提供的net/httpgithub.com/gorilla/websocket包。以下是一个简单的示例:

package main

import (
	"fmt"
	"net/http"

	"github.com/gorilla/websocket"
)

var upgrader = websocket.Upgrader{
	CheckOrigin: func(r *http.Request) bool {
		return true
	},
}

func handler(w http.ResponseWriter, r *http.Request) {
	conn, err := upgrader.Upgrade(w, r, nil)
	if err != nil {
		fmt.Println("Error upgrading to WebSocket:", err)
		return
	}

	for {
		// 读取客户端发送的消息
		_, message, err := conn.ReadMessage()
		if err != nil {
			fmt.Println("Error reading message:", err)
			break
		}

		// 输出客户端发送的消息
		fmt.Printf("Received message: %s\n", message)

		// 发送消息给客户端
		err = conn.WriteMessage(websocket.TextMessage, []byte("Message received"))
		if err != nil {
			fmt.Println("Error writing message:", err)
			break
		}
	}
}

func main() {
	http.HandleFunc("/", handler)
	http.ListenAndServe(":8080", nil)
}

在上面的代码中,我们首先创建了一个upgrader实例,用于将HTTP连接升级为WebSocket连接。然后定义了一个处理函数handler,当有客户端连接时会调用该函数。在处理函数中,我们通过upgrader.Upgrade方法将HTTP连接升级为WebSocket连接,并通过conn.ReadMessage读取客户端发送的消息,然后通过conn.WriteMessage发送消息给客户端。

最后在main函数中,我们通过http.HandleFunc将处理函数注册到路由上,然后通过http.ListenAndServe启动HTTP服务器,监听在8080端口上。

在客户端可以使用JavaScript来与该WebSocket服务器进行通信,例如:

const ws = new WebSocket("ws://localhost:8080/");

ws.onopen = function() {
    console.log("Connected to WebSocket server");
    ws.send("Hello, server!");
};

ws.onmessage = function(event) {
    console.log("Received message from server:", event.data);
};

通过这种方式,可以使用Go语言实现WebSocket通信。

未经允许不得转载 » 本文链接:https://www.117.info/ask/fe31eAzsIBg5SA1M.html

推荐文章

  • go语言在linux如何安装

    在Linux上安装Go语言,你可以按照以下步骤操作: 首先,你需要下载Go语言的安装包。访问Go的官方下载页面(https://golang.org/dl/ ),选择适合你的Linux发行版...

  • go语言在linux内存管理

    Go语言在Linux下的内存管理主要依赖于其内置的垃圾回收机制(Garbage Collection,简称GC)和内存分配器。Go的内存管理设计旨在提供高效、安全且易于理解的内存使...

  • go语言在linux错误处理

    在Go语言中,错误处理是通过返回值的方式进行的。通常,一个函数在遇到错误时会返回一个错误类型(error),你可以检查这个返回值来判断是否发生了错误。在Linux...

  • go语言在linux文件操作

    在Go语言中,可以使用标准库中的os和io/ioutil包来执行Linux文件操作。以下是一些常见的文件操作示例: 创建文件: package main import ( "fmt" "io/ioutil" "l...

  • Go语言中的协程调度怎么实现

    Go语言中的协程调度是由Go语言的运行时系统(runtime)负责的。在Go语言中,每一个goroutine都会被分配给一个操作系统线程来执行,而goroutine之间的调度是由Go语...

  • Go语言垃圾回收机制是怎么工作的

    Go语言的垃圾回收机制使用的是并发标记-清除算法。当一个Go程序运行时,垃圾回收器会周期性地检查程序中不再使用的对象,并且回收它们所占用的内存。垃圾回收器会...

  • 怎么使用Go语言实现加密和解密操作

    在Go语言中,可以使用crypto包来实现加密和解密操作。下面是一个简单的示例,演示如何使用Go语言进行AES加密和解密操作:
    package main import ( "crypto/a...

  • Go语言中的Ticker如何使用

    Ticker是一个定时触发的定时器,它会每隔一段时间向一个通道发送一个事件。
    下面是一个简单的示例,演示了如何使用Ticker来定时执行任务:
    package ma...