时时商务社区

标题: 用PHP写的基于Memcache的Queue实现代码 [打印本页]

作者: 阿情 时间: 2018-2-14 08:31

php类代码:
[U]复制代码[/U] 代码如下:
0) {
self::mqFrontChange($num);
}
return self:

m_data;
}
private static function mqRealChange() {
memcache_add(self:

client, self:

UEUE_REAL_KEY, 0);
self:

m_real = memcache_increment(self:

client, self:

UEUE_REAL_KEY, 1);
}
private static function mqFrontChange($num) {
memcache_add(self:

client, self:

UEUE_FRONT_KEY, 0);
self:

m_front = memcache_increment(self:

client, self:

UEUE_FRONT_KEY, $num);
}
public static function mflush($memcache_obj) {
memcache_flush($memcache_obj);
}
public static function Debug() {
echo 'real:'.self:

m_real."
/r/n";
echo 'front:'.self:

m_front."
/r/n";
echo 'wait for process data:'.intval(self:

m_real - self::$m_front);
echo "
/r/n";
echo '';
print_r(self::$m_data);
echo '';
}
}
define('FLUSH_MQ',0);//CLEAN ALL DATA
define('IS_ADD',0);//SET DATA
$mobj = MQ::setupMq('127.0.0.1','11211');
if (FLUSH_MQ) {
MQ::mflush($mobj);
} else {
if (IS_ADD) {
MQ::add('user_sync', '1test');
MQ::add('user_sync', '2test');
MQ::add('user_sync', '3test');
MQ::add('user_sync', '4test');
MQ::add('user_sync', '5test');
MQ::add('user_sync', '6test');
} else {
MQ::get('user_sync', 10);
}
}
MQ:

ebug();
?>

使用方法
[U]复制代码[/U] 代码如下:
MQ::setupMq('127.0.0.1','11211');//连接
MQ::add($key, $value);//添加数据到队列
MQ::add($key, $value);//添加数据到队列
MQ::add($key, $value);//添加数据到队列
MQ::add($key, $value);//添加数据到队列
MQ::add($key, $value);//添加数据到队列
MQ::add($key, $value);//添加数据到队列
MQ:get($key, 10);//取出一定数量的数据

您可能感兴趣的文章:

php的memcache类分享(memcache队列)

PHP中的Memcache详解

PHP+memcache实现消息队列案例分享

欢迎光临时时商务社区 (http://bbs.4435.cn/)