草庐IT

msg_queue

全部标签

php - Laravel Queue - 记住属性(property)状态?

如果作业失败,它将被推回队列。有没有办法在再次处理作业时记住作业类中属性的值?例如:classMailJobextendsJob{public$tries=3;public$status;publicfunction__construct(){$this->status=false;//settofalse}/***Executethejob.*/publicfunctionhandle(){$this->status=true;//Assumejobhasfailed,itwentbacktotheQueue.//statusshouldbetruewhenthisjobstartp

php - imap_num_msg 返回的计数少于使用 pop 协议(protocol)收件箱中的实际电子邮件数

我正在尝试使用gmail的电子邮件作为退回地址来处理phplist中退回的电子邮件。当我尝试处理退回邮件时,我陷入了此Post-Thereare250bouncestoprocess中提到的类似场景中。.Phplist只能从我的Gmail帐户中提取250封电子邮件。在进一步调查phplists的代码时,我发现这行代码似乎是罪魁祸首。$num=imap_num_msg($link);//只得到250的计数跳过更多细节。我写了几行代码来使用imap和pop获取邮件计数。pop版本返回的计数错误,而imap版本返回的计数正确$username='bounceemail@mydomain.co

php - 在 Supervisord 和 HHVM 中使用 Laravel Queue 会导致 tmp 文件夹中有很多 .map 文件

我正在使用Larvel4.1。根据此站点(http://www.tienle.com/2014/04-25/setting-nginx-hhvm-php-percona-laravel-projects.html)创建新服务器后,一切都运行得更快。我有40%的速度表现!我仍然遇到的唯一问题是perf-.map文件。由于Laravel的队列每2秒在supervisord中运行一次,因此会创建一个大小为2MB的perf-.map文件。你可以想象一周后会发生什么。有时网站流量很大,文件增长得更快。有一次系统因硬盘驱动器已满而崩溃。我希望以前有人遇到过这个问题。我用谷歌搜索了很多但找不到答案。

php - Queue:push() 在 Laravel 5 中被同步处理

我正在运行Laravel5,我正在尝试让命令排队。我通过运行开始:Queue::push(newMyCommand());为了创建命令,我做了:phpartisanmake:command--queuedMyCommandMyCommand包含一个sleep(20)和file_put_contents('test.txt','Iwork!')我正在运行的命令行:beanstalkd-l127.0.0.1-p11301&phpartisanqueue:listen&并且config/queue.php设置为:'default'=>env('QUEUE_DRIVER','beanstalk

php - 带有 Job Queue 系统的 PHP/Laravel 中的逻辑代码

我正在使用Laravel3制作一个网络抓取工具,并且有一个队列系统resque。问题:抓取逻辑代码应该放在哪里?在worker/job类中?在由工作/作业类静态调用的库类中?在Controller函数中并让worker/job类触发Controller函数?我目前在Controller功能中有它,所以我可以通过转到它的url来测试它。这也允许使用Cron的重复作业,因为resque不允许重复作业。我仍然需要保留这种测试抓取功能的简单方法。尝试:这就是我的想法,您将如何为此目的组织您的代码?worker类(Class)classScraperWorker{publicfunctionpe

java - 为什么 ArrayList 没有实现 Queue?

也许这很愚蠢,但我必须知道答案。我在看它的源代码时抓耳挠腮,没有看到作者在LinkedList中实现Queue的任何原因,但决定不对ArrayList做同样的事情,相反,他们创建了单独的类ArrayDeque。 最佳答案 接口(interface)Queue要求add将项目添加到Queue的末尾,remove从中获取元素队列的开始。(伪代码)Queueq=...q.add("A")q.add("B")q.add("C")//qisnow[A,B,C]Stringa=q.remove()//aisAandqis[B,C]现在;对于Ar

java - ActiveMQ : dead letter queue keeps my messages order

我使用ActiveMQ作为代理来传递消息。这些消息旨在写入数据库中。有时,数据库无法访问或已关闭。在这种情况下,我想回滚我的消息以便稍后重试此消息,并且我想继续阅读其他消息。这段代码工作正常,除了一点:回滚消息阻止我阅读其他代码:privateConnectiongetConnection()throwsJMSException{RedeliveryPolicyredeliveryPolicy=newRedeliveryPolicy();redeliveryPolicy.setMaximumRedeliveries(3);//willretry3timestodequeuerollba

java - Spring 3.1 LDAP 认证流程 : "Bad Credentials" msg When Credentials Are Good

Spring3.1Tomcat6.*我正在制作一个Spring3.1webapp,使用LDAP进行身份验证。我用我编写的JNDI风格的Java程序(引述如下)测试了LDAP凭据(用户名、密码、ldapURL、搜索模式)。该程序有效,转储了所有用户属性,包括似乎在LDAP服务器上加密的密码。当我尝试在Spring3.1中使用相同的凭据登录时,我收到错误消息“BadCredentials”。我在日志中收到这条消息:DEBUG[org.springframework.security.authentication.ProviderManager:authenticate](ProviderM

HCIA-HarmonyOS设备开发认证V2.0-轻量系统内核基础-消息队列queue

目录一、消息队列基本概念二、消息队列运行机制三、消息队列开发流程四、消息队列使用说明五、消息队列接口六、代码分析(待续...)坚持就有收获一、消息队列基本概念队列又称消息队列,是一种常用于任务间通信的数据结构。队列接收来自任务或中断的不固定长度消息,并根据不同的接口确定传递的消息是否存放在队列空间中。任务能够从队列里面读取消息,当队列中的消息为空时,挂起读取任务;当队列中有新消息时,挂起的读取任务被唤醒并处理新消息。任务也能够往队列里写入消息,当队列已经写满消息时,挂起写入任务;当队列中有空闲消息节点时,挂起的写入任务被唤醒并写入消息。可以通过调整读队列和写队列的超时时间来调整读写接口的阻塞模

【C++】stack、queue模拟实现+仿函数

stack、queue模拟实现+仿函数stack定义stack模拟实现queue定义queue模拟实现priority_queue定义priority_queue模拟实现deque定义底层分析容器适配器定义种类仿函数控制类里面数据的比较逻辑回调函数仿函数两者区别铁汁们,今天给大家分享一篇stack、queue模拟实现+仿函数,来吧,开造⛳️stack定义stack是容器适配器,专门用于进行”先进后出”操作的环境中,只能在容器的一端进行数据的插入和删除操作,元素在特定容器的尾部(即栈顶)被压入和弹出。容器适配器是将特定的类进行封装,将其作为该容器的底层容器,通过调用底层容器提供的一系列成员函数来