websocket协议测试

 <?php
 <?php
-require_once __DIR__ . '/simplewind/vendor/autoload.php';
+//require_once __DIR__ . '/simplewind/vendor/autoload.php';
 require_once __DIR__ . '/simplewind/vendor/workerman/workerman/Autoloader.php';
 require_once __DIR__ . '/simplewind/vendor/workerman/workerman/Autoloader.php';
 use Workerman\Worker;
 use Workerman\Worker;
 use think\Db;
 use think\Db;
@@ -130,11 +130,22 @@ $tcp_worker->name='panhaowen';
 // 启动4个进程对外提供服务
 // 启动4个进程对外提供服务
 $tcp_worker->count = 1;
 $tcp_worker->count = 1;
 
 
+
+
+$tcp_worker->onWorkerStart = function($tcp_worker)
+{
+    // 将db实例存储在全局变量中(也可以存储在某类的静态成员中)
+    global $db;
+    $db = new \Workerman\MySQL\Connection('rm-m5eblhc9o3515i25n.mysql.rds.aliyuncs.com', '3306', 'db136s1ehvo1yn73', 'cxz307311SJK', 'scoreshop');
+};
 // 当客户端发来数据时
 // 当客户端发来数据时
 $tcp_worker->onMessage = function($connection, $data)
 $tcp_worker->onMessage = function($connection, $data)
 {
 {
     // 向客户端发送hello $data
     // 向客户端发送hello $data
-    $connection->send('hello '. $data);
+    global $db;
+    // 执行SQL
+    $all_tables = $db->query('sc_user');
+    $connection->send('hello '. $all_tables);
 //    Db::table('user')->where('id',1)->update(['sex'=>2]);
 //    Db::table('user')->where('id',1)->update(['sex'=>2]);
 //    if ($data=='tom') {
 //    if ($data=='tom') {
 //        Db::table('user')->where('id',1)->update(['sex'=>1]);
 //        Db::table('user')->where('id',1)->update(['sex'=>1]);