Go websocket
Go 中的 gorilla/websocket 是一个常用且高效的 WebSocket 实现库，可以帮助你轻松地在 Web 应用中实现实时通信。学习 gorilla/websocket 的基本用法包括建立 WebSocket 连接、发送和接收消息、处理错误、以及在实际场景中的使用。以下是关于 gorilla/websocket 的学习步骤和一些使用示例。
1. 安装 gorilla/websocket
首先，你需要安装 gorilla/websocket 包，可以使用以下命令进行安装：
go get github.com/gorilla/websocket
2. 基本使用步骤
2.1 建立 WebSocket 服务器
在服务器端，你需要升级 HTTP 连接到 WebSocket，并处理来自客户端的消息。以下是一个简单的 WebSocket 服务器示例：
package mainimport ("net/http""github.com/gorilla/websocket""log"
)var upgrader = websocket.Upgrader{// CheckOrigin 函数用于控制 WebSocket 的跨域请求CheckOrigin: func(r *http.Request) bool {return true},
}func handleWebSocket(w http.ResponseWriter, r *http.Request) {// 将 HTTP 连接升级到 WebSocketconn, err := upgrader.Upgrade(w, r, nil)if err != nil {log.Println("Upgrade error:", err)return}defer conn.Close()for {// 读取消息messageType, message, err := conn.ReadMessage()if err != nil {log.Println("Read error:", err)break}log.Printf("Received: %s", message)// 将消息返回给客户端err = conn.WriteMessage(messageType, message)if err != nil {log.Println("Write error:", err)break}}
}func main() {http.HandleFunc("/ws", handleWebSocket)log.Println("Server started on :8080")err := http.ListenAndServe(":8080", nil)if err != nil {log.Fatal("ListenAndServe error:", err)}
}
2.2 创建 WebSocket 客户端
客户端可以使用 JavaScript 来连接和与 WebSocket 服务器通信。以下是一个简单的 HTML 客户端示例：
<!DOCTYPE html>
<html>
<head><title>WebSocket Test</title>
</head>
<body><script>const ws = new WebSocket('ws://localhost:8080/ws');ws.onopen = function() {console.log('Connected to server');ws.send('Hello Server');};ws.onmessage = function(event) {console.log('Received from server:', event.data);};ws.onclose = function() {console.log('Connection closed');};</script>
</body>
</html>
3. 高级用法
3.1 处理 JSON 消息
如果你需要处理 JSON 格式的消息，可以使用 encoding/json 包对消息进行编码和解码：
import ("encoding/json"
)// 示例结构体
type Message struct {Type string `json:"type"`Data string `json:"data"`
}// 读取 JSON 消息
var msg Message
err := conn.ReadJSON(&msg)
if err != nil {log.Println("ReadJSON error:", err)
}// 发送 JSON 消息
err = conn.WriteJSON(Message{Type: "response", Data: "Hello, Client"})
if err != nil {log.Println("WriteJSON error:", err)
}
3.2 广播消息
在 WebSocket 服务器中，可能需要将消息广播给所有连接的客户端，可以使用一个中央的管理器来跟踪所有的连接：
type Hub struct {connections map[*websocket.Conn]boolbroadcast chan []byte
}var hub = Hub{connections: make(map[*websocket.Conn]bool),broadcast: make(chan []byte),
}func (h *Hub) run() {for {message := <-h.broadcastfor conn := range h.connections {if err := conn.WriteMessage(websocket.TextMessage, message); err != nil {conn.Close()delete(h.connections, conn)}}}
}func handleWebSocket(w http.ResponseWriter, r *http.Request) {conn, err := upgrader.Upgrade(w, r, nil)if err != nil {log.Println("Upgrade error:", err)return}defer conn.Close()hub.connections[conn] = truefor {_, message, err := conn.ReadMessage()if err != nil {log.Println("Read error:", err)break}hub.broadcast <- message}
}func main() {go hub.run()http.HandleFunc("/ws", handleWebSocket)log.Fatal(http.ListenAndServe(":8080", nil))
}
4. 常见使用场景
- 实时聊天应用: 使用 WebSocket 可以实现实时聊天功能，支持双向通信。
- 实时通知系统: 用于推送实时的事件通知，如股票价格更新、社交媒体提醒等。
- 多人在线游戏: 实现实时互动的多人在线游戏，确保玩家之间的同步。
- 协同编辑工具: 用于构建实时协作的编辑器，如多人同时编辑文档或白板。
通过学习和使用 gorilla/websocket，你可以在 Go 应用中轻松实现实时通信，满足各种实时数据传输的需求。
相关文章：
Go websocket
Go 中的 gorilla/websocket 是一个常用且高效的 WebSocket 实现库，可以帮助你轻松地在 Web 应用中实现实时通信。学习 gorilla/websocket 的基本用法包括建立 WebSocket 连接、发送和接收消息、处理错误、以及在实际场景中的使用。以下是关于 gorilla/websocket 的学…...
C# 委托与事件 观察者模式
委托与事件是一种观察者模式。 什么是委托与事件 在c#中，委托类似于代理，也跟其它语言的函数指针、回调函数等相似，但委托是类型安全和可靠的。声明自定义委托时，加上delegate关键字，委托定义类似于接口。 事件是特殊…...
K8S - 用service account 登陆kubectl
刚安装好k8s时 我就可以用kubectl 在master server里管理k8s的资源。 这时我们是感觉不到 k8s的用户和权限管理存在的， 但是其实用户的配置都在kubeclt 的配置文件中 /etc/kubernetes/admin.conf 中 我们可以用下命令来查看当前正在用的帐号 rootk8s-master:~/.d…...
Redis 持久化机制详解
引言 Redis 是一款基于内存的高性能键值存储系统，为了在数据丢失时能快速恢复，Redis 提供了多种持久化机制。这些持久化机制可以将内存中的数据存储到磁盘上，确保即使系统重启或宕机后也能恢复数据。Redis 支持两种主要的持久化方式…...
小阿轩yx-案例：Zabbix监控kubernetes云原生环境
小阿轩yx-案例：Zabbix监控kubernetes云原生环境 前言 传统监控的本质 就是收集、分析和使用信息来观察一段时间内监控对象的运行进度，并且进行相应的决策管理的过程，监控侧重于观察特定指标。 随着云原生时代的到来 我们对监控的功能提出…...
量化交易的个人见解
程序化交易在国内兴起有些年数了，个人以为，程序化交易与量化投资的关系，在于两者侧重点有差别。程序化交易侧重于下单的动作是机器自动执行的，量化投资则侧重于投资分析的过程是通过一个量化模型来实现的，所以量化投资…...
Java集合（一）
目录 Java集合（一） 集合介绍 单列集合分类 Collection接口 创建Collection实现类对象 常用方法 迭代器 基本使用 迭代器的执行过程 迭代器底层原理 集合中的并发修改异常及原因分析 List接口 ArrayList类 介绍 常用方法 遍历集合 Array…...
车载软件架构 --- SOA设计与应用（下）
我是穿拖鞋的汉子，魔都中坚持长期主义的汽车电子工程师。 老规矩，分享一段喜欢的文字，避免自己成为高知识低文化的工程师： 屏蔽力是信息过载时代一个人的特殊竞争力，任何消耗你的人和事，多看一眼都是你的不对。非必要不费力证明自己，无利益不试图说服别人，是精神上的节…...
网络原理 IP协议与以太网协议
博主主页: 码农派大星. 数据结构专栏:Java数据结构 数据库专栏:MySQL数据库 JavaEE专栏:JavaEE 关注博主带你了解更多数据结构知识 目录 1.网络层 IP协议 1.IP协议格式 2.地址管理 2.1 IP地址 2.2 解决IP地址不够用的问题 2.3NAT网络地址转换 2.4网段划分 3.路由选择…...
k8s的安装
k8s的安装 1.创建主机，设置ip,hostname，关闭firewalld,selinux,NetworkManager 编号主机名称ip1k8s-master192.168.118.662k8s-node01192.168.118.773k8s-node02192.168.118.88 2.设置主机之间的ssh免密 [rootk8s-master ~]# ssh-keygen [rootk8s-ma…...
Qt中样式表常用的属性名称定义
Qt中，用好样式表，不但可以做出意想不到的酷炫效果，有时候也能减轻开发量，可能由于你不了解某些样式使用，想破脑袋通过代码实现的效果，反倒不如别人用样式，一两句样式脚本就搞定。 Qt中ÿ…...
React源码学习（一）：如何学习React源码
本系列源码学习，是基于 v16.13.1，v17.x与v16.x区别并不太大！ 一、如何正确的学习React源码？ 找到Github，转到React仓库，fork / clone源码：React 查看Readme，在Documentation中有Cont…...
云计算服务的底层，虚拟化技术的实现原理
虚拟化技术： 一、 从cpu说起， intel和amd等cpu制造商 为了提高其cpu对 虚拟化程序的运算速度， 给cpu硬件里面 增加了指令集 VMLAUNCH, VMRESUME, VMEXIT, VMXOFF 这些指令集称为硬件辅助虚拟化技术的指令集。 ---------------------…...
大数据Flink（一百一十六）：Flink SQL的时间属性
文章目录 Flink SQL的时间属性 一、Flink 三种时间属性简介 二、Flink 三种时间属性的应用场景 三、SQL 指定时间属性的两种方式 四、SQL 处理时间DDL定义 五、SQL 事件时间DDL定义 Flink SQL的时…...
Ansible自动化部署kubernetes集群
机器环境介绍 1.1. 机器信息介绍 IP hostname application CPU Memory 192.168.204.129 k8s-master01 etcd，kube-apiserver，kube-controller-manager，kube-scheduler,kubelet,kube-proxy,containerd 2C 4G 192.168.204.130 k8s-w…...
网络通信流程
目录 ♫IP地址 ♫子网掩码 ♫MAC地址 ♫相关设备 ♫ARP寻址 ♫网络通信流程 ♫IP地址 我们已经知道 IP 地址由网络号主机号组成，根据 IP 地址的不同可以有5钟划分网络号和主机号的方案： 其中，各类地址的表示范围是： 分类范围适用…...
数据结构一：绪论
（一）数据结构的基本概念 1.相关名词 【1】数据 1.信息的载体，描述客观事物 2.能被输入到计算机中 3.能被计算机程序识别和处理的符号的集合。 【2】数据元素 1.数据的一个“个体” 2.数据的基本单位 3.有时候也被称为元素、结点、顶点…...
使用OpenFeign在不同微服务之间传递用户信息时失败
文章目录 起因原因解决方法： 起因 从pay-service中实现下单时，会调用到user-service中的扣减余额。 因此这里需要在不同微服务之间传递用户信息。 但是user-service中始终从始至终拿不到user的信息。 原因 在pay-service中，不仅要Enable O…...
js中【Worker】相关知识点详细解读
什么是 JavaScript 中的 Worker？ JavaScript 中的 Worker 是一个可以在后台线程中运行代码的 API，这样可以避免主线程（通常是 UI 线程）被阻塞。使用 Worker 时，JavaScript 可以在多线程环境中工作，解决了单…...
使用Apify加载Twitter消息以进行微调的完整指南
# 使用Apify加载Twitter消息以进行微调的完整指南## 引言在自然语言处理领域，微调模型以适应特定任务是提升模型性能的常见方法。本文将介绍如何使用Apify从Twitter导出聊天信息，以便进一步进行微调。## 主要内容### 使用Apify导出推文首先，我…...
B站视频下载高效解决方案：bilibili-downloader完全指南
B站视频下载高效解决方案：bilibili-downloader完全指南 【免费下载链接】bilibili-downloader B站视频下载，支持下载大会员清晰度4K，持续更新中 项目地址: https://gitcode.com/gh_mirrors/bil/bilibili-downloader 你是否遇到过这些困…...
OpenClaw定时任务实战：gemma-3-12b-it每日凌晨自动备份重要文件
OpenClaw定时任务实战：gemma-3-12b-it每日凌晨自动备份重要文件 1. 为什么需要自动化文件备份 上周我的移动硬盘突然罢工，导致三个月的工作文档险些丢失。这次事故让我意识到：人工备份永远存在疏漏。即使设置了日历提醒，也难免因…...
 输出电流2A)
