关于我们

质量为本、客户为根、勇于拼搏、务实创新

< 返回新闻公共列表

云南大王-golang Gin framework with websocket

发布时间:2020-04-16 00:00:00
概述 golang websocket 库 示例 后端 前端 结论 概述 对于 golang 的 web 开发, 之前写过 2 篇 blog, 分别介绍了: 在 Gin 框架下, 各类 http API 的开发方法(包括文件上传, 下载等) golang Web 方案 Gin 框架下反向代理的使用: 反向代理的使用 这里再给之前的 Web 方案中加上 Websocket 的部分, 基本就能涵盖日常开发所需的所有接口类型了. golang websocket 库 这里使用的 websocket 库来自 Gorilla web toolkit 下面用代码来演示如何在 Gin 框架中结合 websocket API 示例 后端 后端提供 2 种 API, 分别支持 text 格式和 json 格式的消息 示例中的 API 每次收到消息后, 返回 10 次 1 package main 2 3 import ( 4 "log" 5 "net/http" 6 "strconv" 7 "time" 8 9 "github.com/gin-contrib/static" 10 "github.com/gin-gonic/gin" 11 "github.com/gorilla/websocket" 12 ) 13 14 var upGrader = websocket.Upgrader{ 15 CheckOrigin: func(r *http.Request) bool { 16 return true 17 }, 18 } 19 20 // webSocket返回text 格式 21 func textApi(c *gin.Context) { 22 //升级get请求为webSocket协议 23 ws, err := upGrader.Upgrade(c.Writer, c.Request, nil) 24 if err != nil { 25 log.Println("error get connection") 26 log.Fatal(err) 27 } 28 defer ws.Close() 29 //读取ws中的数据 30 mt, message, err := ws.ReadMessage() 31 if err != nil { 32 log.Println("error read message") 33 log.Fatal(err) 34 } 35 36 //写入ws数据, pong 10 times 37 var count = 0 38 for { 39 count++ 40 if count > 10 { 41 break 42 } 43 44 message = []byte(string(message) + " " + strconv.Itoa(count)) 45 err = ws.WriteMessage(mt, message) 46 if err != nil { 47 log.Println("error write message: " + err.Error()) 48 } 49 time.Sleep(1 * time.Second) 50 } 51 } 52 53 //webSocket返回 json格式 54 func jsonApi(c *gin.Context) { 55 //升级get请求为webSocket协议 56 ws, err := upGrader.Upgrade(c.Writer, c.Request, nil) 57 if err != nil { 58 log.Println("error get connection") 59 log.Fatal(err) 60 } 61 defer ws.Close() 62 var data struct { 63 A string `json:"a"` 64 B int `json:"b"` 65 } 66 //读取ws中的数据 67 err = ws.ReadJSON(&data) 68 if err != nil { 69 log.Println("error read json") 70 log.Fatal(err) 71 } 72 73 //写入ws数据, pong 10 times 74 var count = 0 75 for { 76 count++ 77 if count > 10 { 78 break 79 } 80 81 err = ws.WriteJSON(struct { 82 A string `json:"a"` 83 B int `json:"b"` 84 C int `json:"c"` 85 }{ 86 A: data.A, 87 B: data.B, 88 C: count, 89 }) 90 if err != nil { 91 log.Println("error write json: " + err.Error()) 92 } 93 time.Sleep(1 * time.Second) 94 } 95 } 96 97 func websocketGin() { 98 r := gin.Default() 99 r.GET("/json", jsonApi) 100 r.GET("/text", textApi) 101 102 // static files 103 r.Use(static.Serve("/", static.LocalFile("./public", true))) 104 105 r.NoRoute(func(c *gin.Context) { 106 c.File("./public/index.html") 107 }) 108 109 r.Run(":8000") 110 } 后端代码中有个静态文件的路由 r.Use(static.Serve("/", static.LocalFile("./public", true))) 只要将下面的前端代码命名为 index.html 并放在和后端代码根目录下的 public 文件夹中, 就可以在启动后端之后, 直接通过访问 *http://localhost:8000" 来显示页面了 前端 前端很简单, 就是在页面初始化完成后创建 websocket 连接, 然后发送消息并显示接受到的消息 1 2 3 4 5 index 6 7 8

test websocket

9

10

11 52 53 结论 运行之后, 就可以看到页面上显示的 message 了, 发送一次信息, 会收到 10 条返回.

相关阅读

