strukt/queue

Memcached 队列

维护者

详细信息

github.com/struktapp/strukt-queue

源代码

问题

安装次数: 1

依赖: 0

建议者: 0

安全: 0

星标: 0

关注者: 1

分支: 0

公开问题: 0

dev-master 2024-01-25 02:20 UTC

Requires

MIT ff2a37156dc00780636061cbf7b9a700c6135d38

  • pitsolu <pitsolu.woop@gmail.com>

This package is not auto-updated.

Last update: 2024-09-20 20:16:31 UTC

README

简单实现消息队列，使用 Memcached https://memcached.org/ 作为后端

需要安装 PHP Memcached 扩展才能正常运行

@author Maurizio Giunti https://www.mauriziogiunti.it / https://codeguru.it
@license MIT

用法

等待

//wait.php
$data = ["username"=>"pitsolu", "password"=>"p@55w0rd"];
wait("queue_test", $data, function($reply){

	print_r($reply);
});

回复

//reply.php
reply("queue_test", function($data){

	$data["processed"] = true;

	return $data;
});

其他用法

弹出

$data = array(
	"username"=>"pitsolu", 
	"password"=>"p@55w0rd"
);

$uid = push("queue_test", $data);

推送

list($oid, $udata) = pop("queue_test");

print_r(array(

	"uid"=>$uid,
	"oid"=>$oid,
	"data"=>$data,
	"udata"=>$udata
));