zoukankan      html  css  js  c++  java
  • PHP多进程开发与Redis结合实践

    原文:https://blog.51cto.com/laok8/2107892?source=drh

    业务逻辑介绍:

    1. 用户在 APP 上发帖子,然后存储到 Redis 的 List 列表中
    2. 利用 Linux 的 crontab 定时任务功能,按秒请求执行PHP脚本文件(processNewsRedisList.php)
    3. 调用 redis_process 处理API,进行存储到 Mysql 中

    1.发帖子API

    public function post_json() { $image = $_FILES['image']; $data = I(); $images = $this->post_upload($image); $data['image'] = $images ? $images : ''; if( count($data) ){ $redis = new Redis(); $data['creation_time'] = time(); //把发过来的帖子存储redis $result = $redis->lpush('news_list', json_encode($data)); // $redis->lpush('news_list', json_encode($data)); // while (TRUE){ // if ($redis->lsize('news_list') > 0){ // $info = $redis->rpop('news_list'); // $info = json_decode($info, true); // $result = $this->_model->news_publish( $info ); // }else { // sleep(1);break; // } // } // $redis->close(); $data['creation_time'] = time(); // $result = $this->_model->news_publish( $data ); if( $result < 1 ){//redis方式 // if( !$result ){//model方式 $this->_data['data'] = ''; $this->_data['error'] = true; $this->_data['message'] = L('_DATABASE_ERROR_'); }else{//success $this->_data['data'] = $result; $this->_data['error'] = false; } } else{ $this->_data['data'] = ''; $this->_data['error'] = true; $this->_data['message'] = L('_Invalid_Parameters_'); } $this->response($this->_data); }

     
     

    2.processNewsRedisList.php

    <?php
    /**
    *检查队列中帖子,并把帖子插入数据库表中
    */
    
    function worker() { //再次克隆出子进程 $pid = pcntl_fork(); if ( $pid == -1 ) { exit('fork error'); } if ( $pid == 0 ) { $redis = new Redis(); $redis->connect('127.0.0.1', 7200); //业务逻辑代码 while(true) {//sleep(5); if( $redis->lsize('news_list') > 0 ){ $info = $redis->rpop('news_list'); $info = json_decode($info, TRUE); //使用curl调用API接口 $uri = "http://*.*.*.*:*/api.zmartec/News/redis_process"; $data = $info; $ch = curl_init(); curl_setopt($ch, CURLOPT_URL, $uri); curl_setopt($ch, CURLOPT_POST, 1); curl_setopt($ch, CURLOPT_HEADER, 0); curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); curl_setopt($ch, CURLOPT_POSTFIELDS, $data); $result = curl_exec($ch); curl_close($ch); } else { sleep(1);//队列中没有任务的时候,睡眠1s,让出cpu给其它进程 } } $redis->close(); } } /** *子进程,负责设置子进程为领导小组 * *并调用处理函数,处理任务 */ function children() { $sid = posix_setsid(); echo $sid; for( $i = 0; $i < 2; $i++ ) { worker(); } } //克隆子进程,返回子进程的进程id $pid = pcntl_fork(); if ( $pid == -1 ) { exit('fork error'); } if ( $pid == 0 ) { children(); }else{ exit('parent exit'); } ?>

     
     

    3.存储帖子到 Mysql

    thinkphp 3.2框架:
    public function redis_process() { $data = $_POST; if ($this->_model->news_publish($data)) { return true; } esle { return false; } } public function news_publish( $data ) { try{ return M('news')->add($data); }catch(Exception $ex){ return FALSE; } }
  • 相关阅读:
    sql2slack alash3al 开源的又个轻量级工具
    pgspider fetchq 扩展docker镜像
    godns 集成coredns 的demo
    godns 简单dnsmasq 的dns 替换方案
    aviary.sh 一个基于bash的分布式配置管理工具
    使用coredns 的template plugin实现一个xip 服务
    nginx 代理 coredns dns 服务
    基于nginx proxy dns server
    几个不错的geodns server
    spring boot rest api 最好添加servlet.context-path
  • 原文地址:https://www.cnblogs.com/lxwphp/p/15453267.html
Copyright © 2011-2022 走看看