From 2970f368bc2cd6da0c80d154c9c1222af1763b1c Mon Sep 17 00:00:00 2001 From: laodaming <11058467+laudamine@user.noreply.gitee.com> Date: Mon, 30 Oct 2023 18:24:42 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4=E4=BA=A7=E5=93=81=E6=9C=8D?= =?UTF-8?q?=E5=8A=A1=E6=97=A0=E7=94=A8=E7=9A=84=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../logic/ws_allocation_processing_factory.go | 16 +++++----------- 1 file changed, 5 insertions(+), 11 deletions(-) diff --git a/server/websocket/internal/logic/ws_allocation_processing_factory.go b/server/websocket/internal/logic/ws_allocation_processing_factory.go index 9ba718cc..7fedddc1 100644 --- a/server/websocket/internal/logic/ws_allocation_processing_factory.go +++ b/server/websocket/internal/logic/ws_allocation_processing_factory.go @@ -10,20 +10,14 @@ type allocationProcessorFactory interface { allocationMessage(w *wsConnectItem, data []byte) } -var mapAllocationProcessor = make(map[constants.Websocket]allocationProcessorFactory) +// 要添加分发在这里 +var mapAllocationProcessor = map[constants.Websocket]allocationProcessorFactory{ + constants.WEBSOCKET_RENDER_IMAGE: &renderProcessor{}, //渲染工厂 +} func (w *wsConnectItem) newAllocationProcessor(msgType constants.Websocket) allocationProcessorFactory { if val, ok := mapAllocationProcessor[msgType]; ok { return val } - var obj allocationProcessorFactory - switch msgType { - //图片渲染 - case constants.WEBSOCKET_RENDER_IMAGE: - obj = &renderProcessor{} - default: - return nil - } - mapAllocationProcessor[msgType] = obj - return obj + return nil }