脚本宝典收集整理的这篇文章主要介绍了php – React / Ratchet / ZMQ中多个订阅方法的最佳实践，脚本宝典觉得挺不错的，现在分享给大家，也给大家做个参考。
对于这种情况,当用户登录或注销时,我在UserController中使用ZMQ PUSH Socket.
UserConstroller
public function login() { //... here is the auth code,model call etc... $aUserData = array();// user data comes From the database wITh username,LOGintime,etc.... $context = new \ZMQContext(); $oSocket = $context->getSocket(\ZMQ::SOCKET_PUSH,'USER_LOGIN_PUSHER'); // use PErsistent_id if($oSocket instanceof \ZMQSocket) { $oSocket->connect("tcp://127.0.0.1:5555"); // $oSocket->send(json_encode($aUserData)); } } public function logout() { //... here is the logout code,model call etc .... $aUserData = array();// user data comes from the SESSION with username,'USER_logoUT_PUSHER'); // use persistent_id if($oSocket instanceof \ZMQSocket) { $oSocket->connect("tcp://127.0.0.1:5555"); // $oSocket->send(json_encode($aUserData)); } }@H_777_12@然后我就像Ratchet文档中那样有一个Pusher类：link
在这个类中有两个方法：onUserLogin和onUserlogout,当然还有所有其他的东西
UserInformationPusher
public function onUserLogin($aUserData) { //var_dump("onUserLogin"); $SUSErData = json_decode($aUserData,true); $oTopic = $this->subscribedTopics["user_login"]; if($oTopic instanceof Topic) { $oTopic->broadcast($sUserData); } else { return; } } public function onUserlogout($aUserData) { //VAR_dump("onUserlogout"); $entryData = json_decode($aUserData,true); $oTopic = $this->subscribedTopics["user_logout"]; if($oTopic instanceof Topic) { $oTopic->broadcast($entryData); } else { return; } }最后一部分是WampServer / WsServer / HttpServer,它有一个Loop来监听传入的连接.还有我的ZMQ PULL插座
RatchetServerConsole
public function start_server() { $oPusher = new UserInformationPusher(); $oLoop = \React\EventLoop\Factory::create(); $oZMQContext = new \React\ZMQ\Context($oLoop); $oPullSocket = $oZMQContext->getSocket(\ZMQ::SOCKET_PULL); $oPullSocket->bind('tcp://127.0.0.1:5555'); // Binding to 127.0.0.1 means the only client that can connect is itself $oPullSocket->on('message',array($oPusher,'onUserLogin')); $oPullSocket->on('message','onUserlogout')); $oMemcache = new \Memcache(); $oMemcache->connect('127.0.0.1',11211); $oMemcacheHandler = new Handler\MemcacheSessionHandler($oMemcache); $oSession = new SessionPRovider( new \Ratchet\Wamp\WampServer( $oPusher ),$oMemcacheHandler ); //$this->Output->info("Server start initiation with memcache!..."); $webSock = new \React\Socket\Server($oLoop); $webSock->listen(8080,'0.0.0.0'); // Binding to 0.0.0.0 means remotes can connect $oServer = new \Ratchet\Server\IoServer( new \Ratchet\Http\HttpServer( new \Ratchet\WebSocket\WsServer( $oSession ) ),$webSock ); $this->Output->info("Server started "); $oLoop->run(); }在此示例中,来自login()或logout()的调用将始终调用这两个方法(onUserLogin和onUserlogout).
我无法找到一些文档,它描述了我可以在on($event,callable $listener)方法中使用哪些事件,是否有人拥有链接/知识库？
检查UserController中哪个方法被触发的最佳方法是什么？>我可以在Controller中的$sUserData中添加一些信息,并在Pusher中进行检查
>我可以将另一个套接字绑定到另一个端口(例如5554用于PULL和PUSH)并在此处使用On()方法
>我可以……还有另一个最好的做法来解决这个问题吗？
去掉,
$oPullSocket->on('message','onUserLogin'));
$oPullSocket->on('message','onUserlogout'));
加,'onUserActionBroadcast'));
.
在UserInformationPusher中,
删除onUserLogin()和onUserlogout().
加,
public function onUserActionBroadcast($aUserData)
{
$entryData = json_decode($aUserData,true);
// If the lookup topic object isn't set there is no one to publish to
if (!array_key_exists($entryData['topic'],$this->subscribedTopics)) {
return;
}
$topic = $this->subscribedTopics[$entryData['topic']];
unset($entryData['topic']);
// re-send the data to all the clients subscribed to that category
$topic->broadcast($entryData);
}
.
您的UserConstroller(在$aUserData中添加主题),
public function login() {
//... here is the auth code,model call etc...
$aUserData = array();// user data comes from the database with username,etc....
$aUserData['topic'] = 'USER_LOGIN'; // add the topic name
$context = new \ZMQContext();
$oSocket = $context->getSocket(\ZMQ::SOCKET_PUSH,'my pusher'); // use persistent_id
if($oSocket instanceof \ZMQSocket) {
$oSocket->connect("tcp://127.0.0.1:5555"); //
$oSocket->send(json_encode($aUserData));
}
}
public function logout() {
//... here is the logout code,model call etc ....
$aUserData = array();// user data comes from the SESSION with username,etc....
$aUserData['topic'] = 'USER_logoUT'; // add the topic name
$context = new \ZMQContext();
$oSocket = $context->getSocket(\ZMQ::SOCKET_PUSH,'my pusher'); // use persistent_id
if($oSocket instanceof \ZMQSocket) {
$oSocket->connect("tcp://127.0.0.1:5555"); //
$oSocket->send(json_encode($aUserData));
}
}
.
最后在你的视图文件中
<script>
var conn = new ab.Session('ws://yourdomain.dev:9000',// Add the correct domain and port here
function() {
conn.subscribe('USER_LOGIN',function(topic,data) {
console.log(topic);
console.log(data);
});
conn.subscribe('USER_logoUT',data) {
console.log(topic);
console.log(data);
});
},function() {
console.warn('WebSocket connection closed');
},{'skipSubprotocolCheck': true}
);
</script>
.
注意：基本思想是在推送器类中使用单个广播功能.
以上是脚本宝典为你收集整理的php – React / Ratchet / ZMQ中多个订阅方法的最佳实践全部内容，希望文章能够帮你解决php – React / Ratchet / ZMQ中多个订阅方法的最佳实践所遇到的问题。
本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。