update: json 字符串输出

Author: lisgroup

laravel/app/Services/WebSocketService.php

@@ -37,15 +37,16 @@ public function onOpen($server, $request)
             while (true) {
                 // 3. 输出完成率
                 $rate = MultithreadingRepository::getInstent()->completionRate($req['id']);
-                $server->push($request->fd, $rate.'%');
+                $data = $this->outJson(200, ['rate' => $rate]);
+                $server->push($request->fd, $data);
                 sleep(3);
 
                 if ($rate >= 100) {
                     break;
                 }
             }
         } else {
-            $server->push($request->fd, '100%');
+            $server->push($request->fd, $this->outJson(200, ['rate' => '100']));
         }
 
         // throw new \Exception('an exception');// 此时抛出的异常上层会忽略，并记录到Swoole日志，需要开发者try/catch捕获处理
@@ -62,4 +63,22 @@ public function onClose($server, $fd, $reactorId)
     {
         // throw new \Exception('an exception');// 此时抛出的异常上层会忽略，并记录到Swoole日志，需要开发者try/catch捕获处理
     }
+
+    /**
+     * 处理输出
+     *
+     * @param int $code
+     * @param array $data
+     * @param string $reason
+     *
+     * @return array
+     */
+    public function outJson($code = 200, $data = [], $reason = 'success')
+    {
+        if ($reason === 'success') {
+            $reason = config('errorCode.'.$code.'.reason') ?? 'success';
+        }
+
+        return json_encode(['code' => $code, 'reason' => $reason, 'data' => $data], JSON_UNESCAPED_UNICODE);
+    }
 }