百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 编程网 > 正文

在 Go 中使用 Websockets 和 Socket.IO - 教程

yuyutoo 2025-03-08 01:58 15 浏览 0 评论

注意 -本教程是使用 Go 1.9 版和 googollee/go-socket.io 编写的

Websockets 是我觉得有趣的东西,因为它们为我们提供了应用程序之间通信的替代选项,而不是标准的 RESTful API 解决方案。使用 Sockets,我们可以做很酷的事情,例如在数千到数十万不同的客户端之间进行实时通信,而不必每分钟产生数十万次 RESTful API 调用访问我们的服务器的费用。

现实生活中的例子


透视事物并展示 websockets 的重要性。想象一下,我们有一个聊天应用程序,它从单个服务器获取所有最新消息,并将所有新消息推送到同一台服务器。

REST API 方法

  1. 为了实现实时聊天,您必须轮询每秒提供新消息的 REST API。
  2. 这相当于每个客户端每分钟大约 60 个 REST API 调用。
  3. 如果我们构建了一个成功的服务并且我们开始看到越来越多的流量访问我们的应用程序,我们的服务器将开始被每分钟处理数百万个 REST API 调用所淹没。

套接字示例

如果我们考虑使用 websockets 而不是 REST API 调用的场景:

  1. 每个客户端将与服务器保持一个单独的连接。
  2. 对于 1,000 个客户端,我们只需维护 1,000 个套接字连接。
  3. 如果有人发布新消息,只有到那时我们的服务器才会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



  
    
    
    
    Go WebSocket Tutorial
  
  
    

Hello World

<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>

当你然后通过调用运行你的 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 服务器的前端!



如果您发现本教程有用或需要任何进一步的帮助,请随时在下面的评论部分告诉我。


相关推荐

《保卫萝卜2》安卓版大更新 壕礼助阵世界杯

《保卫萝卜2:极地冒险》本周不仅迎来了安卓版本的重大更新,同时将于7月4日本周五,带来“保卫萝卜2”安卓版本世界杯主题活动的火热开启,游戏更新与活动两不误。一定有玩家会问,激萌塔防到底进行了哪些更新?...

儿童手工折纸:胡萝卜,和孩子一起边玩边学carrot

1、准备两张正方形纸,一橙一绿,对折出折痕。2、橙色沿其中一条对角线如图折两三角形。3、把上面三角折平,如图。4、绿色纸折成三角形。5、再折成更小的三角形。6、再折三分之一如图。7、打开折纸,压平中间...

《饥荒》食物代码有哪些(饥荒最新版代码总汇食物篇)

饥荒游戏中,玩家们需要获取各种素材与食物,进行生存。玩家们在游戏中,进入游戏后按“~”键调出控制台使用代码,可以直接获得素材。比如胡萝卜的代码是carrot,玉米的代码是corn,南瓜的代码是pump...

Skyscanner:帮你找到最便宜机票 订票不求人

你喜欢旅行吗?在合适的时间、合适的目的地,来一场说走就走的旅行?机票就是关键!Skyscanner这款免费的手机应用,在几秒钟内比较全球600多家航空公司的航班安排、价格和时刻表,帮你节省金钱和时间。...

小猪佩奇第二季50(小猪佩奇第二季英文版免费观看)

Sleepover过夜Itisnighttime.现在是晚上。...

我在民政局工作的那些事儿(二)(我在民政局上班)

时间到了1997年的秋天,经过一年多的学习和实践,我在处理结婚和离婚的事情更加的娴熟,也获得了领导的器重,所以我在处理平时的工作时也能得心应手。这一天我正在离婚处和同事闲聊,因为离婚处几天也遇不到人,...

夏天来了就你还没瘦?教你不节食13天瘦10斤的哥本哈根减肥法……

好看的人都关注江苏气象啦夏天很快就要来了你是否和苏苏一样身上的肉肉还没做好准备?真是一个悲伤的故事……下面这个哥本哈根减肥法苏苏的同事亲测有效不节食不运动不反弹大家快来一起试试看吧~DAY1...

Pursuing global modernization for peaceful development, mutually beneficial cooperation, prosperity for all

AlocalworkeroperatesequipmentintheChina-EgyptTEDASuezEconomicandTradeCooperationZonei...

Centuries-old tea road regains glory as Belt and Road cooperation deepens

FUZHOU/ST.PETERSBURG,Oct.2(Xinhua)--NestledinthepicturesqueWuyiMountainsinsoutheastChi...

15 THE NUTCRACKERS OF NUTCRACKER LODGE (CONTINUED)胡桃夹子小屋里的胡桃夹子(续篇)

...

AI模型部署:Triton Inference Server模型部署框架简介和快速实践

关键词:...

Ftrace function graph简介(flat function)

引言由于android开发的需要与systrace的普及,现在大家在进行性能与功耗分析时候,经常会用到systrace跟pefetto.而systrace就是基于内核的eventtracing来实...

JAVA历史版本(java各版本)

JAVA发展1.1996年1月23日JDK1.0Java虚拟机SunClassicVM,Applet,AWT2.1997年2月19日JDK1.1JAR文件格式,JDBC,JavaBea...

java 进化史1(java的进阶之路)

java从1996年1月第一个版本诞生,到2022年3月最新的java18,已经经历了27年,整整18个大的版本。很久之前有人就说java要被淘汰,但是java活到现在依然坚挺,不知道java还能活...

学习java第二天(java学完后能做什么)

#java知识#...

取消回复欢迎 发表评论: