数码资讯
使用swoole+Redis实现股票和块链服务
本文主要介绍了swoole + Redis的相关内容来实现股票和块链服务,分享出来供大家参考学习。让我们详细介绍一下。 PHP的redis扩展受阻的IO,使整个过程块当订阅/发布模式的使用。因此,该swoole Redis异步客户端必须实现它。 $ SERVER =新swoole_websocket
选购提示
关注价格、性能、续航、售后和真实使用场景,理性比较后再下单。
本文主要介绍了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事件回调
在这个回调函数中,使用$ > >连接遍历服务器的所有连接并发送消息。
总结
以上就是本文的全部内容。希望本文的内容对大家的学习或工作有一定的参考价值。如果有任何疑问,可以留言交流,谢谢您的支持。
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事件回调
在这个回调函数中,使用$ > >连接遍历服务器的所有连接并发送消息。
总结
以上就是本文的全部内容。希望本文的内容对大家的学习或工作有一定的参考价值。如果有任何疑问,可以留言交流,谢谢您的支持。
声明:本文内容用于数码产品信息整理与选购参考,具体价格、库存、售后政策以官方渠道和电商页面实时信息为准。