fixed
This commit is contained in:
@@ -110,8 +110,8 @@ class Events extends \think\worker\Events
|
|||||||
public static function onMessage($client_id, $data)
|
public static function onMessage($client_id, $data)
|
||||||
{
|
{
|
||||||
Tools::log_to_write_txt(['客户端发来数据(Gateway进程收到数据).client_id:'.$client_id,$data]);
|
Tools::log_to_write_txt(['客户端发来数据(Gateway进程收到数据).client_id:'.$client_id,$data]);
|
||||||
$res = Tools::set_ok('ok',['client_id'=>$client_id,'msg'=>'你发来的消息我接收到了:',$client_id=>$data]);
|
//$res = Tools::set_ok('ok',['client_id'=>$client_id,'msg'=>'你发来的消息我接收到了:',$client_id=>$data]);
|
||||||
Gateway::sendToClient($client_id,json_encode($res,JSON_UNESCAPED_UNICODE));
|
//Gateway::sendToClient($client_id,json_encode($res,JSON_UNESCAPED_UNICODE));
|
||||||
|
|
||||||
//if(empty($data)){
|
//if(empty($data)){
|
||||||
// $json = BaseWssApi::json_wss('error','消息为空');
|
// $json = BaseWssApi::json_wss('error','消息为空');
|
||||||
|
|||||||
Reference in New Issue
Block a user