PHP多进程通信-消息队列使用

 更新时间:2019-04-17 21:43:14   作者:佚名   我要评论(0)

向消息队列发送五分时时彩数据和获取五分时时彩数据的测试


<&#63;php
$key=ftok(__FILE__,'a');

//获取消息队列
$queue=msg_get_queue($key,0666);
//发送消息
//msg_send($que

向消息队列发送五分时时彩数据和获取五分时时彩数据的测试

<?php
$key=ftok(__FILE__,'a');

//获取消息队列
$queue=msg_get_queue($key,0666);
//发送消息
//msg_send($queue, 1, "Hello, 1");
//接收消息,如果接收不到会阻塞
msg_receive($queue, 1, $message_type, 1024, $message1);
//移除消息
//msg_remove_queue($queue);
//var_dump($message1);

<?php
/**
 * 这段代码模拟了一个日常的任务。
 * 第一个父进程产生了一个子进程。子进程又作为父进程,产生10个子进程。
 * 可以简化为A -> B -> c,d,e... 等进程。
 * 作为A来说,只需要生产任务,然后交给B 来处理。B 则会将任务分配给10个子进程来进行处理。
 * 
 */

//设定脚本永不超时
set_time_limit(0);
$ftok = ftok(__FILE__, 'a');
$msg_queue = msg_get_queue($ftok);
$pidarr = []; 

//产生子进程
$pid = pcntl_fork();
if ($pid) {
 //父进程模拟生成一个特大的数组。
 $arr = range(1,100000);
 //将任务放进队里,让多个子进程并行处理
 foreach ($arr as $val) {
  $status = msg_send($msg_queue,1, $val);
  usleep(1000);
 } 
 $pidarr[] = $pid;
 msg_remove_queue($msg_queue);
} else {
 //子进程收到任务后,fork10个子进程来处理任务。
 for ($i =0; $i<10; $i++) {
  $childpid = pcntl_fork();
  if ($childpid) {
   $pidarr[] = $childpid; //收集子进程processid
  } else {
   while (true) {
    msg_receive($msg_queue, 0, $msg_type, 1024, $message);
    if (!$message) exit(0);
    echo $message.PHP_EOL;
    usleep(1000);
   } 
  } 
 } 
}

//防止主进程先于子进程退出,形成僵尸进程
while (count($pidarr) > 0) {
 foreach ($pidarr as $key => $pid) {
  $status = pcntl_waitpid($pid, $status);
  if ($status == -1 || $status > 0) {
   unset($pidarr[$key]);
  } 
 } 
 sleep(1);
}

以上所述是小编给大家介绍的PHP通信-消息队列使用详解整合,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对脚本之家网站的支持!

您可能感兴趣的文章:

  • PHP消息队列用法实例分析
  • 解析PHP实现多进程并行执行脚本
  • PHP实现多进程并行操作的详解(可做守护进程)

相关文章

  • 一篇文章搞懂JavaScript正则表达式之方法

    一篇文章搞懂JavaScript正则表达式之方法

    咱们来看看JavaScript中都有哪些操作正则的方法。 RegExp RegExp 是正则表达式的构造函数。 使用构造函数创建正则表达式有多种写法: new RegExp('abc');
    2019-04-17
  • PHP多进程通信-消息队列使用

    PHP多进程通信-消息队列使用

    向消息队列发送五分时时彩数据和获取五分时时彩数据的测试 <&#63;php $key=ftok(__FILE__,'a'); //获取消息队列 $queue=msg_get_queue($key,0666); //发送消息 //msg_send($que
    2019-04-17
  • 密码强度的正则表达式两种方案JS总结篇

    密码强度的正则表达式两种方案JS总结篇

    本文给出了两个密码强度的正则表达式方案,一个简单,一个更复杂和安全。并分别给出了两个方案的解析和测试程序。一般大家可以根据自己的项目的实际需要,自行
    2019-04-17
  • VS+opencv实现鼠标移动图片

    VS+opencv实现鼠标移动图片

    基于控制台应用程序+opencv,实现点击鼠标左键,可以拖动图片以显示感兴趣区域 #include <opencv2/highgui/highgui.hpp> //#include <iostream> //using
    2019-04-17
  • vue使用el-upload上传文件及Feign服务间传递文件的方法

    vue使用el-upload上传文件及Feign服务间传递文件的方法

    一、前端代码 <el-upload class="step_content" drag action="string" ref="upload" :multiple="false" :http-req
    2019-04-17
  • 详解Spring的核心机制依赖注入

    详解Spring的核心机制依赖注入

    详解Spring的核心机制依赖注入 对于一般的Java项目,他们都或多或少有一种依赖型的关系,也就是由一些互相协作的对象构成的。Spring把这种互相协作的关系称为
    2019-04-17
  • JS正则表达式获取指定字符之后指定字符之前的字符串(推荐)

    JS正则表达式获取指定字符之后指定字符之前的字符串(推荐)

    一个常见的场景,获取:标签背景图片链接: 如字符串:var bgImg = "url (\"https://img30.360buyimg.com/sku/jfs/t26203/262/100869187/204098/1d1479e9/5b8
    2019-04-17
  • JSP状态管理的简单介绍

    JSP状态管理的简单介绍

    JSP状态管理的简单介绍 一 http协议的无状态性 无状态性是指:当浏览器发送请求给服务器时,服务器响应客户端请求。 但是当同一个浏览器再次发送请求给
    2019-04-17
  • Spring获取ApplicationContext对象工具类的实现方法

    Spring获取ApplicationContext对象工具类的实现方法

    Spring获取ApplicationContext对象工具类的实现方法 (1)实现的工具类: package com.util; import org.springframework.context.ApplicationConte
    2019-04-17
  • Vue渲染过程浅析

    Vue渲染过程浅析

    Vue 推荐在绝大多数情况下使用 template 来创建你的 HTML。但是模板毕竟是模板,不是真实的dom节点。从模板到真实dom节点还需要经过一些步骤 把模板编译为
    2019-04-17

最新评论