当前位置： > > > > 我需要解决 golang 服务器上的 websockets 问题
来源：stackoverflow
2024-05-01 19:57:37
0浏览
收藏
大家好，我们又见面了啊~本文《我需要解决 golang 服务器上的 websockets 问题》的内容中将会涉及到等等。如果你正在学习Golang相关知识，欢迎关注我，以后会给大家带来更多Golang相关文章，希望我们能一起进步！下面就开始本文的正式内容~
问题内容
我在 golang 和 googollee/go-socket.io 上有一个服务器。
当服务器和客户端工作在同一端口时，套接字工作正常。但是当我启动时，它们位于不同的端口上，客户端上会出现错误：
与“ws://localhost:4444/socket.io/?eio=3&transport=websocket&sid=6”的 websocket 连接失败：websocket 握手期间出错：意外的响应代码：403
post http://localhost:4444/socket.io/?eio=3&transport=polling&t=nddzcym&sid=5 400（错误请求）
get http://localhost:4444/socket.io/?eio=3&transport=polling&t=nddzcyc&sid=5 400（错误请求）
与“ws://localhost:4444/socket.io/?eio=3&transport=websocket&sid=5”的 websocket 连接失败：websocket 握手期间出错：意外的响应代码：403
在服务器上：
连接：1 关闭的客户端名称空间断开连接遇到错误：json：无法将对象解组为字符串类型的 go 值连接：2
这是我的代码：
package main
import (
"fmt"
"log"
"net/http"
"github.com/gorilla/mux"
"github.com/rs/cors"
socketio "github.com/googollee/go-socket.io"
)
func main() {
fmt.println("hello world")
router := mux.newrouter()
router.handlefunc("/is-alive", isalive).methods("get")
server, err := socketio.newserver(nil)
if err != nil {
log.fatal(err)
}
server.onconnect("/", func(s socketio.conn) error {
s.setcontext("")
fmt.println("connected:", s.id())
s.emit("change")
s.join("bcast")
return nil
})
server.onevent("/", "msg", func(s socketio.conn, msg string) string {
s.setcontext(msg)
s.emit("change")
fmt.println("event: msg")
return "recv " + msg
})
server.onerror("/", func(s socketio.conn, e error) {
fmt.println("meet error:", e)
})
server.ondisconnect("/", func(s socketio.conn, reason string) {
fmt.println("closed", reason)
})
go server.serve()
defer server.close()
router.handle("/socket.io/", server)
c := cors.new(cors.options{
allowedorigins: []string{"http://localhost:3000"},
allowcredentials: true,
})
handler := c.handler(router)
log.println("serving at localhost:4444...")
log.fatal(http.listenandserve(":4444", handler))
}
func isalive(w http.responsewriter, r *http.request) {
w.writeheader(http.statusok)
}
在我的反应应用程序上
import socketIOClient from "socket.io-client";
export class SocketClientManager {
public socket = socketIOClient("ws://localhost:4444");
public subscribe() {
this.socket.emit("msg", { msg: "Hello!" });
}
public setCallback(callback: (arg: any) => void) {
this.socket.on("change", callback);
}
public async unsubscribe() {
this.socket.disconnect();
}
}
解决方案
错误消息表明服务器尝试将您的 json 对象解组为字符串，但它期望不同的内容。
原因在于您的方法定义中：
server.onevent("/", "msg", func(s socketio.conn, msg string) string {
msg 是字符串类型。
但是，您发送了不同类型的消息：
public subscribe() {
this.socket.emit("msg", { msg: "hello!" });
}
此消息可以在此结构定义中描述：
type Message struct {
Msg string `json:"msg"`
}
因此，将您的信息解组为字符串是行不通的，因为您发送的对象不是字符串，而是必须以不同的方式表示。
要解决此问题，您有两种选择：
-
更改服务器端方法定义以便能够接受客户端数据：
使用
server.onevent("/", "msg", func(s socketio.conn, msg message) string {，注意msg现在是message类型，它是与接收到的数据匹配的结构体。
或者
-
更改您的客户端发送的数据：
使用
this.socket.emit("msg", "hello!");仅发送一个字符串（然后该字符串将被正确解码为字符串类型的msg参数。
到这里，我们也就讲完了《我需要解决 golang 服务器上的 websockets 问题》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注公众号，带你了解更多关于的知识点！
