当前位置： > > > > 我需要解决 golang 服务器上的 websockets 问题

我需要解决 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"`
}

因此，将您的信息解组为字符串是行不通的，因为您发送的对象不是字符串，而是必须以不同的方式表示。

要解决此问题，您有两种选择：

1. 更改服务器端方法定义以便能够接受客户端数据：

   使用 server.onevent("/", "msg", func(s socketio.conn, msg message) string {，注意 msg 现在是 message 类型，它是与接收到的数据匹配的结构体。

或者

1. 更改您的客户端发送的数据：

   使用 this.socket.emit("msg", "hello!"); 仅发送一个字符串（然后该字符串将被正确解码为字符串类型的 msg 参数。

到这里，我们也就讲完了《我需要解决 golang 服务器上的 websockets 问题》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注米云公众号，带你了解更多关于的知识点！