草庐IT

DISPATCH_QUEUE_PRIORITY_LOW

全部标签

php - ZF2 : How to attach module specific listener for dispatch. 错误

有没有一种方法可以为ZendFramework2中的事件dispatch.error附加事件监听器,其中该监听器将仅附加到与Module.php相关的EventManager?我通过将dispatch的监听器附加到全局SharedManager并将当前Module.php的命名空间作为第一个参数传递来实现这一点。它工作得很漂亮,但当我对dispatch.error尝试相同时,它不起作用。这是Module.php中的示例:publicfunctioninit(ModuleManager$moduleManager){$sharedManager=$moduleManager->getEv

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 - 我可以向 Laravel 中的 Route::group 添加参数,但在分派(dispatch)到 Laravel 中的路由之前将其删除吗?

我正在使用Laravel4创建由每个客户的accountname命名空间的API。每个客户都有自己的相同数据库。所以Foocorp应该进行如下所示的api调用:http://api.example.com/Foocorp/users/5Barcorpapi调用如下所示http://api.example.com/Barcorp/users/5出于业务/品牌原因,我必须在URL中包含帐户名称,因此我无法从URL路由中删除此参数。这是我用来尝试从路由中提取帐户名称、验证它是否处于事件状态并指向他们的数据库的过滤器。我希望删除accountname参数,这样我就可以编写我所有的Control

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 - 我可以使用自定义预分派(dispatch)、后分派(dispatch)和错误处理程序代码来包装所有 JAX-RS 请求吗?

我使用javax.ws.rs.Path注释将许多类公开为JAX-RS请求“处理程序”。我想在每个请求之前和每个请求之后添加某些操作。此外,我需要创建一个全局应用程序范围的异常处理程序,它将捕获这些处理程序和协议(protocol)抛出的所有内容。是否可以使用标准JAX-RS实现这一点,而无需创建继承自com.sun.jersey.spi.container.servlet.ServletContainer的自定义类(我正在使用Jersey)。 最佳答案 您还可以使用ExceptionMappers。该机制捕获您的服务抛出的异常并将其

Java : ReentrantReadWriteLock with priority

下面是典型的读写模式(读多写少)privateReadWriteLocklock=newReentrantReadWriteLock();privateintvalue;publicvoidwriteValue(intnewValue){lock.writeLock().lock();try{this.value=newValue;}finally{lock.writeLock().unlock();}}publicintreadValue(){lock.readLock().lock();try{returnvalue;}finally{lock.writeLock().unlock

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