php gatewaywoker,GatewayWorker使用总结

偏执的太偏执、 2022-11-18 13:38 130阅读 0赞

首先，看懂这个图，真的很重要的！不骗你！！！

![1b8820a769d5ff468e9dcceb5bbf256e.png][]

我也不想说什么，累了，折腾一天了！直接上代码了！

前端代码

ws = new WebSocket("ws://127.0.0.1:8282");

// 服务端主动推送消息时会触发这里的onmessage

ws.onopen = function()\{\};

ws.onmessage = function(e)\{

console.log(e);

// json数据转换成js对象

var data = eval("("+e.data+")");

var type = data.type || '';

switch(type)\{

// Events.php中返回的init类型的消息，将client\_id发给后台进行uid绑定

case 'init':

var init=JSON.stringify(\{"type":'init','uid':10003\});

ws.send(init);

break;

case 'online':

$.post("", \{uid: data.uid\}, function(data)\{

if(data.code==200)\{

console.log(data.msg)

\}else\{

console.log(data.msg)

\}, 'json');

default :

console.log(e.data);

\};

ws.onclose = function(e)

if(e.type=="close")\{

$.post("", \{uid: 10003\}, function(data)\{

if(data.code==200)\{

console.log(data.msg)

\}else\{

console.log(data.msg)

\}, 'json');

\};

后端代码：

第一：需要修改一下协议

$gateway = new Gateway("WebSocket://0.0.0.0:8282")

第二：响应函数

/\*\*

\* 当客户端连接时触发

\* 如果业务不需此回调可以删除onConnect

\* @param int $client\_id 连接id

\*/

public static function onConnect($client\_id)

global $num;

\++$num;

echo "ConnectTotal:".$num."\\r\\n";

// 向当前client\_id发送数据

//Gateway::sendToClient($client\_id, "Hello $client\_id\\r\\n");

// 向所有人发送

//Gateway::sendToAll("$client\_id login\\r\\n");

Gateway::sendToClient($client\_id, json\_encode(array(

'type'      => 'init',

'client\_id' => $client\_id

)));

/\*\*

\* 当客户端发来消息时触发

\*/

public static function onMessage($client\_id, $message)

// 向所有人发送

//Gateway::sendToAll("$client\_id said $message\\r\\n");

if(!$message)\{

return false;

$message\_data=json\_decode($message,true);

switch ($message\_data\['type'\])\{

case 'init':

Gateway::bindUid($client\_id,$message\_data\['uid'\]);

$sdata=\[

'type'      => 'online',

'client\_id' => $client\_id,

'uid'=>$message\_data\['uid'\]

\];

Gateway::sendToUid($message\_data\['uid'\],json\_encode($sdata));

break;

default:

return false;

/\*\*

\* 当用户断开连接时触发

\* @param int $client\_id 连接id

\*/

public static function onClose($client\_id)

$data=\[

'type'      => 'close',

'client\_id' => $client\_id,

\];

Gateway::sendToClient($client\_id,json\_encode($data));

第三：最重要的！MVC通讯使用gatewayclient

composer安装：

>composer require workerman/gatewayclient

通讯：

public function say()\{

$data=\[

'type'=>'say',

'data'=>123456

\];

Gateway::$registerAddress = "127.0.0.1:1238";

Gateway::isUidOnline(10003);

Gateway::sendToUid(10003,json\_encode($data));

[1b8820a769d5ff468e9dcceb5bbf256e.png]: http://www.zhanglei928.com/uploads/umeditor/20190422/1b8820a769d5ff468e9dcceb5bbf256e.png

php gatewaywoker,GatewayWorker使用总结

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 PHP优化加速之Opcache使用总结

相关 php技术知识总结,自己总结的PHP知识_PHP教程

相关 php 小技巧总结,phpStorm使用技巧总结

相关 php gatewaywoker,GatewayWorker使用总结

相关 php header总结

相关 php的总结

相关 php生成器使用总结

相关 PHP-resque使用经验总结

相关 PHP openssl加密扩展使用总结

相关总结 php导出Excel php