PHP多进程通信中,如何实现消息队列的长尾词?
- 内容介绍
- 文章标签
- 相关推荐
本文共计496个文字,预计阅读时间需要2分钟。
向消息队列发送和接收数据的测试示例(PHP):
php
// 发送消息msg_send($queue, 1, Hello, 1);
// 接收消息,如果接收不到会阻塞msg_receive($queue);?>
向消息队列发送数据和获取数据的测试
<?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个子进程来进行处理。
本文共计496个文字,预计阅读时间需要2分钟。
向消息队列发送和接收数据的测试示例(PHP):
php
// 发送消息msg_send($queue, 1, Hello, 1);
// 接收消息,如果接收不到会阻塞msg_receive($queue);?>
向消息队列发送数据和获取数据的测试
<?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个子进程来进行处理。

