1-3 beanstalkd参数

2024-03-18 03:58
文章标签 参数 beanstalkd

本文主要是介绍1-3 beanstalkd参数,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

<?php 
$pheanstalk=require 'beanstalkd.php';
print_r($pheanstalk->status);


print_r($pheanstalk->listTubes());  #查询目前存在的管道


print_r($pheanstalk->statsTube('newUsers')); #查询newUsers管道详情

php -f demo.php

Array(
  [0]=>default   #默认管道
[1]=>newUsers  #自定义管道
)


[name]=>newUsers                     #当前管道名
[current-jobs-urgent]=>0             #当前管道里存在优先级的任务数
[current-jobs-ready]=>2              #当前管道里等待的任务数字
[current-jobs-reserved]=>0           #。。。保留任务数
[current-jobs-delayed]=>0            #。。。等待状态的任务数
[current-jobs-buried]=>0             #。。。保留状态的任务数
[total-jobs]=>2                      #总任务统计
[current-using]=>0                   #当前有多少生产者在使用该管道 usetube命令统计
[current-watching]=>0                #当前有多少消费者在使用该管道 watch 命令统计
[current-waiting]=>0                 #当前有多少消费者在等待任务到来 reserved指令统计
[current-delete]=>0
[current-pause-tube]=>0
[pause]=>0
[pause-time-left]=>0






<?php 
$pheanstalk=require 'beanstalkd.php';
$pheanstalk->useTube('newUsers')->put('test');
print_r($pheanstalk->statsTube(newUsers));


#php -f demo.php

<?php 
$pheanstalk=require 'beanstalkd.php';


$job=$pheanstalk->watch('newUsers')->resers();
$stats=$pheanstalk->statsJob($job);


print_r($stats);


#php -f demo.php

Array
([id]=>51                      当前任务的job  ID[tube]=>newUsers              当前任务所在的管道名字[state]=>reserved             当前任务的状态是reserved  [pri]=>1024                   当前任务的优先级 越小越优先[age]=>11376                  任务从创建到现在活了多久[delay]=>0                    当前任务设置延时的时间[ttr]=>60                     ttr 时间 [time-left]=>59               当前任务在reserved状态已经维持了多久 ttr只有60秒,超过60秒任务就会被放回管道[file]=>4                     bin-log 存储在日志中了  [reserves]=>12                当前reserves状态的次数  一直ttr超时就会被消费多次,这个任务就好被reserved n 次[timeouts]=>0                 reversed超时的次数[releases]=>0                 release方法重设任务的状态[buries]=>0                   被预留的次数   [kicks]=>0                    任务从预留状态准备状态
)



<?php
$pheanstalk=require 'beanstalkd.php';

$job=$pheanstalk->peek(51);

$stats=$pheanstalk->statsJob($job);

print_r($stats);
?>


#php -f demo.php

Array
([id]=>51                      当前任务的job  ID[tube]=>newUsers              当前任务所在的管道名字[state]=>reserved             当前任务的状态是reserved  [pri]=>1024                   当前任务的优先级 越小越优先[age]=>11376                  任务从创建到现在活了多久[delay]=>0                    当前任务设置延时的时间[ttr]=>60                     ttr 时间 [time-left]=>59               当前任务在reserved状态已经维持了多久 ttr只有60秒,超过60秒任务就会被放回管道[file]=>4                     bin-log 存储在日志中了  [reserves]=>12                当前reserves状态的次数  一直ttr超时就会被消费多次,这个任务就好被reserved n 次[timeouts]=>0                 reversed超时的次数[releases]=>0                 release方法重设任务的状态[buries]=>0                   被预留的次数   [kicks]=>0                    任务从预留状态准备状态
)


工具类 :bean.class.php


<?php
class Bean{const AUTHOR='nixuehan';const VERSION='0.91-dev';private $_beanstalkd=null;public function __construct(array $conf){$this->_initBeanstalkd($conf['host'],$conf['port']);}//连接beanstalkdprivated function _initBeanstalkd($host='127.0.0.1',$port=11300){$this->_beanstalkd=new Pheanstalk\Pheanstalk($host,$port);}privated function _getBeanstalkdInstance(){return $this->_beanstalkd;}privated function _kvOutput($val){if($val instanceof \Pheanstalk\Job){printf("jobId:%s message:%s".PHP_EOL,$val->getId(),$val->getData());}}
}?>



这篇关于1-3 beanstalkd参数的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/821120

相关文章

Andrej Karpathy最新采访:认知核心模型10亿参数就够了,AI会打破教育不公的僵局

