Update: 修复websocket处理包失败问题

i0gan · i0gan · commit 0b044b7add01 · 2026-01-27T11:22:02.000+08:00
diff --git a/src/plugin/core/net/net.cc b/src/plugin/core/net/net.cc
@@ -140,7 +140,7 @@ void Net::conn_readcb(struct bufferevent *bev, void *user_data) {
         int len = pObject->GetBuffLen();
         if (len > 0) {
             if (pNet->mRecvCB) {
-                pNet->mRecvCB(pObject->GetRealFD(), -1, pObject->GetBuff(), len);
+                pNet->mRecvCB(pObject->GetRealFD(), 0, pObject->GetBuff(), len);
                 pNet->mnReceiveMsgTotal++;
             }
 
diff --git a/src/plugin/core/net/ws_module.cc b/src/plugin/core/net/ws_module.cc
@@ -216,7 +216,7 @@ bool WSModule::SendRawMsg(const std::string &msg, const socket_t sock) {
 }
 
 void WSModule::OnReceiveNetPack(const socket_t sock, const uint32_t msg_id, const char *msg, const uint32_t len) {
-    if (msg_id < 0) {
+    if (msg_id == 0) {
         NetObject *pNetObject = m_pNet->GetNetObject(sock);
         if (nullptr != pNetObject) {
             switch (pNetObject->GetConnectState()) {

Original file line number	Diff line number	Diff line change
`@@ -140,7 +140,7 @@ void Net::conn_readcb(struct bufferevent bev, void user_data) {`
`140`	`140`	`int len = pObject->GetBuffLen();`
`141`	`141`	`if (len > 0) {`
`142`	`142`	`if (pNet->mRecvCB) {`
`143`		`- pNet->mRecvCB(pObject->GetRealFD(), -1, pObject->GetBuff(), len);`
	`143`	`+ pNet->mRecvCB(pObject->GetRealFD(), 0, pObject->GetBuff(), len);`
`144`	`144`	`pNet->mnReceiveMsgTotal++;`
`145`	`145`	`}`
`146`	`146`
Original file line number	Diff line number	Diff line change
`@@ -216,7 +216,7 @@ bool WSModule::SendRawMsg(const std::string &msg, const socket_t sock) {`
`216`	`216`	`}`
`217`	`217`
`218`	`218`	`void WSModule::OnReceiveNetPack(const socket_t sock, const uint32_t msg_id, const char *msg, const uint32_t len) {`
`219`		`- if (msg_id < 0) {`
	`219`	`+ if (msg_id == 0) {`
`220`	`220`	`NetObject *pNetObject = m_pNet->GetNetObject(sock);`
`221`	`221`	`if (nullptr != pNetObject) {`
`222`	`222`	`switch (pNetObject->GetConnectState()) {`