测试修改

application/chat/Events.php

@@ -55,9 +55,9 @@ class Events
          if(is_array($message)){
              self::changestatus($message);
          }else{
-             echo 'default';
+             //echo 'default';
          }
-         return ;
+         //return ;
 
          /*if(is_array($message) && isset($message['action']) && $message['action'] == 'changestatus'){
              self::changestatus($message);
@@ -67,6 +67,19 @@ class Events
          return ;*/
     }
 
+    /**
+     * 当客户端连接时触发
+     * 如果业务不需此回调可以删除onConnect
+     * @param int $client_id 连接id
+     */
+    /*public static function onConnect($client_id)
+    {
+        // 向当前client_id发送数据
+        Gateway::sendToClient($client_id, "Hello $client_id");
+        // 向所有人发送
+        Gateway::sendToAll("$client_id login");
+    }*/
+
 
 	/*{
         'action':'changestatus',

application/database.php

@@ -52,4 +52,6 @@ return [
     'datetime_format' => 'Y-m-d H:i:s',
     // 是否需要进行SQL性能分析
     'sql_explain'     => false,
+    // 是否需要断线重连
+    'break_reconnect' => true,
 ];

restart.sh

@@ -1,2 +1,2 @@
 php newone.php stop;
-php newone.php start -d;
+php newone.php start -d;

thinkphp/library/think/db/Connection.php

@@ -109,7 +109,7 @@ abstract class Connection
         // Query类
         'query'           => '\\think\\db\\Query',
         // 是否需要断线重连
-        'break_reconnect' => false,
+        'break_reconnect' => true,
     ];
 
     // PDO连接参数
@@ -313,11 +313,21 @@ abstract class Connection
      * 释放查询结果
      * @access public
      */
-    public function free()
+    public function free_old()
     {
         $this->PDOStatement = null;
     }
 
+    public function free()
+    {
+        try {
+            $this->PDOStatement = null;
+        } catch (Exception $e) {
+            Log::write("has error when free PDOStatement maybe mysql gone away,skip it:" . $e->getMessage(), log::DEBUG);
+        }
+    }
+
+
     /**
      * 获取PDO对象
      * @access public