centos7系统中忘记了root管理员账号密码的解决方式公司管理必须的20条军规[参考]云南昆明天猫旗舰店如何开_怎么开_要什么条件云南大王-通俗理解spring源码(三)—— 获取xml的验证模式 云南大王-用户登录 云南大王-【Golang进阶】指针的详细讲解 云南大王-Java 单线程代码ThreadLocal串值问题 云南大王-Java 实例级别的锁和类级别的锁 云南大王-工作流引擎会签,加签,主持人,组长模式专题讲解 云南大王-Android连载5云南大王-NTP对时器(NTP对时服务器)重要性!京准电子科技 云南大王-关于redis单线程的分析 云南大王-CVE云南大王-PHP SESSION反序列化本地样例分析 云南大王-这不就是多线程ThreadPoolExecutor和阻塞队列吗 云南大王-Tomcat AJP 文件包含漏洞(CVE云南大王-讲真,这两款idea插件,能治愈你英语不好的病 云南大王-消息中间件ActiveMQ、RabbitMQ、RocketMQ、ZeroMQ、Kafka如何选型? 云南大王-JVM系列十三(类加载器). 云南大王-Win10安装MySQL8压缩包版 云南大王-初始WebApi(2) 云南大王-初识人工智能(二):机器学习(一):sklearn特征抽取 云南大王-Popup中ListBox的SelectChange事件关闭弹出窗体后主窗体点击无效BUG 云南大王-基础知识记录 云南大王-FastDFS搭建图片服务器 云南大王-git/sourcetree解决本地仓库历史合并到线上仓的历史数据合并问题_refusing to merge unrelated histories 云南大王-js判断字符是否在数组中【转】 云南大王-Python 云南大王-面向对象之多线程(可捎带电梯调度) 云南大王-Python练习题2.5求奇数分之一序列前N项和(存在问题) 云南大王-React 中的前端路由 react云南大王-VSCODE 远程开发树莓派 云南大王-React新闻网站云南大王-vs .net CS0006 C# 未能找到元数据文件 .dll 云南大王-Vue.js 技术揭秘 云南大王-流程控制语句云南大王-Python学习笔记:Python的时间操作(time,datetime,timedelta,calendar) 云南大王-流程控制语句云南大王-golang Gin framework with websocket 云南大王-多重判断if..else嵌套语句 云南大王-用户登录 云南大王-流程控制语句云南大王-密码类 云南大王-Unity2018发布WebGL注意事项总结 云南大王-web系统安全运营之基础云南大王- 流程控制语句云南大王-中型WPF客户端开发项目总结(3.3.4) 云南大王-流程控制语句云南大王-流程控制语句云南大王-流程控制语句云南大王-中型WPF客户端开发项目总结(4) 云南大王-流程控制语句云南大王-ASP.NET Core笔记(4) 云南大王-C# 基础知识系列云南大王-让 .NET 轻松构建中间件模式代码(二) 云南大王-基于 HTML5 WebGL 的 水泥工厂可视化系统 云南大王-.NET Core 3 WPF MVVM框架 Prism系列之导航系统 云南大王-《JavaScript异步编程》精读笔记 云南大王-合理使用CSS框架,加速UI设计进程 云南大王-CLSID 为 {000209FF云南大王-从零基础转行到前端大牛,需要经过哪几个阶段? 云南大王-一个简单的例子看明白 async await Task 云南大王-【目前】宇宙第一IDE Visual Studio 合并压缩css、js扩展组件云南大王-写一个通用的List集合导出excel的通用方法 云南大王-Bootstrap4 按钮组+徽章(Badges)+进度条+分页+列表组 云南大王-Web前端工程师需要学些什么? 云南大王-react嵌套路由 云南大王-【java框架】Struts2(2) 云南大王-javaSE笔记云南大王-.net core 集成 sentry 进行异常报警 云南大王-Java の 四种引用 云南大王-JVM 虚拟机&&类加载(一) 云南大王-使用Fastjson实现JSON与JavaBean之间互相转换 云南大王-Python操作Oracle数据库:cx_Oracle 云南大王-为什么要用内插字符串代替string.format 云南大王-作为字节跳动的面试官,有些话我不得不说! 云南大王-微信公众号自定义菜单与启用服务器配置冲突(图文消息、链接及文本回复) 云南大王-C#队列学习笔记:RabbitMQ延迟队列 云南大王-Disruptor 基础篇 云南大王-C#获取设备(Audio和Video)名称 简单整理 云南大王-基于注解的IOC配置 云南大王-C#调用EnumDevice获取设备信息 云南大王-Jenkins基础系统之更换镜像源 云南大王-Jenkins基础系统之完整的.net项目编译 云南大王-Scala学习系列(二)——环境安装配置 云南大王-WinForm中DataGridView复制选中单元格内容解决方案 云南大王-关键词匹配优化(第0篇)—— 问题和思路 云南大王-ASP.NET CORE WEBAPI文件下载 云南大王-GC垃圾回收器 云南大王-多线程之旅(Task 任务) 云南大王-当模板方法遇到了委托函数,你的代码又可以精简了 云南大王-基于.NetCore3.1搭建项目系列 —— 使用Swagger导出文档 (补充篇) 云南大王-关键词匹配优化(第1篇)—— 测试计算过程 云南大王-原理解密 → Spring AOP 实现动态数据源(读写分离),底层原理是什么 云南大王-Navicat 密码加密算法 云南大王-【WPF学习】第六十六章 支持可视化状态 云南大王-composer安装 windows 云南大王-ASP.NET Core中的Controller 云南大王-HttpClient来自官方的JSON扩展方法 云南大王-Python3标准库:http.cookies HTTP cookie
/template/Home/Zkeys/PC/Static