博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
1-4 beanstalkd生产类
阅读量:4185 次
发布时间:2019-05-26

本文共 983 字,大约阅读时间需要 3 分钟。

putInTube('newUsers',666666);print_r($io);?>

#  php -f  demo.php

优先级设置:

putInTube('newUsers','test',1000);print_r($io);?>
#  php -f  demo.php

# ./bean --action=listTubes

优先级对别:

useTube('newUsers');$io->put('member_1024');$io->put('member_4',4);$io->put('member_3',3);$io->put('member_1000',1000);?>

查看优先级设置结果

watch('newUsers')->reserve();print_r($job);$pheanstalk->delete($job);?>

延时设置

useTube('newUsers');$tube->put('member_3',50,20);?>
ttr设置

useTube('newUsers');$tube->put('member_3',0,50,30); #设置ttr$job=$pheanstalk->watch('newUsers')->reserve();print_r($pheanstalk->statsJob($job));sleep(100);$job=$pheanstalk->delete($job);?>
超时重发

useTube('newUsers');$tube->put('member_3',0,50,30); #第三个参数 设置延时50秒执行任务 #第四个参数任务超时重发$job=$pheanstalk->watch('newUsers')->reserve();print_r($pheanstalk->statsJob($job)); #从管道中读取任务sleep(9); #暂停9毫秒 $pheanstalk->touch($job); #续命print "touch"; #提示print_r($pheanstalk->statsJob($job)); $pheanstalk->delete($job);?>
你可能感兴趣的文章
kafka常用命令
查看>>
kafka顺序消息
查看>>
kafka 消息服务
查看>>
从零开始玩转JMX(一)——简介和Standard MBean
查看>>
究竟啥才是互联网架构中的高并发!
查看>>
数据库水平扩展与垂直扩展
查看>>
Jsp中include动作指令简介
查看>>
交互两个数(不引入第三个变量)
查看>>
C/C++面试题分享
查看>>
链表类型题目需要用到的头文件list.h
查看>>
tree类型题目需要用到的头文件tree.h
查看>>
有一个1亿结点的树,已知两个结点, 求它们的最低公共祖先!
查看>>
BST(binary search tree)类型题目需要用到的头文件binary_tree.h
查看>>
将BST转换为有序的双向链表!
查看>>
中体骏彩C++面试题
查看>>
永成科技C++笔试题
查看>>
webkit入门准备
查看>>
在Ubuntu 12.04 64bit上配置,安装和运行go程序
查看>>
ATS程序功能和使用方法详解
查看>>
常用Linux命令总结
查看>>