redis 中发布和订阅可以实现消息的实时传输，这里我只是用它的事件驱动，当客户端发送了消息，服务器端立马可以接收指令处理相应的业务逻辑。
客户端
client.php
<?php //发布 $redis = new Redis(); $redis->connect(‘11.10.1.121‘, 6379); $message = ‘send msg‘;
#将手机号存放到队列中 $redis->lPush("phone", "15013028236"); $ret = $redis->publish(‘subscribe‘, $message);
服务器端
server.php
<?php //订阅端 常驻进程 ini_set(‘default_socket_timeout‘, -1); //不超时 $redis = new Redis(); $redis->connect(‘11.10.1.121‘, 6379); $result = $redis->subscribe(array(‘subscribe‘), ‘callback‘); function callback($instance, $channelName, $message) { # 回调函数内只能使用 SUBSCRIBE、PSUBSCRIBE、UNSUBSCRIBE、PUNSUBSCRIBE 4 条命令 # 事件驱动 接到信息后执行业务逻辑 如 发送短信 、邮件等 //请求接口 接口完成发送短信、邮件业务逻辑 $curl = curl_init(); curl_setopt($curl, CURLOPT_URL, ‘http://www.layui.test/home/article/attrJob‘); curl_setopt($curl, CURLOPT_HEADER, 1); curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1); $data = curl_exec($curl); echo curl_getinfo($curl, CURLINFO_HTTP_CODE); curl_close($curl); }
发送短信示例代码
public function attrJob(){ //示例代码 $redis = new Redis(); $redis->connect(‘11.10.1.121‘, 6379); $phone = $redis->rPop("phone"); if (!$phone || ctype_digit($phone)) { echo json_encode([‘error_code‘ => 1, ‘msg‘ => "s手机号不能为空！"]); return; } #使用短信接口 echo json_encode([‘error_code‘ => 0, ‘msg‘ => "短信已发送！"]); }
