redis 订阅与发布

2018-06-28 02:00:04 php分享记录

<?php
$redis = new Redis();
$redis->pconnect("127.0.0.1",6379);
$redis->auth("243356");
$redis->setOption(Redis::OPT_READ_TIMEOUT,-1);
$redis->subscribe(array('news'),'callback');
function callback($instance,$channelName,$message){
    echo $channelName,"==>",json_decode($message)->msg,PHP_EOL;
}

发布

<?php
$redis = new Redis();
$redis->connect("127.0.0.1",6379);
$redis->auth("243356");
$redis->publish('news',json_encode(array('news','msg'=>"Hello world")));

张书贤

ajax跨域 API设计 coding exception freeswitch freeswitch，多网卡 frp，局域网穿透，端口转发 Git自动部署 go,浏览器调用，模拟按键操作 jwt jwt方法 laravel monit,centos7,进程监控 mysql时间函数 nginx,小程序 nginx，跨域 python小计 RESTful 设计规范 tar恢复备份，新硬盘个人常用函数主从同步二步验证伪SQL,binlog,row 元组内存优化列表多网卡字符串正则笛卡尔积订阅，发布队列任务，laravel

redis 订阅与发布

张书贤

标签