夕小瑶科技说 原创  作者 | 海野 AI圈子的红人,AI大神Andrej Karpathy,曾是OpenAI联合创始人之一,特斯拉AI总监。上一次的动态是官宣创办一家名为 Eureka Labs 的人工智能+教育公司 ,宣布将长期致力于AI原生教育。 近日,Andrej Karpathy接受了No Priors(投资博客)的采访,与硅谷知名投资人 Sara Guo 和 Elad G

C++11第三弹:lambda表达式 | 新的类功能 | 模板的可变参数

🌈个人主页: 南桥几晴秋 🌈C++专栏: 南桥谈C++ 🌈C语言专栏: C语言学习系列 🌈Linux学习专栏: 南桥谈Linux 🌈数据结构学习专栏: 数据结构杂谈 🌈数据库学习专栏: 南桥谈MySQL 🌈Qt学习专栏: 南桥谈Qt 🌈菜鸡代码练习: 练习随想记录 🌈git学习: 南桥谈Git 🌈🌈🌈🌈🌈🌈🌈🌈🌈🌈🌈🌈🌈�

如何在页面调用utility bar并传递参数至lwc组件

1.在app的utility item中添加lwc组件: 2.调用utility bar api的方式有两种: 方法一,通过lwc调用: import {LightningElement,api ,wire } from 'lwc';import { publish, MessageContext } from 'lightning/messageService';import Ca

4B参数秒杀GPT-3.5:MiniCPM 3.0惊艳登场!

​ 面壁智能 在 AI 的世界里,总有那么几个时刻让人惊叹不已。面壁智能推出的 MiniCPM 3.0,这个仅有4B参数的"小钢炮",正在以惊人的实力挑战着 GPT-3.5 这个曾经的AI巨人。 MiniCPM 3.0 MiniCPM 3.0 MiniCPM 3.0 目前的主要功能有: 长上下文功能:原生支持 32k 上下文长度,性能完美。我们引入了

AI(文生语音)-TTS 技术线路探索学习:从拼接式参数化方法到Tacotron端到端输出

AI(文生语音)-TTS 技术线路探索学习:从拼接式参数化方法到Tacotron端到端输出 在数字化时代,文本到语音(Text-to-Speech, TTS)技术已成为人机交互的关键桥梁,无论是为视障人士提供辅助阅读,还是为智能助手注入声音的灵魂,TTS 技术都扮演着至关重要的角色。从最初的拼接式方法到参数化技术,再到现今的深度学习解决方案,TTS 技术经历了一段长足的进步。这篇文章将带您穿越时

如何确定 Go 语言中 HTTP 连接池的最佳参数?

确定 Go 语言中 HTTP 连接池的最佳参数可以通过以下几种方式: 一、分析应用场景和需求 并发请求量: 确定应用程序在特定时间段内可能同时发起的 HTTP 请求数量。如果并发请求量很高,需要设置较大的连接池参数以满足需求。例如,对于一个高并发的 Web 服务,可能同时有数百个请求在处理,此时需要较大的连接池大小。可以通过压力测试工具模拟高并发场景,观察系统在不同并发请求下的性能表现,从而

多路转接之select(fd_set介绍,参数详细介绍),实现非阻塞式网络通信

目录 多路转接之select 引入 介绍 fd_set 函数原型 nfds readfds / writefds / exceptfds readfds  总结  fd_set操作接口  timeout timevalue 结构体 传入值 返回值 代码 注意点 -- 调用函数 select的参数填充  获取新连接 注意点 -- 通信时的调用函数 添加新fd到

struts2中的json返回指定的多个参数

要返回指定的多个参数,就必须在struts.xml中的配置如下: <action name="goodsType_*" class="goodsTypeAction" method="{1}"> <!-- 查询商品类别信息==分页 --> <result type="json" name="goodsType_findPgae"> <!--在这一行进行指定,其中lis是一个List集合,但

mybatis if test 之 0当做参数传入出问题

首先前端传入了参数 if(StringUtils.isNotBlank(status)){requestParam.setProperty("status", Integer.parseInt(status));}List<SuperPojo> applicationList = groupDao.getApplicationListByReviewStatusAndMember(req

Linux的系统性能监测参数获取方法介绍

目前的工程需要简单的监测一下Linux系统的:CPU负载、内存消耗情况、几个指定目录的磁盘空间、磁盘I/O、swap的情况还有就是网络流量。   Linux下的性能检测工具其实都有很多。   mrtg(http://people.ee.ethz.ch/~oetiker/webtools/mrtg/)就是一个很不错的选择。不过用mrtg就要装sysstat、apache、snmp、pe