使用swoole+Redis实现股票和块链服务

使用swoole+Redis实现股票和块链服务
本文主要介绍了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事件回调
在这个回调函数中,使用$ > >连接遍历服务器的所有连接并发送消息。
总结

以上就是本文的全部内容。希望本文的内容对大家的学习或工作有一定的参考价值。如果有任何疑问,可以留言交流,谢谢您的支持

免责声明:本网信息来自于互联网,目的在于传递更多信息,并不代表本网赞同其观点。其原创性以及文中陈述文字和内容未经本站证实,对本文以及其中全部或者部分内容、文字的真实性、完整性、及时性本站不作任何保证或承诺,并请自行核实相关内容。本站不承担此类作品侵权行为的直接责任及连带责任。如若本网有任何内容侵犯您的权益,请及时联系我们,本站将会在24小时内处理完毕。
相关文章
返回顶部