PHP的消息通信机制测试实例
网络编程 2021-07-05 08:23www.168986.cn编程入门
这篇文章主要介绍了PHP的消息通信机制,结合实例形式分析了php消息通信的信息发送与获取相关操作技巧,需要的朋友可以参考下
本文实例讲述了PHP的消息通信机制。分享给大家供大家参考,具体如下:
<?php error_reporting(E_ALL&~E_WARNING&~E_NOTICE); /** * Example for sending and receiving Messages via the System V Message Queue * * To try this script run it synchron/asynchron twice times. One time with ?type=send and one time with ?type=receive * * @author Thomas Eimers - Mehrkanal GmbH * * This document is distributed in the hope that it will be useful, but without any warranty; * without even the implied warranty of merchantability or fitness for a particular purpose. */ ob_implicit_flush(1); header('Content-Type: text/plain; charset=ISO-8859-1'); echo "Start...\n"; // Create System V Message Queue. Integer value is the number of the Queue //$queue = msg_get_queue(100379); $mesg_key = ftok(__FILE__, 'm'); $mesg_id = msg_get_queue($mesg_key, 0666); $queue = $mesg_id; // Sendoptions $serialize_needed=false; // Must the transfer data be serialized ? $block_send=false; // Block if Message could not be send (Queue full...) (true/false) $msgtype_send=1; // Any Integer above 0. It signeds every Message. So you could handle multible message // type in one Queue. // Receiveoptions $msgtype_receive=1; // Whiche type of Message we want to receive ? (Here, the type is the same as the type we send, // but if you set this to 0 you receive the next Message in the Queue with any type. $maxsize=100; // How long is the maximal data you like to receive. $option_receive=MSG_IPC_NOWAIT; // If there are no messages of the wanted type in the Queue continue without wating. // If is set to NULL wait for a Message. // Send or receive 20 Messages for ($i=0;$i<20;$i++) { sleep(1); ob_flush(); flush(); $message='Hello, This is Flandy,now is '.date("H:i:s",time()); // Transfering Data // This one sends if (isset($_GET['type'])&&$_GET['type']=='send') { if(msg_send($queue,$msgtype_send, $message,$serialize_needed, $block_send,$err)===true) { echo "The ".$i." Message has been sent, the messge is ".$message."\n"; } else { var_dump($err); } // This one received } else { $queue_status=msg_stat_queue($queue); echo 'Get Messages in the queue: '.$queue_status['msg_qnum']."\n"; print_r($queue_status); echo "\n"; if ($queue_status['msg_qnum']>0) { if (msg_receive($queue,$msgtype_receive ,$msgtype_erhalten,$maxsize,$daten,$serialize_needed, $option_receive, $err)===true) { echo "Received data:".$daten."\n"; } else { var_dump($err); } } } } ?>
更多关于PHP相关内容感兴趣的读者可查看本站专题:《》、《》、《》、《》、《》、《》、《》及《》
希望本文所述对大家PHP程序设计有所帮助。
上一篇:php事件驱动化设计详解
下一篇:PHP使用GD库输出汉字的方法【测试可用】
编程语言
- 机械手焊接机器人编程 机械手焊接设备编程
- vb数据库编程实例,vb做数据库
- tiobe世界编程语言排行榜,全球编程语言排行
- 成都java编程培训 成都it编程培训中心
- 编程基础培训,编程基础知识培训
- flash游戏编程基础教程,flash游戏开发教程
- 不会英语能学编程吗 不会英语可以学程序员吗
- 爱心代码编程C语言 爱心代码编程c语言公式
- c语言编程学习入门 c语言编程快速入门
- 西门子plc编程培训 西门子plc编程培训班
- 哪里可以学编程 台州哪里可以学编程
- 少儿编程哪个好 少儿编程哪个品牌好
- 编程是什么意思,图形编程是什么意思
- c语言编程软件下载,c语言编程软件在哪下载
- java编程软件下载,java编程下载手机版
- ug编程培训学校,ug编程培训教程