我们可以看到 gorilla/websocket中的examples中有一个聊天室的demo.
我们进入该项目可以看到里面有这样的一些内容
按照官方的运行方式来运行这个项目
就是这样一个简单的demo.
然后我们去看一下它的具体实现.
在这个项目中首先定义了一个hub的结构体：
我们打开main.go,main函数的源码为：
今天这一节首先会新开一个goroutine,去跑hub的run方法,run方法中一个死循环,不停地去轮询hub中的内容
如果取到了新用户,就加入到clients中,如果取到了信息,就循环所有的client,将信息写到client.send中.
而在请求路径为"/ws"的时候,他会执行一个serveWS的函数.
每当一个新的用户进来之后,首先将连接升级为长连接,然后将当前的client写到register中,由hub.run函数去做处理.然后开启两个goroutine,一个去读client中发送来的数据,一个将数据写入到所有的client中,去发送给用户.
这就是整个聊天室的实现原理.
我们在mian函数中,首先初始化配置文件,然后新建http连接.
这个方法中首先我们创建一个websocket的Upgrader实例,然后我们使用Upgrader的upgrade方法来升级一下我们的连接为长连接.
升级完成之后会返回一个*websocket.Conn的连接,我们之后所有的关于连接的操作,都是基于该conn的.
在该连接完成之后,我们将连接存放到一个名为Client的map中,以便之后管理更为方便.
之后,我们启动一个goroutine来读取连接中发送的信息内容,再根据内容进行相应的操作.
Go语言在云计算、大数据、微服务、高并发领域应用应用非常广泛.BAT大厂正在把Go作为新项目开发的首选语言.
Go语言应用范围：
①.、服务端开发：以前你使用C或者C++做的那些事情,用Go来做很合适,例如日志处理、文件系统、监控系统等;
上一节中,我们为每个连接都创建了一个goroutine来读取其中的消息,现在我们将这个读取消息的方法实现一下.
我们在application目录下新建controllers目录,并在其中创建一个MessageController.go文件.
首先我们新建一个MessageController的结构体,内容如下
这个结构体包括两个内容,一个是我们将连接放在数组之后,返回的索引,另一个是连接本身.
这个是具体的方法.
我们首先设置了一下读消息的大小、超时时间以及超时后需要的操作.
超时时间如果设置为0,那么就是永不超时.之前今天这一节直接写0,被告知需要传一个time.Time类型的数据.最终谷歌后才得到了这个值time.Time{}为"0001-01-01 00:00:00 +0000 UTC".
我们将用户手法消息的内容定义为一个结构体,然后将用户的订阅信息的json通过json.unmarshal转换成这个结构体.
之后的switch操作与我们在Swoole中的操作基本雷同,在查询到login之后,调用service中 的login方法来进行注册.
下一节中我们再介绍具体的注册逻辑.
以上就是土嘎嘎小编为大家整理的go语言即时聊天应用相关主题介绍,如果您觉得小编更新的文章只要能对粉丝们有用,就是我们最大的鼓励和动力,不要忘记讲本站分享给您身边的朋友哦！！