本文主要
介绍了swoole + Redis的相关内容来实现股票和块链
服务,
分享出来供大家
参考学习。让我们
详细介绍一下。
PHP的redis
扩展受阻的IO,使整个过程块当订阅/发布
模式的使用。因此,该swoole Redis异步客户端必须实现它。
$ SERVER =新swoole_websocket_server(0.0.0.0
$服务器->上('workerstart
功能($ SERVER,workerid美元){
客户=新swoole_redis美元;
客户->对美元(
消息功能(swoole_redis美元美元的客户,结果)使用($ SERVER){($ SERVER){
如果($结果{ 0 } = =消息){
foreach($服务器->
连接至FD){
服务器>推($ $,$结果{ 1 });
}
}
});
为客户->连接('127.0.0.1 ',6379,(swoole_redis客户端功能美元,导致美元){
为客户->订阅('kline1min);
});
});
$服务器->上(打开,功能($ SERVER,要求美元){
});
$服务器->在(消息,功能(swoole_websocket_server $ SERVER,为帧){
服务器>推($帧> FD,hello);
});
$服务器->对('
关闭',功能(合服务,为FD){
});
服务器>开始();
在起动过程中(onworkerstart),该swoole redis客户端
创建连接到redis
服务器 邮件订阅的msg_0话题连接成功后
当有新的消息,swoole redis触发的onmessage事件回调
在这个回调函数中,使用$ > >连接遍历服务器的所有连接并发送消息。
总结
以上就是本文的全部内容。希望本文的内容对大家的学习或
工作有一定的参考价值。如果有任何疑问,可以留言交流,谢谢您的
支持。