This commit is contained in:
laodaming 2023-08-30 17:46:47 +08:00
parent 6c36817750
commit b8dbda6a4c
3 changed files with 7 additions and 6 deletions

View File

@ -19,10 +19,10 @@ func (w *wsConnectItem) newAllocationProcessor(msgType constants.Websocket) allo
switch msgType { switch msgType {
//图片渲染 //图片渲染
case constants.WEBSOCKET_RENDER_IMAGE: case constants.WEBSOCKET_RENDER_IMAGE:
obj = &renderProcesser{w} obj = &renderProcessor{w}
//刷新重连请求恢复上次连接的标识 //刷新重连请求恢复上次连接的标识
case constants.WEBSOCKET_REQUEST_REUSE_LAST_CONNECT: case constants.WEBSOCKET_REQUEST_REUSE_LAST_CONNECT:
obj = &reuseConnProcesser{w} obj = &reuseConnProcessor{w}
default: default:
} }

View File

@ -19,7 +19,7 @@ import (
) )
// 渲染处理器 // 渲染处理器
type renderProcesser struct { type renderProcessor struct {
w *wsConnectItem w *wsConnectItem
} }
@ -49,7 +49,8 @@ type renderTask struct {
uploadUnityRenderImageTakesTime int64 //上传unity渲染结果图时间 uploadUnityRenderImageTakesTime int64 //上传unity渲染结果图时间
} }
func (r *renderProcesser) allocationMessage(data []byte) { func (r *renderProcessor) allocationMessage(data []byte) {
logx.Info("收到渲染任务消息:", string(data))
select { select {
case <-r.w.closeChan: //已经关闭 case <-r.w.closeChan: //已经关闭
return return

View File

@ -10,11 +10,11 @@ import (
) )
// 复用连接处理器 // 复用连接处理器
type reuseConnProcesser struct { type reuseConnProcessor struct {
w *wsConnectItem w *wsConnectItem
} }
func (r *reuseConnProcesser) allocationMessage(data []byte) { func (r *reuseConnProcessor) allocationMessage(data []byte) {
logx.Info("收到请求恢复上次连接标识数据:", string(data)) logx.Info("收到请求恢复上次连接标识数据:", string(data))
var wid string var wid string
if err := json.Unmarshal(data, &wid); err != nil { if err := json.Unmarshal(data, &wid); err != nil {