群聊天 群内消息发送 这里就不搭建wokerman直接上代码
群聊天 群内消息发送
<?php
/**
* @ Copyright 2017-2018 VARIANT TECHNOLOGY CO.,LTD All Rights Reserved.
* Created by PhpStorm.
* @author [wolf]
* @version [版本号,2019年4月23日 9:46]
* @see [相关文件,类,函数]
* @since [产品/模块]
* @deprecated
*/
namespace app\user\controller;
use think\Controller;
use think\Db;
use think\worker\Server;
use Workerman\Lib\Timer;
class ChatController extends Server
{
protected $socket = 'websocket://127.0.0.1:3000';
protected $processes = 10;
/**
* 收到信息
*
* @param $connection
* @param $data
*/
public function onMessage($connection, $data)
{
$arr = json_decode($data, true);
global $worker;
if($arr['type'] == 1)
{//验证用户是否是群主
//建立聊天室
if(!isset($uid))
{
$uid = $arr['business_id'];//群id
}
$connection->uid = $uid;
$worker->uidConnections[$connection->uid] = $this->worker->connections;
foreach ( $this->worker->connections as $connection)
{
if($connection->uid == $uid)
{//向指定uid的用户发送消息
$connection->send($arr['content']);
}
}
}
else if($arr['type'] == 2)
{
if(!isset($uid))
{
$uid = $arr['a_business_id'];//群id
}
$connection->uid = $uid;
$worker->uidConnections[$connection->uid] = $this->worker->connections;
foreach ( $this->worker->connections as $connection)
{
if($connection->uid == $uid)
{//向指定uid的用户发送消息
$connection->send($arr['content']);
}
}
}
}
/**
*
* @param $connection当连接建立时触发的回调函数
*/
public function onConnect($connection)
{
$connection->uid = '';
}
/**
* 当连接断开时触发的回调函数
*
* @param $connection
*/
public function onClose($connection)
{
/*global $worker;
if(isset($uid))
{
// 连接断开时删除映射
unset($worker->uidConnections[$uid]);
}*/
}
/**
* 当客户端的连接上发生错误时触发
*
* @param $connection
* @param $code
* @param $msg
*/
public function on
error($connection, $code, $msg)
{
echo "error $code $msg\n";
}
/**
* 每个进程启动
*
* @param $worker
*/
public function onWorkerStart($worker)
{
}
//向所有验证的用户推送数据
public function broadcast($message)
{
global $worker;
foreach ($worker->uidConnections as $connection)
{
$connection->send($message);
}
}
}