当前位置：首页 > news >正文

golang Gin实现websocket

news 2025/7/12 8:34:23

golang使用 Gin实现 websocket，这里笔者重新搭建一个项目

1、创建项目安装依赖

项目名为 go-gin-websocket

在指定文件夹下，新建项目文件夹 go-gin-websocket

进入项目文件夹，打开cmd窗口，在项目（go-gin-websocket）文件夹路径下，执行初始化命令 go mod init go-gin-websocket

go mod init go-gin-websocket

安装依赖

安装gin

go get -u github.com/gin-gonic/gin

安装websocket

go get github.com/gorilla/websocket

2、搭建项目

在项目目录下新建controller、static、templates、ws文件夹，分别用来存放controller代码、静态文件、页面、websocket代码

在templates目录下新建 index.html页面

<!DOCTYPE html>
<html lang="en">
<head><meta charset="UTF-8"><title>Title</title>
</head>
<body>
hello
<script>var webSocket;try {webSocket = new WebSocket('ws://127.0.0.1:8080/ws?id=abc123456789');}catch (e) {console.log(e)}webSocket.onerror = function(event) {}//与WebSocket建立连接webSocket.onopen = function(event) {console.log('建立连接')console.log(JSON.stringify(event))var msg = "身无彩凤双飞翼，心有灵犀一点通"//发送消息webSocket.send(msg);};//接收服务端发送的消息webSocket.onmessage=function (m) {console.log(m)console.log(m.data)}
</script>
</body>
</html>

在controller目录下新建 page_controller.go

package controllerimport "github.com/gin-gonic/gin"func Index(c *gin.Context) {c.HTML(200, "index.html", nil)
}

在ws目录下新建 websocket.go

package wsimport ("fmt""github.com/gin-gonic/gin""github.com/gorilla/websocket""log""net/http"
)func InitWebSocket(c *gin.Context) {var upgrader = websocket.Upgrader{ReadBufferSize:  1024,WriteBufferSize: 1024,CheckOrigin: func(r *http.Request) bool {log.Println("升级协议", r.Header["User-Agent"])return true},}conn, err := upgrader.Upgrade(c.Writer, c.Request, nil)if err != nil {log.Println(err)return}defer conn.Close()userId := c.Query("id")log.Println("用户id:", userId)for {mt, message, err := conn.ReadMessage()log.Println("获取客户端发送的消息:" + string(message))fmt.Println(mt)if err != nil {log.Println(err)break}var msg = "春风得意马蹄疾,一日看尽长安花"err2 := conn.WriteMessage(websocket.TextMessage, []byte(msg))if err2 != nil {log.Println("write:", err2)break}}}

在项目根目录下新建 main.go

main.go内容

package mainimport ("github.com/gin-gonic/gin""go-gin-websocket/controller""go-gin-websocket/ws"
)func main() {e := gin.Default()//html页面位置e.LoadHTMLGlob("templates/*")//静态文件位置e.Static("/static", "./static")e.GET("/", controller.Index)e.GET("/ws", ws.InitWebSocket)e.Run("0.0.0.0:8080")
}

3、运行测试

浏览器请求 http://localhost:8080/

4、添加session

添加session用来存储在线用户

这里使用一个map用来保存，key是用户id，value是websocket连接，再加一个读写锁保证线程安全

