本文目录一览：
golang 能链接多少个 websocket
用一个服务器是可以的，但是websocket必须是同一个对象连接服务，否则会报错。 websocket.onmessage = function (evt) { //收到服务器消息，使用evt.data提取 //自己根据返回的内容分发给不同聊天室};有啥问题可以留言给我
go语言聊天室实现（七）websocket收消息设置
上一节中，我们为每个连接都创建了一个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语言聊天室实现（六）创建HTTP连接，并升级为长连接
我们在mian函数中，首先初始化配置文件，然后新建http连接。
这个连接创建之后，监听服务器的9999端口。如果url的路径后缀为 “/ws”,就转发到ws/ws.go中的IndexHandler方法中。
这个方法中首先我们创建一个websocket的Upgrader实例，然后我们使用Upgrader的upgrade方法来升级一下我们的连接为长连接。
升级完成之后会返回一个*websocket.Conn的连接，我们之后所有的关于连接的操作，都是基于该conn的。
在该连接完成之后，我们将连接存放到一个名为Client的map中，以便之后管理更为方便。
之后，我们启动一个goroutine来读取连接中发送的信息内容，再根据内容进行相应的操作。
原创文章，作者：小蓝，如若转载，请注明出处：https://www.506064.com/n/243288.html
微信扫一扫 
支付宝扫一扫 