在 Go 中使用 Websockets 和 Socket.IO - 教程
haoteby 2024-12-27 13:32 6 浏览
注意 -本教程是使用 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 服务器的前端！
如果您发现本教程有用或需要任何进一步的帮助，请随时在下面的评论部分告诉我。
相关推荐
- 单点登录(SSO)解决方案介绍（单点登录概念）
-
一、单点登录的介绍单点登录（SingleSignOn），简称为SSO，是目前比较流行的企业业务整合的解决方案之一。SSO的定义是在多个应用系统中，用户只需要登录一次就可以访问所有相互信任的应用系...
- 系统登录的三种方式，哪一种更安全?
-
登录是一个高频的动作，笔者抓住这一个小点，分析了系统登录的几种方式和对应的场景。今天谈谈登录。登录即用户输入用户名和密码登录进系统中。B端系统，对于登录的业务场景有两种（可能不止，目前遇到过这两种）：...
- 到底什么是单点登录(SSO)?（什么叫做单点登录）
-
什么是单点登录？单点登录（SingleSign-On，简称SSO）是一种集中式的身份验证和授权机制，用户只需在一处输入一次凭证（例如用户名和密码）就可以访问多个相关但独立的软件系统。在数字化时代，...
- 5年稳如老狗的单点登录系统，到底是怎么搞出来的?
-
说到单点登录（SingleSign-On，简称SSO），大家的第一反应可能是——啊不就是登录一次，能到处串门儿嘛？别说，还真差不多，就是这么个意思。但真要搭一套好用、耐造、还能扛住公司里各种奇奇怪...
- 这些负载均衡都解决哪些问题?服务、网关、NGINX?
-
在微服务项目中，有服务的负载均衡、网关的负载均衡、Nginx的负载均衡，这几个负载均衡分别用来解决什么问题呢？一、服务的负载均衡先抛出一个问题：...
- Nginx负载均衡最全详解(4大算法原理机制)
-
Nginx在大型网站架构很重要，也是大厂重点考察方向，今天我就重点来详解Nginx负载均衡@mikechen本篇已收于mikechen原创超30万字《阿里架构师进阶专题合集》里面。Nginx负载均衡N...
- 负载均衡 Nginx Session 一致性（nginx 负载均衡 会话保持）
-
HTTPS请求跳转...
- 监控Oracle Cloud负载均衡器:Applications Manager释放最佳性能
-
设想你正在运营一个受欢迎的在线学习平台，在考试前的高峰期，平台流量激增。全球的学生同时登录，观看视频、提交作业和参加测试。如果OracleCloud负载均衡器不能高效地分配流量，或者后端服务器难...
- Nginx负载均衡:nginx.conf配置文件说明!
-
大家好，欢迎来到程序视点！我是你们的老朋友.小二！在此记录下Nginx服务器nginx.conf负载均衡的配置文件说明,部分注释收集与网络.关于nginx.conf基本的配置，请查看上一篇文章！Ng...
- Java高可用系统架构中的负载均衡策略
-
Java高可用系统架构中的负载均衡策略在现代的分布式系统中，负载均衡策略是构建高可用系统的基石。Java开发者需要深刻理解这些策略，以便打造稳定且高效的系统。接下来，让我们一起揭开负载均衡的神秘面纱。...
- Spring Boot3 客户端负载均衡全解析:从原理到实战
-
在当今互联网大厂后端技术开发的激烈竞争环境中，构建高效、稳定的微服务架构是核心诉求。其中，SpringBoot3作为热门开发框架，其客户端负载均衡功能对于提升系统性能、保障服务稳定性起着关键作用。...
- MySql高可用集群MySQL Router负载均衡读写分离
-
名词解释MGR:MysqlGroupReplication组复制，多台MySQL服务器在同一组中会自动保持同步状态，当某台服务器故障时，整个复制组依然可以保持正常并对外提供服务。...
- 性能测试之tomcat+nginx负载均衡（nginx tomcat）
-
nginxtomcat配置准备工作：两个tomcat执行命令cp-rapache-tomcat-8.5.56apache-tomcat-8.5.56_2修改被复制的tomcat2下con...
- win10/11双网卡链路聚合叠加负载均衡提升网速解决网卡网速瓶颈!
-
双网卡链路聚合一种网络配置技术，通过将多个物理网卡绑定在一起，形成一个逻辑上的网络接口，以提高网络的可靠性、可用性和性能。这种技术通常用于服务器和网络设备中，以实现负载均衡、冗余和高可用性。本机环境：...