package wsimport ("fmt""github.com/gin-gonic/gin""github.com/gorilla/websocket""log""net/http""sync"
)var connects = make(map[string]*websocket.Conn)
var lock sync.RWMutexfunc addSession(id string, conn *websocket.Conn) {lock.Lock()connects[id] = conndefer lock.Unlock()
}
func getSession(id string) *websocket.Conn {lock.RLock()defer lock.RUnlock()return connects[id]
}
func removeSession(id string) {lock.Lock()delete(connects, id)defer lock.Unlock()
}func InitWebSocket(c *gin.Context) {var upgrader = websocket.Upgrader{ReadBufferSize:  1024,WriteBufferSize: 1024,CheckOrigin: func(r *http.Request) bool {log.Println("升级协议", r.Header["User-Agent"])return true},}conn, err := upgrader.Upgrade(c.Writer, c.Request, nil)if err != nil {log.Println(err)return}defer conn.Close()userId := c.Query("id")log.Println("用户id:", userId)//添加sessionaddSession(userId, conn)for {mt, message, err := conn.ReadMessage()log.Println("获取客户端发送的消息:" + string(message))fmt.Println(mt)if err != nil {log.Println(err)break}var msg = "春风得意马蹄疾,一日看尽长安花"err2 := conn.WriteMessage(websocket.TextMessage, []byte(msg))if err2 != nil {log.Println("write:", err2)break}}}

至此完

golang Gin实现websocket

golang使用 Gin实现 websocket，这里笔者重新搭建一个项目 1、创建项目安装依赖项目名为 go-gin-websocket 在指定文件夹下，新建项目文件夹 go-gin-websocket 进入项目文件夹，打开cmd窗口，在项目（go-gin-websocket&a…...

编程日记 2023/4/30 15:24:53

冯·诺依曼体系结构与初始操作系统

目录冯诺依曼体系结构冯诺依曼体系结构图内存外存网卡和磁盘结构之间运算速度的差异缓冲区初始操作系统概念操作系统上边与下边分别有什么从上到下依次顺序解析用户用户操作接口系统调用接口操作系统四项管理驱动硬件冯诺依曼体系结构冯诺…...

编程日记 2023/4/30 15:19:52

软件测试之黑盒测试的具体方法详解

提示：文章写完后，目录可以自动生成，如何生成可参考右边的帮助文档文章目录前言一.基于需求的设计方法二.等价类三.边界值四.判定表4.1 **关系**4.2 如何设计测试用例4.3 实际案例第一步第二步第三步第四步五.正交排列5.1 什么是正交表5.2 …...

编程日记 2023/4/30 15:14:51

图形编辑器：历史记录设计

大家好，我是前端西瓜哥。今天讲一下图形编辑器如何实现历史记录，做到撤销重做。其实就是版本号的更替。每个版本保存一个状态。数据结构要记录图形编辑器的历史记录，支持撤销重做功能，需要两个栈：撤销&#xff0…...

编程日记 2023/4/30 15:09:50

ubuntu22.04下挂载第二块硬盘

文章目录一、查看硬盘情况二、找到nvme1n1三、挂载四、修改分区文件一、查看硬盘情况首先要查看一下系统识别出来的设备。也就是说，我希望知道，ubuntu到底发现了几块硬盘。用命令：lsblk 显示结果如下： 有两块硬盘&#xff1a…...

编程日记 2023/5/30 23:59:17

举例说明.net中in与out的作用与区别

-----作用在 .NET 中，in 和 out 是用于泛型类型参数的修饰符，它们用于指定参数类型的协变性和逆变性。 - in 修饰符：表示这个泛型类型参数是协变的。也就是说，in 类型参数可以从较特殊的类型隐式转换为较通用的类型。例如&…...

编程日记 2023/4/30 14:59:47

Java常见的100道面试题（内附答案及代码示例）持续更新

什么是Java程序？ Java程序是一组可执行的代码，由Java编译器编译生成，可以在Java虚拟机（JVM）上运行。 public class HelloWorld {public static void main(String[] args) {System.out.println("Hello, World!&qu…...

编程日记 2023/4/30 14:54:46

策略设计模式知多少

目录目标概述实现目标熟悉策略设计模式，了解策略设计模式的使用场景、具体实现。概述一、行为设计模式行为设计模式是设计模式的一种类型。该类型的设计模式关注的重点在于对象的行为（通信和交互），而非对象的创建方…...

编程日记 2023/5/29 19:26:56

第三十九章配置镜像 - 配置 ISCAgent - 在 UNIX Linux 和 macOS 系统上为非根实例启动 ISCAgent

文章目录第三十九章配置镜像 - 配置 ISCAgent - 在 UNIX Linux 和 macOS 系统上为非根实例启动 ISCAgent在 UNIX/Linux 和 macOS 系统上为非根实例启动 ISCAgent在 Microsoft Windows 系统上启动 ISCAgent 自定义 ISCAgent 第三十九章配置镜像 - 配置 ISCAgent - 在 UNIX Li…...

编程日记 2023/4/30 14:44:44

文章目录 Camera2介绍Camera2的主要API类介绍CameraManager通过CameraManage获取Cameracharacteristics通过CameraManage获取CameraDevice从CameraDevice获取CameraCaptureSession预览效果参考 Camera2介绍从Android 5.0开始，Google 引入了一套全新的相机框架 Ca…...

编程日记 2023/4/30 14:39:43

阿里云g8i服务器Intel Xeon(Sapphire Rapids) Platinum 8475B

阿里云服务器ECS通用型实例规格族g8i采用2.7 GHz主频的Intel Xeon(Sapphire Rapids) Platinum 8475B处理器，3.2 GHz睿频，g8i实例采用阿里云全新CIPU架构，可提供稳定的算力输出、更强劲的I/O引擎以及芯片级的安全加固。阿里云百科分享阿里云服…...

编程日记 2023/4/30 14:34:42

设计模式——组件协作模式之观察者模式

文章目录前言一、“组件协作” 模式二、Observer 观察者模式1、动机2、模式定义3、伪代码示例①、第一种方案，最朴素的方式②、第二种方案，重构使得遵循DIP原则：③、进一步的小优化：④、修改使得支持多个观察者： 4、结…...

编程日记 2023/4/30 14:29:41

观察者设计模式知多少

目录目标概述实现推设计模式拉设计模式被动观察者设计模式目标熟悉观察者设计模式，了解观察者设计模式的使用场景、具体实现（包括：推设计模式、拉设计模式、被动观察者设计模式）。概述一、行为设计模式行为设…...

编程日记 2023/5/30 18:23:16

Flink之TaskManager内存解析

一、CK失败 Flink任务的checkpoint操作失败大致分为两种情况，ck decline和ck expire: （1）ck decline 发生ck decline情况时，我们可以通过查看JobManager.log或TaskManager.log查明具体原因。其中有一种特殊情况为ck cancel&…...

编程日记 2023/4/30 14:19:38

为何越来越多人不喜欢“试用期六个月”的公司？网友：感觉不靠谱

众所周知，任何一份工作都有试用期，一般是三月左右。但如果你遇到试用期达到半年的公司，你会不会进入？ 近日，就有人遇到了此类公司，并对是否要进入该公司犹豫不决。他在论坛上发帖求助：大家是怎…...

编程日记 2023/4/30 14:14:37

单例模式的四种创建方式

前言单例模式是日常开发中最常见的一种设计模式，常用来做为池对象，或者计数器之类的需要保证全局唯一的场景。单例模式的目的是保证在整个程序中只存在一个对象实例，使用单例一个前提条件就是构造器私有化，不允许通过new 对象…...

编程日记 2023/4/30 14:09:36

Nginx+Keepalived 中的脑裂现象

如何解决和预防 NginxKeepalived 中会出现的脑裂现象? Nginx是一种高性能的Web服务器和反向代理服务器，可以处理大量并发请求。Keepalived是一种开源软件，用于实现IP负载均衡和故障转移。在Nginx和Keepalived结合使用时，可以通过将多个Ngin…...

编程日记 2023/5/31 9:16:51

04 KVM虚拟化网络概述

文章目录 04 KVM虚拟化网络概述4.1 Linux Bridge4.2 Open vSwitch 04 KVM虚拟化网络概述为了使虚拟机可以与外部进行网络通信，需要为虚拟机配置网络环境。KVM虚拟化支持Linux Bridge、Open vSwitch网桥等多种类型的网桥。如图1所示，数据传输路径为“虚…...

编程日记 2023/5/31 17:57:46

110页智慧农业解决方案(农业信息化解决方案)(ppt可编辑)

本资料来源公开网络，仅供个人学习，请勿商用，如有侵权请联系删除。第一部分智慧农业概述智慧农业以农业资源为基础、市场为导向、效益为中心、产业化为抓手，面向农业管理部门、农技推广部门、农业企业、农业园区和基地、农业专…...

编程日记 2023/4/30 13:54:33

Java知识体系及聊天室程序

Java知识体系结构梳理如下： 基础语法：Java的基本语法，包括数据类型、运算符、控制语句、数组等。面向对象编程：Java是一种面向对象的编程语言，需要掌握类、对象、继承、多态等概念。异常处理：Java提供了…...

编程日记 2023/5/30 4:53:33

工业安全零事故的智能守护者：一体化AI智能安防平台

前言： 通过AI视觉技术，为船厂提供全面的安全监控解决方案，涵盖交通违规检测、起重机轨道安全、非法入侵检测、盗窃防范、安全规范执行监控等多个方面，能够实现对应负责人反馈机制，并最终实现数据的统计报表。提升船厂…...

编程新知 2025/7/11 13:47:54

聊聊 Pulsar：Producer 源码解析

一、前言 Apache Pulsar 是一个企业级的开源分布式消息传递平台，以其高性能、可扩展性和存储计算分离架构在消息队列和流处理领域独树一帜。在 Pulsar 的核心架构中，Producer（生产者） 是连接客户端应用与消息队列的第一步。生产者…...

编程新知 2025/7/7 17:18:31

LeetCode - 394. 字符串解码

题目 394. 字符串解码 - 力扣（LeetCode） 思路使用两个栈：一个存储重复次数，一个存储字符串遍历输入字符串： 数字处理：遇到数字时，累积计算重复次数左括号处理：保存当前状态&a…...

编程新知 2025/7/11 10:26:35

在四层代理中还原真实客户端ngx_stream_realip_module

一、模块原理与价值 PROXY Protocol 回溯第三方负载均衡（如 HAProxy、AWS NLB、阿里 SLB）发起上游连接时，将真实客户端 IP/Port 写入 PROXY Protocol v1/v2 头。Stream 层接收到头部后，ngx_stream_realip_module 从中提取原始信息…...

编程新知 2025/7/6 17:42:11