已经解决了，我在把GatewayWorker\Lib\DbConnection.php 的$sQuery属性改成 public,然后在我的业务代码执行完single()查询之后，调用一下$db1->sQuery->closeCursor();就可以了，代码如下。。 $orderCount = $db1->single("select count(*) as count from t2 lim...

我的需求是每隔一段时间查询数据库，然后推送给所有人 代码类似如下： while(true){ $sql ="select 1+1"; $count=$mysql->query($sql); Gateway::sendToAll(json_encode($count)); sleep(1000); } 我现在用websocket的onMessage来写这个的话，但是他是每个客户端...

每次客户端连接后，第一次发送聊天信息，服务器那里执行插入就会出错，再发一次他就正常了。两次发送的信息都是一样的，除了时间。 错误如下： 用的GatewayWorker INSERT INTO `xf_user_im` (`send_id`,`accept_id`,`sender`,`time`,`type`,`content`,`msg_time`) VALUES ('4','5','guwen','14679411...