search
php讯息队列Jun 13, 2016 am 10:49 AM
gtmessagemsgqueuethis

php消息队列

php-通过共享内存实现消息队列和进程通信的两个类

实现消息队列,可以使用比较专业的工具,例如:Apache ActiveMQ、memcacheq…..,下面是两个基本简单的实现方式:

使用memcache方法来实现

<?php /* * @Copyright (c) 2007,上海友邻信息科技有限公司 * @All	rights reserved. * * 这个消息队列不是线程安全的,我只是尽量的避免了冲突的可能性。如果你要实现线程安全的,一个建议是通过文件进行锁定,然后进行操作。 * * @filename   MemcacheQueue.class.php *//** * Class and Function List: * Function list: * - __construct() * - singleton() * - init() * - __get() * - __set() * - isEmpty() * - isFull() * - enQueue() * - deQueue() * - getTop() * - getAll() * - getPage() * - makeEmpty() * - getAllKeys() * - add() * - increment() * - decrement() * - set() * - get() * - delete() * - getKeyByPos() * Classes list: * - Yl_MemcacheQueue */class Yl_MemcacheQueue {	private static $instance;	private $memcache;	private $name;	private $prefix;	private $maxSize;		private function __construct() {	}		static function singleton() {				if (! (self::$instance instanceof self)) {			self::$instance = new Yl_MemcacheQueue ();				}				return self::$instance;	}		public function init($max_size, $name, $prefix = "__queue__") {		$max_size = 1000;		$name = '_war_';		$prefix = '_queue';				$this->memcache = Yl_Memcache::singleton ();		$this->name = $name;		$this->prefix = $prefix;		$this->maxSize = $max_size;				$this->add ( 'front', 0 );		$this->add ( 'rear', 0 );		$this->add ( 'size', 0 );	}		function isEmpty() {		return $this->get ( 'size' ) == 0;	}		function isFull() {		return $this->get ( 'size' ) >= $this->maxSize;	}		function enQueue($data) {		if ($this->isFull ()) {			throw new Exception ( "Queue is Full" );		}				$size = $this->increment ( 'size' );		$rear = $this->increment ( 'rear' );				$this->set ( ($rear - 1) % $this->maxSize, $data );				return $this;	}		function deQueue() {		if ($this->isEmpty ()) {			throw new Exception ( "Queue is Empty" );		}				$this->decrement ( 'size' );		$front = $this->increment ( 'front' );		$this->delete ( ($front - 1) % $this->maxSize );				return $this;	}		function getTop() {		return $this->get ( $this->get ( 'front' ) % $this->maxSize );	}		function getAll() {		return $this->getPage ();	}		function getPage($offset = 0, $limit = 0) {		$size = $this->get ( 'size' );				if (0 == $size || $size get ( 'front' ) % $this->maxSize;		$rear = $this->get ( 'rear' ) % $this->maxSize;				$keys [] = $this->getKeyByPos ( ($front + $offset) % $this->maxSize );		$num = 1;				for($pos = ($front + $offset + 1) % $this->maxSize; $pos != $rear; $pos = ($pos + 1) % $this->maxSize) {			$keys [] = $this->getKeyByPos ( $pos );			$num ++;						if ($limit > 0 && $limit == $num) {				break;			}		}				return array_values ( $this->memcache->get ( $keys ) );	}		function makeEmpty() {		$keys = $this->getAllKeys ();				foreach ( $keys as $value ) {			$this->delete ( $value );		}				$this->delete ( "rear" );		$this->delete ( "front" );		$this->delete ( 'size' );		$this->delete ( "maxSize" );	}		private function getAllKeys() {		if ($this->isEmpty ()) {			return array ();		}				$keys [] = $this->get ( 'front' );				for($pos = ($this->get ( 'front' ) % $this->maxSize + 1) % $this->maxSize; $pos != $this->get ( 'rear' ) % $this->maxSize; $pos = ($pos + 1) % $this->maxSize) {			$keys [] = $pos;		}				return $keys;	}		private function add($pos, $data) {		$this->memcache->add ( $this->getKeyByPos ( $pos ), $data );				return $this;	}		private function increment($pos) {				return $this->memcache->increment ( $this->getKeyByPos ( $pos ) );	}		private function decrement($pos) {		$this->memcache->decrement ( $this->getKeyByPos ( $pos ) );	}		private function set($pos, $data) {		$this->memcache->save ( $data, $this->getKeyByPos ( $pos ) );				return $this;	}		private function get($pos) {				return $this->memcache->get ( $this->getKeyByPos ( $pos ) );	}		private function delete($pos) {				return $this->memcache->delete ( $this->getKeyByPos ( $pos ) );	}		private function getKeyByPos($pos) {				return $this->prefix . $this->name . $pos;	}}?>
使用共享内存队列实现 点击查看原文地址

?

利用PHP操作Linux消息队列完成进程间通信

当我们开发的系统需要使用多进程方式运行时,进程间通信便成了至关重要的环节。消息队列(message queue)是Linux系统进程间通信的一种方式。
  关于Linux系统进程通信的概念及实现可查看:http://www.ibm.com/developerworks/cn/linux/l-ipc/
  关于Linux系统消息队列的概念及实现可查看:http://www.ibm.com/developerworks/cn/linux/l-ipc/part4/
  PHP的sysvmsg模块是对Linux系统支持的System V IPC中的System V消息队列函数族的封装。我们需要利用sysvmsg模块提供的函数来进进程间通信。先来看一段示例代码_1:

<?php $message_queue_key = ftok(__FILE__, 'a');$message_queue = msg_get_queue($message_queue_key, 0666);var_dump($message_queue);$message_queue_status = msg_stat_queue($message_queue);print_r($message_queue_status);//向消息队列中写msg_send($message_queue, 1, "Hello,World!");$message_queue_status = msg_stat_queue($message_queue);print_r($message_queue_status);//从消息队列中读msg_receive($message_queue, 0, $message_type, 1024, $message, true, MSG_IPC_NOWAIT);print_r($message."\r\n");msg_remove_queue($message_queue);?>
?这段代码的运行结果如下:
resource(4) of type (sysvmsg queue)Array(    [msg_perm.uid] => 1000    [msg_perm.gid] => 1000    [msg_perm.mode] => 438    [msg_stime] => 0    [msg_rtime] => 0    [msg_ctime] => 1279849495    [msg_qnum] => 0    [msg_qbytes] => 16384    [msg_lspid] => 0    [msg_lrpid] => 0)Array(    [msg_perm.uid] => 1000    [msg_perm.gid] => 1000    [msg_perm.mode] => 438    [msg_stime] => 1279849495    [msg_rtime] => 0    [msg_ctime] => 1279849495    [msg_qnum] => 1    [msg_qbytes] => 16384    [msg_lspid] => 2184    [msg_lrpid] => 0)Hello,World!
?可以看到已成功从消息队列中读取“Hello,World!”字符串

下面列举一下示例代码中的主要函数:

ftok ( string $pathname , string $proj ) 	手册上给出的解释是:Convert a pathname and a project identifier to a System V IPC key。这个函数返回的键值唯一对应linux系统中一个消息队列。在获得消息队列的引用之前都需要调用这个函数。msg_get_queue ( int $key [, int $perms ] )	msg_get_queue()会根据传入的键值返回一个消息队列的引用。如果linux系统中没有消息队列与键值对应,msg_get_queue()将会创建一个新的消息队列。函数的第二个参数需要传入一个int值,作为新创建的消息队列的权限值,默认为0666。这个权限值与linux命令chmod中使用的数值是同一个意思,因为在linux系统中一切皆是文件。msg_send ( resource $queue , int $msgtype , mixed $message [, bool $serialize [, bool $blocking [, int &$errorcode ]]] )	顾名思义,该函数用来向消息队列中写数据。msg_stat_queue ( resource $queue ) 	这个函数会返回消息队列的元数据。消息队列元数据中的信息很完整,包括了消息队列中待读取的消息数、最后读写队列的进程ID等。示例代码在第8行调用该函数返回的数组中队列中待读取的消息数msg_qnum值为0。msg_receive ( resource $queue , int $desiredmsgtype , int &$msgtype , int $maxsize , mixed &$message [, bool $unserialize [, int $flags [, int &$errorcode ]]] ) 	msg_receive用于读取消息队列中的数据。msg_remove_queue ( resource $queue )     msg_remove_queue用于销毁一个队列。
?示例代码_1只是展示了PHP操作消息队列函数的应用。下面的代码具体描述了进程间通信的场景
<?php $message_queue_key = ftok ( __FILE__, 'a' );$message_queue = msg_get_queue ( $message_queue_key, 0666 );$pids = array ();for($i = 0; $i < 5; $i ++) {	//创建子进程	$pids [$i] = pcntl_fork ();		if ($pids [$i]) {		echo "No.$i child process was created, the pid is $pids[$i]\r\n";	} elseif ($pids [$i] == 0) {		$pid = posix_getpid ();		echo "process.$pid is writing now\r\n";				msg_send ( $message_queue, 1, "this is process.$pid's data\r\n" );		posix_kill ( $pid, SIGTERM );	}}do {	msg_receive ( $message_queue, 0, $message_type, 1024, $message, true, MSG_IPC_NOWAIT );	echo $message;	//需要判断队列是否为空,如果为空就退出//break;} while ( true )?>
运行结果为:
No.0 child process was created, the pid is 5249No.1 child process was created, the pid is 5250No.2 child process was created, the pid is 5251No.3 child process was created, the pid is 5252No.4 child process was created, the pid is 5253process.5251 is writing nowthis is process.5251's dataprocess.5253 is writing nowprocess.5252 is writing nowprocess.5250 is writing nowthis is process.5253's datathis is process.5252's datathis is process.5250's dataprocess.5249 is writing nowthis is process.5249's data

redis
http://www.neatstudio.com/show-976-1.shtml

?

php自带的三个消息队列相关的函数
http://www.zhangguangda.com/?p=89?

Statement
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn
华为GT3 Pro和GT4的差异是什么?华为GT3 Pro和GT4的差异是什么?Dec 29, 2023 pm 02:27 PM

许多用户在选择智能手表的时候都会选择的华为的品牌,其中华为GT3pro和GT4都是非常热门的选择,不少用户都很好奇华为GT3pro和GT4有什么区别,下面就就给大家介绍一下二者。华为GT3pro和GT4有什么区别一、外观GT4:46mm和41mm,材质是玻璃表镜+不锈钢机身+高分纤维后壳。GT3pro:46.6mm和42.9mm,材质是蓝宝石玻璃表镜+钛金属机身/陶瓷机身+陶瓷后壳二、健康GT4:采用最新的华为Truseen5.5+算法,结果会更加的精准。GT3pro:多了ECG心电图和血管及安

Laravel开发:如何使用Laravel Queue处理异步任务?Laravel开发:如何使用Laravel Queue处理异步任务?Jun 13, 2023 pm 08:32 PM

随着应用程序变得越来越复杂,处理和管理大量数据和流程是一个挑战。为了处理这种情况,Laravel为用户提供了一个非常强大的工具,即Laravel队列(Queue)。它允许开发人员在后台运行诸如发送电子邮件,生成PDF,处理图像剪裁等任务,而不会对用户界面产生任何影响。在这篇文章中,我们将深入研究如何使用Laravel队列。什么是LaravelQueue队列

修复:截图工具在 Windows 11 中不起作用修复:截图工具在 Windows 11 中不起作用Aug 24, 2023 am 09:48 AM

为什么截图工具在Windows11上不起作用了解问题的根本原因有助于找到正确的解决方案。以下是截图工具可能无法正常工作的主要原因:对焦助手已打开:这可以防止截图工具打开。应用程序损坏:如果截图工具在启动时崩溃,则可能已损坏。过时的图形驱动程序:不兼容的驱动程序可能会干扰截图工具。来自其他应用程序的干扰:其他正在运行的应用程序可能与截图工具冲突。证书已过期:升级过程中的错误可能会导致此issu简单的解决方案这些适合大多数用户,不需要任何特殊的技术知识。1.更新窗口和Microsoft应用商店应用程

如何修复无法连接到iPhone上的App Store错误如何修复无法连接到iPhone上的App Store错误Jul 29, 2023 am 08:22 AM

第1部分:初始故障排除步骤检查苹果的系统状态:在深入研究复杂的解决方案之前,让我们从基础知识开始。问题可能不在于您的设备;苹果的服务器可能会关闭。访问Apple的系统状态页面,查看AppStore是否正常工作。如果有问题,您所能做的就是等待Apple修复它。检查您的互联网连接:确保您拥有稳定的互联网连接,因为“无法连接到AppStore”问题有时可归因于连接不良。尝试在Wi-Fi和移动数据之间切换或重置网络设置(“常规”>“重置”>“重置网络设置”>设置)。更新您的iOS版本:

vue3中怎么使用element-plus调用messagevue3中怎么使用element-plus调用messageMay 17, 2023 pm 03:52 PM

vue3使用element-plus调用message环境:vue3+typescript+element-plus1.全局引入element之后element已经在app.config.globalProperties添加了全局方法$message所以在optionsAPI中可以直接使用mounted(){(thisasany).$message.success("this.$message");}2.在CompositionAPI中setup方法传入了两个变量props和

php提交表单通过后,弹出的对话框怎样在当前页弹出,该如何解决php提交表单通过后,弹出的对话框怎样在当前页弹出,该如何解决Jun 13, 2016 am 10:23 AM

php提交表单通过后,弹出的对话框怎样在当前页弹出php提交表单通过后,弹出的对话框怎样在当前页弹出而不是在空白页弹出?想实现这样的效果:而不是空白页弹出:------解决方案--------------------如果你的验证用PHP在后端,那么就用Ajax;仅供参考:HTML code<form name="myform"

多线程环境下Java Queue队列的安全性问题及解决方案多线程环境下Java Queue队列的安全性问题及解决方案Jan 13, 2024 pm 03:04 PM

JavaQueue队列在多线程环境下的安全性问题与解决方案引言:在多线程编程中,程序中的共享资源可能面临竞争条件,这可能导致数据的不一致性或者错误。在Java中,Queue队列是一种常用的数据结构,在多个线程同时操作队列的情况下,就存在安全性问题。本文将讨论JavaQueue队列在多线程环境下的安全性问题,并介绍几种解决方案,重点以代码示例的方式解释。一

Queue在Java中的应用Queue在Java中的应用Feb 18, 2024 pm 03:52 PM

Java中Queue的用法在Java中,Queue(队列)是一种常用的数据结构,它遵循先进先出(FIFO)原则。Queue可用于实现消息队列、任务调度等场景,能够很好地管理数据的排列和处理顺序。本文将介绍Queue的用法,并提供具体的代码示例。Queue的定义和常用方法在Java中,Queue是JavaCollectionsFramework中的一个接口

See all articles

Hot AI Tools

Undresser.AI Undress

Undresser.AI Undress

AI-powered app for creating realistic nude photos

AI Clothes Remover

AI Clothes Remover

Online AI tool for removing clothes from photos.

Undress AI Tool

Undress AI Tool

Undress images for free

Clothoff.io

Clothoff.io

AI clothes remover

AI Hentai Generator

AI Hentai Generator

Generate AI Hentai for free.

Hot Article

R.E.P.O. Energy Crystals Explained and What They Do (Yellow Crystal)
2 weeks agoBy尊渡假赌尊渡假赌尊渡假赌
Repo: How To Revive Teammates
4 weeks agoBy尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island Adventure: How To Get Giant Seeds
3 weeks agoBy尊渡假赌尊渡假赌尊渡假赌

Hot Tools

SublimeText3 Chinese version

SublimeText3 Chinese version

Chinese version, very easy to use

SublimeText3 Mac version

SublimeText3 Mac version

God-level code editing software (SublimeText3)

MantisBT

MantisBT

Mantis is an easy-to-deploy web-based defect tracking tool designed to aid in product defect tracking. It requires PHP, MySQL and a web server. Check out our demo and hosting services.

Dreamweaver CS6

Dreamweaver CS6

Visual web development tools

DVWA

DVWA

Damn Vulnerable Web App (DVWA) is a PHP/MySQL web application that is very vulnerable. Its main goals are to be an aid for security professionals to test their skills and tools in a legal environment, to help web developers better understand the process of securing web applications, and to help teachers/students teach/learn in a classroom environment Web application security. The goal of DVWA is to practice some of the most common web vulnerabilities through a simple and straightforward interface, with varying degrees of difficulty. Please note that this software