PHP中如何实现多进程间的消息队列通信？
- 内容介绍
- 文章标签
- 相关推荐
本文共计490个文字，预计阅读时间需要2分钟。
向消息队列发送和接收数据的测试 + PHPphp$key=ftok(__FILE__, 'a');$queue=msg_get_queue($key, 0666);
// 发送消息msg_send($queue, 1, Hello, 1);
// 接收消息，如果接收不到会阻塞msg_receive($queue, $msg_type, $msg_body, $msg_size);
向消息队列发送数据和获取数据的测试
<?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个子进程来进行处理。
本文共计490个文字，预计阅读时间需要2分钟。
向消息队列发送和接收数据的测试 + PHPphp$key=ftok(__FILE__, 'a');$queue=msg_get_queue($key, 0666);
// 发送消息msg_send($queue, 1, Hello, 1);
// 接收消息，如果接收不到会阻塞msg_receive($queue, $msg_type, $msg_body, $msg_size);
向消息队列发送数据和获取数据的测试
<?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个子进程来进行处理。