在 Go 中使用 Websockets 和 Socket.IO - 教程
csdh11 2025-05-16 12:37 2 浏览
注意 -本教程是使用 Go 1.9 版和 googollee/go-socket.io 编写的
Websockets 是我觉得有趣的东西，因为它们为我们提供了应用程序之间通信的替代选项，而不是标准的 RESTful API 解决方案。使用 Sockets，我们可以做很酷的事情，例如在数千到数十万不同的客户端之间进行实时通信，而不必每分钟产生数十万次 RESTful API 调用访问我们的服务器的费用。
现实生活中的例子
透视事物并展示 websockets 的重要性。想象一下，我们有一个聊天应用程序，它从单个服务器获取所有最新消息，并将所有新消息推送到同一台服务器。
REST API 方法
- 为了实现实时聊天，您必须轮询每秒提供新消息的 REST API。
- 这相当于每个客户端每分钟大约 60 个 REST API 调用。
- 如果我们构建了一个成功的服务并且我们开始看到越来越多的流量访问我们的应用程序，我们的服务器将开始被每分钟处理数百万个 REST API 调用所淹没。
套接字示例
如果我们考虑使用 websockets 而不是 REST API 调用的场景：
- 每个客户端将与服务器保持一个单独的连接。
- 对于 1,000 个客户端，我们只需维护 1,000 个套接字连接。
- 如果有人发布新消息，只有到那时我们的服务器才会push向我们的 1,000 个客户端发送更新。
通过这种方法，我们极大地减少了访问我们服务器的网络流量。我们已经节省了我们需要运行的服务器应用程序实例数量的成本，而且我们基本上可以毫不费力地处理数千个客户端。
实现一个 Golang 服务器
为了在 Go 中实现 websockets，我们有许多不同的选择。我来自前端背景，前端中最流行的套接字通信库之一是socket-io，因此我们将使用 Golang 等效项，以便轻松地将它们集成在一起。
安装 go-socket.io
我们可以使用如下go get命令安装软件包：
go get github.com/googollee/go-socket.io
然后我们可以将它包含在我们的 go 程序中，如下所示：
import "github.com/googollee/go-socket.io"
简单服务器
让我们看一下readme.md我们正在使用的库中提供的示例代码。
main.go
package main
import (
"log"
"net/http"
socketio "github.com/googollee/go-socket.io"
)
func main() {
server, err := socketio.NewServer(nil)
if err != nil {
log.Fatal(err)
}
server.On("connection", func(so socketio.Socket) {
log.Println("on connection")
so.Join("chat")
so.On("chat message", func(msg string) {
log.Println("emit:", so.Emit("chat message", msg))
so.BroadcastTo("chat", "chat message", msg)
})
so.On("disconnection", func() {
log.Println("on disconnect")
})
})
server.On("error", func(so socketio.Socket, err error) {
log.Println("error:", err)
})
http.Handle("/socket.io/", server)
fs := http.FileServer(http.Dir("static"))
http.Handle("/", fs)
log.Println("Serving at localhost:5000...")
log.Fatal(http.ListenAndServe(":5000", nil))
}
运行它
所以在上面的代码示例中，我们在我们的main()函数中做所有事情。我们首先socketio通过调用定义一个新的服务器实例， socketio.NewServer(nil)然后再定义我们希望我们的套接字服务器在连接时和出现错误时具有的行为。
在server.On('connection',...)我们第一次登录，有已经连接成功做出之前就加入了chat使用房间 so.Join("chat")。
之后，我们指定当我们"chat message"通过一个连接的套接字接收到事件时我们想要发生的事情 。每当我们的服务器收到这种类型的事件时，我们就会调用 so.BroadcastTo("chat", "chat message", msg)它广播发送到当前连接的每个套接字的任何消息。这意味着一个客户端将看到另一个客户端要发送的任何消息。
最后，我们定义应该发生什么"disconnection"，在这种情况下，我们只记录我们的一个客户端断开连接的事实。
前端客户端
好的，我们已经设法充实了我们的后端基于 Go 的 WebSocket 服务器，但是现在是时候启动并运行一个简单的前端应用程序，以便我们可以测试我们所做的工作。
我们将首先index.html在我们的项目目录中创建一个简单的。
索引.html
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8" />
<meta name="viewport" content="width=device-width, initial-scale=1.0" />
<meta http-equiv="X-UA-Compatible" content="ie=edge" />
<title>Go WebSocket Tutorial</title>
</head>
<body>
<h2>Hello World</h2>
<script src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/2.1.1/socket.io.js"></script>
<script>
const socket = io("http://localhost:5000/socket.io/");
</script>
</body>
</html>
当你然后通过调用运行你的 websocket 服务器时：
$ 去运行 main.go
2018/06/10 07:54:06 Serving at localhost:5000...
2018/06/10 07:54:15 on connection
2018/06/10 07:54:16 on connection
这应该然后开始运行http://localhost:5000。然后，您应该能够在浏览器中导航到此 URL，并在服务器的日志输出中看到正在建立的新连接。
您现在已经成功构建了一个直接连接到新创建的后端 websocket 服务器的前端！
如果您发现本教程有用或需要任何进一步的帮助，请随时在下面的评论部分告诉我。
相关推荐
- 完美解决华硕主板机箱前置面板连接音箱无声音问题
-
#精品长文创作季#最近新组装了一台电脑主机，听歌时发现，音箱音频输入线插入主板自带的音频输出端口LINEOUT声音正常。但当将音箱音频输入线插入机箱自带的音频输出端口却没有声音。...
- Java 监控直播流rtsp协议转rtmp、hls、httpflv协议返回浏览器
-
Java监控直播流rtsp协议转rtmp、hls、httpflv协议返回浏览器...
- 编译安装OpenCV全攻略，附本地源码包
-
本文以Ubuntu（适用于18，20，22版本，其他的未进行测试）为例，介绍了编译安装OpenCV的最佳实践。其他平台比如windows，只需要参考本文的思路做稍微调整即可。一、为什么需要编译安装Op...
- 音视频录制+RTMP直播推拉流
-
音视频录制：1，录音通过条件编译识别pc或者mac://条件编译技术识别pc或者mac#ifdefQ_OS_WIN#defineFMT_NAME"dshow"...
- Python Socket.IO 简介
-
Socket.IO是一种传输协议，支持客户端与服务器之间基于事件的实时双向通信。客户端通常但不总是web浏览器，一般情况下，客户端是采用js编写的，当然，也可以用python、Java等。...
- MyCat系列二--配置文件之server.xml
-
MyCat系列二--配置文件之server.xml从【安装与基本使用】一文中，可以看到MyCat运行，需要进行一些配置文件的相关配置，本文将重点介绍配置文件server.xml的基本元素信息，尽量了解...
- 3分钟搞懂Socket.IO:接口调试技巧
-
在数字化协作需求井喷的今天，即时通讯、协同文档、MMO游戏等场景对实时交互提出了严苛要求。传统HTTP协议"请求-响应"的离散式通信机制已难以满足需求，这正是Socket.IO这类实时...
- 「云原生」Containerd ctr，crictl 和 nerdctl 命令介绍与实战操作
-
一、概述作为接替Docker运行时的Containerd在早在Kubernetes1.7时就能直接与Kubelet集成使用，只是大部分时候我们因熟悉Docker，在部署集群时采用了默认的dockers...
- 搜狗开源srpc:自研高性能通用RPC框架
-
今年7月底，搜狗公司开源了内部的工业级C++服务器引擎Workflow，一路收获业内许多认可和关注。9月15日，作为Workflow最重要的生态项目——srpc，一个基于其打造的轻量级RPC框架，也在...
- socket.io 权限认证
-
socket.io是一款流行的WebSocket库，提供了实时双向通信的能力。它支持多种身份验证方式，可用于保护某些敏感信息。接下来，我们将介绍如何使用socket.io权限认证1.安装依...
- Linux高性能服务器设计
-
C10K和C10M计算机领域的很多技术都是需求推动的，上世纪90年代，由于互联网的飞速发展，网络服务器无法支撑快速增长的用户规模。1999年，DanKegel提出了著名的C10问题：一台服务器上同时...
- 19K 标星!开源局域网文件传输神器，AirDrop 跨平台替代品!
-
传统文件传输方式（如USB、蓝牙、邮件）要么速度慢，要么操作繁琐，而AirDrop仅限苹果生态。如果你还在为手机和电脑之间传文件来回折腾？还在装各种臃肿的客户端、扫码连Wi-Fi、用数据线拖来...
- WebRTC 入门教程:搭建WebRTC信令服务器
-
前言我们在学习WebRTC时，首先要把实验环境搭建好，这样我们就可以在上面做各种实验了。对于WebRTC来说，它有一整套规范，如怎样使用它的接口、使用SDP进行媒体协商、通过ICE收集地址并进...
- 在 Go 中使用 Websockets 和 Socket.IO - 教程
-
注意-本教程是使用Go1.9版和googollee/go-socket.io编写的Websockets是我觉得有趣的东西，因为它们为我们提供了应用程序之间通信的替代选项，而不是标准的R...
- 2021 年 Node.js 开发人员学习路线图
-
Node.js自发布以来，已成为业界重要破局者之一。Uber、Medium、PayPal和沃尔玛等大型企业，纷纷将技术栈转向Node.js。Node.js支持开发功能强大的应用，例如实时追踪...
- 一周热门
- 最近发表
- 标签列表
-
- mydisktest_v298 (34)
- document.appendchild (35)
- 头像打包下载 (61)
- acmecadconverter_8.52绿色版 (39)
- word文档批量处理大师破解版 (36)
- server2016安装密钥 (33)
- mysql 昨天的日期 (37)
- parsevideo (33)
- 个人网站源码 (37)
- centos7.4下载 (33)
- mysql 查询今天的数据 (34)
- intouch2014r2sp1永久授权 (36)
- 先锋影音源资2019 (35)
- jdk1.8.0_191下载 (33)
- axure9注册码 (33)
- pts/1 (33)
- spire.pdf 破解版 (35)
- shiro jwt (35)
- sklearn中文手册pdf (35)
- itextsharp使用手册 (33)
- 凯立德2012夏季版懒人包 (34)
- 冒险岛代码查询器 (34)
- 128*128png图片 (34)
- jdk1.8.0_131下载 (34)
- dos 删除目录下所有子目录及文件 (36)