XZ1820A输入电压6-90V 输出电压ADJ(0.8V-50V) 输出电流2A
这是一款单片集成可设定输出电流的开关型降压恒压驱动器，可工作在宽输入电压范围具有优良的负载和线性调整度。安全保护机制包括每周期的峰值限流、软启动、过压保护和温度保护，带短路保护。保护点150度的温度过热保护,较高占空比大于92%。压差最小2V左右…...
从零到精通：Vue3.0中使用vuedraggable实现完美拖拽功能的5个关键技巧
从零到精通：Vue3.0中使用vuedraggable实现完美拖拽功能的5个关键技巧 在当今前端开发领域，交互体验的重要性日益凸显，而拖拽功能作为提升用户操作直观性的核心手段，已经成为现代Web应用的标配。Vue3.0凭借其出色的响应式系统和组合…...
保姆级教程：Ollama部署translategemma-27b-it，小白也能玩转多语言翻译
保姆级教程：Ollama部署translategemma-27b-it，小白也能玩转多语言翻译 1. 引言：为什么选择translategemma-27b-it 想象一下，你正在阅读一份重要的外文资料，或者需要与外国客户沟通，但语言成了障碍。传统的…...
如何让你的10美元鼠标秒变Mac神器？Mac Mouse Fix终极指南
如何让你的10美元鼠标秒变Mac神器？Mac Mouse Fix终极指南 【免费下载链接】mac-mouse-fix Mac Mouse Fix - Make Your $10 Mouse Better Than an Apple Trackpad! 项目地址: https://gitcode.com/GitHub_Trending/ma/mac-mouse-fix 还在为Mac上的第三方鼠标发…...
iperf3 Windows预编译二进制深度解析：专业网络性能测试技术实践
iperf3 Windows预编译二进制深度解析：专业网络性能测试技术实践 【免费下载链接】iperf3-win-builds iperf3 binaries for Windows. Benchmark your network limits. 项目地址: https://gitcode.com/gh_mirrors/ip/iperf3-win-builds iperf3-win-builds是针对…...
OAuth 2.1+PKCE 实战指南（附 Python 验证代码）
在技术领域，我们常常被那些闪耀的、可见的成果所吸引。今天，这个焦点无疑是大语言模型技术。它们的流畅对话、惊人的创造力，让我们得以一窥未来的轮廓。然而，作为在企业一线构建、部署和维护复杂系统的实践者，我们深知…...
保姆级教程：用阿里云物联网平台给你的ESP32实现远程OTA升级（Arduino/PlatformIO通用）
ESP32远程OTA升级实战：基于阿里云物联网平台的完整解决方案 想象一下这样的场景：你开发的智能家居设备已经部署在用户家中，突然发现一个关键漏洞需要紧急修复。传统方式需要用户手动下载固件或返厂升级，而远程OTA（Ove…...
3.3.1 eUICC Package Download and Execution: A Deep Dive into ES10b and ProfileRollback Mechanisms
1. eUICC包下载与执行的核心流程解析 想象一下你正在给远在另一个城市的智能水表更换运营商服务，就像给手机换SIM卡一样。但这里有个问题：你不可能亲自跑到每个水表旁边插拔SIM卡。这就是eUICC技术大显身手的时候了，它能让物联网设备远程切换…...