private const int Port = 8777;private HttpListener _listener;private readonly string _printerConfigFile;private readonly Control _parent;private CancellationTokenSource _cancellationTokenSource; public async Task Start() {     // 加载用户设置      LoadSettings();
     _listener = new HttpListener();     _listener.Prefixes.Add($"http://localhost:{Port}/");     _listener.Start();
     Console.WriteLine($"🛡️ WebSocket服务已启动: ws://localhost:{Port}/print");
     try     {         while (!_cancellationTokenSource.Token.IsCancellationRequested)         {             var context = await _listener.GetContextAsync();             if (context.Request.IsWebSocketRequest)             {                 // 处理WebSocket请求                  await ProcessWebSocketRequest(context);             }             else             {                 // 处理其他HTTP请求（可选）                 context.Response.StatusCode = 400;                 context.Response.Close();             }         }     }     catch (Exception ex)     {         Console.WriteLine($"🔴 服务异常: {ex.Message}");     } }

        //处理消息，并打印        private async Task ProcessWebSocketRequest(HttpListenerContext context)        {            WebSocket webSocket = null;            try            {                // 接受WebSocket连接                 var wsContext = await context.AcceptWebSocketAsync(null);                webSocket = wsContext.WebSocket;                Console.WriteLine("🟢 客户端已连接");
                var buffer = new byte[1024 * 1024];                // 持续接收消息                while (webSocket.State == WebSocketState.Open &&                       !_cancellationTokenSource.Token.IsCancellationRequested)                {                    WebSocketReceiveResult result;                    string json = string.Empty;                    using (var ms = new MemoryStream())                    {                        do                        {                            var segment = new ArraySegment<byte>(buffer);                            result = await webSocket.ReceiveAsync(segment, CancellationToken.None);                            if (result.MessageType == WebSocketMessageType.Close)                            {                                await webSocket.CloseAsync(WebSocketCloseStatus.NormalClosure,                                                         "客户端关闭连接",                                                         CancellationToken.None);                                return;                            }
                            if (result.Count > 0)                            {                                ms.Write(buffer, 0, result.Count);                            }                        } while (!result.EndOfMessage);                        json = Encoding.UTF8.GetString(ms.ToArray());                    }                    if (!string.IsNullOrEmpty(json))                    {                        // 解析打印请求                        var printReq = new PrintRequest();                        var obj = JObject.Parse(json);                        var jsonData = JsonConvert.DeserializeAnonymousType(json, new                        {                            ReportId = "",                            ReportContent = "",                            PrintCopies = 1                        });                        if (!string.IsNullOrEmpty(jsonData.ReportId) && !string.IsNullOrEmpty(jsonData.ReportContent))                        {                            printReq.ReportId = jsonData.ReportId;                            printReq.ReportContent = Base64UrlEncoder.Decode(jsonData.ReportContent);                            printReq.PrintCopies = jsonData.PrintCopies;                            // 在主线程执行打印操作                             _parent.Invoke((MethodInvoker)delegate                            {                                PrintDocument(printReq);                            });                            // 发送成功响应                             var response = JsonConvert.SerializeObject(new                            {                                Flag = true,                                Msg = "打印成功"                            });
                            await webSocket.SendAsync(new ArraySegment<byte>(Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(response))),                                                    WebSocketMessageType.Text,                                                    true,                                                    CancellationToken.None);                        }                    }                }            }            catch (WebException ex)            {                Console.WriteLine($"🔴 WebSocket错误: {ex.Message}");            }            catch(Exception ex)            {                var response = JsonConvert.SerializeObject(new                {                    Flag = false,                    Msg = ex.Message                });                await webSocket.SendAsync(new ArraySegment<byte>(Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(response))),                                        WebSocketMessageType.Text,                                        true,                                        CancellationToken.None);            }            finally            {                webSocket?.Dispose();                Console.WriteLine("🔴 客户端已断开");            }        }

         async printManual(){             if(this.isPrinting){                 this.$message.info('请等待当前打印完成');                 return             }             if(!this.printData.BoxQty) {                 this.$message.info("每箱数量必须大于0");                 return;             }             if(!this.printData.GrossWeight) {                 this.$message.info("毛重必须大于0");                 return;             }             this.isPrinting=true;             this.setPrintResult('printing', '正在发送打印任务...');             try{                 const res=await this.$post("@Url.Action("PrintManual", "Print")",this.printData);                 if(res.data.Status!=='OK'){                     throw new Error(res.data.Msg||'获取打印数据失败');                 }                 const taskId=Date.now().toString();                 this.setPrintResult('printing', '正在连接打印机...', {                     taskId: taskId                 });                 //连接客户端打印守护接口                 if(!this.printManager.isConnected){                     await this.printManager.connect();                 }
                 await this.printManager.send(JSON.stringify(res.data.Response));                 this.setPrintResult('printing', '已发送到打印机，等待响应...');                 // 设置打印超时（30秒）                 this.printTimeoutTimer = setTimeout(() => {                     if (this.isPrinting) {                         this.handlePrintTimeout();                     }                 }, 30000);             }catch(err){                 this.handlePrintError(error.message);             }          

  /**   * 连接 WebSocket 服务器   */  async connect() {      if (this.isConnected || this.isConnecting) {          this.log('⏳ 已连接或正在连接中');          return this.waitForConnection();      }
      this.isConnecting = true;      this.log('🔌 开始连接 WebSocket...');
      return new Promise((resolve, reject) => {          try {              // 创建 WebSocket 连接 ws://localhost              this.ws = new WebSocket(this.config.url);              this.ws.binaryType = this.config.binaryType;
              // 设置连接超时              const connectionTimeout = setTimeout(() => {                  if (!this.isConnected) {                      this.log('❌ 连接超时');                      this.ws.close();                      reject(new Error('连接超时'));                      this.isConnecting = false;                  }              }, this.config.connectionTimeout);
              // 连接成功              this.ws.onopen = () => {                  clearTimeout(connectionTimeout);                  this.log('✅ WebSocket 连接成功');                  this.isConnected = true;                  this.isConnecting = false;                  this.reconnectAttempts = 0;
                  // 触发事件                  this.triggerEvent('open', null);                  this.triggerEvent('connected', null);
                  // 启动心跳                  this.startHeartbeat();
                  // 发送积压消息                  this.flushMessageQueue();
                  resolve();              };
              // 连接关闭              this.ws.onclose = (event) => {                  clearTimeout(connectionTimeout);                  this.log(`🔴 连接关闭，代码: ${event.code}, 原因: ${event.reason}`);                  this.isConnected = false;                  this.isConnecting = false;
                  // 停止心跳                  this.stopHeartbeat();
                  // 触发事件                  this.triggerEvent('close', event);                  this.triggerEvent('disconnected', event);
                  // 自动重连                  if (this.config.reconnect && event.code !== 1000) {                      this.reconnect();                  }              };
              // 连接错误              this.ws.onerror = (error) => {                  clearTimeout(connectionTimeout);                  this.log('❌ WebSocket 错误:', error);                  this.isConnecting = false;
                  // 触发事件                  this.triggerEvent('error', error);
                  reject(error);              };
              // 接收消息              this.ws.onmessage = (event) => {                  this.handleMessage(event);              };
          } catch (error) {              this.isConnecting = false;              this.log('❌ 创建 WebSocket 失败:', error);              reject(error);          }      });  }