Celery Beat：一次限制为单个任务实例
我有芹菜和芹菜（四个工人）批量做一些处理步骤。其中一个任务大致沿着“对于没有创建Y的每个X，创建一个Y”。 任务周期性地运行半速率（10sec）。任务完成非常快。还有其他任务也一样。 我遇到过这个问题多次，其中心跳任务显然变成积压，所以相同的任务（从不同的节拍时间），导致不正确的重复工作。 可以限制芹菜节拍以确保只有一个一个任务的优秀实例？在任务上设置类似 rate_limit
..
rabbitmq相关内容
如何在保证每个实体的FIFO的同时处理消息？
假设您在系统中有一个实体，例如“Person”，并且您希望处理修改各种Person实体的事件。重要的是： 同一人的事件按FIFO顺序处理 事件流由不同的线程/进程并行处理 我们有一个实现使用共享数据库和锁来解决这个问题。线程竞争获取一个Person的锁，然后在获取锁后按顺序处理事件。我们想移动到一个消息队列，以避免轮询和锁定，我们认为这将减少DB上的负载，并简化消费者代码的实现。
..
erl with centos“无法为ll_alloc创建主载波”
我有一个centos vps。我已经通过命令安装了erlang rpm -Uvh erlang-17.4-1.el6.x86_64.rpm 现在每当我尝试运行我的rabbitmq服务器。或者我只是发出erl命令 然后我得到这个错误。 无法为ll_alloc创建主载波中止 这是一个内存问题erlang无法获得空闲内存或什么？ 是机
..
rabbitmq服务器安装CentOS - Erlang错误
我有centos 6，并试图安装rabbitmq 3.5.3使用rpm。 （没有yum 选项） 它将我抛弃在eror之下。 [root @ osboxes CentOS]＃rpm -Uvh rabbitmq-server-3.5.3-1.noarch.rpm 警告：rabbitmq-server-3.5.3 -1.noarch.rpm：头文件V4 DSA / SHA1签名，密钥I
..
如何公开访问RabbitMq
我安装了&在Centos远程服务器上设置Rabbitmq。后来我创建了一个文件“rabbitmq.config”并添加了 [{rabbit，[{loopback_users，[]}] ，然后重新启动rabbitmq服务器。再次尝试使用访客凭据从本地计算机登录rabbitmq管理Web界面，但获取 登录失败 错误消息。在Centos中为Rabbitmq清空环回用户设置的正确方
..
我怎么能清除一个MassTransit队列？
我想删除我的集成测试安装例程都从队列中的消息，我怎么能做到呢？没有运气与谷歌搜索/智能感知，暴力破解 如果它很重要 - 我使用RabbitMQ的运输 解决方案 有没有办法”从内部MassTransit队列中删除。“对于测试，您可以通过 RabbitMQ的使用临时，随机队列的URI：//本地主机/ *临时= TRUE ？。或者你也可以追加？临时= TRUE 到现有队列的URI的末尾有M
..
在.NET URL编码正斜杠（/）
我怎么能强迫或者乌里或的HttpWebRequest 允许包含一个URI既 / 和％2F 像下面？ HTTP：//本地主机：55672 / API /交换/％2F / MyExchange 我想这... 的WebRequest请求= HttpWebRequest.Create（“HTTP ：//本地主机：55672 / API /交换/％2F /
..
如何实现分布式处理
我请求进来为不同的样品（S1，S2，..）需要以线性方式进行处理（即，只有一个说在时刻S1-请求可以被处理）。我有工作人员服务，可以处理请求给予N个。我如何能实现RPC的队列模式，使得样品消耗一个在时间和仍然允许不同样本之间计算的分配？ 我想与实现这一兔MQ因为它的简单性，群集功能，但我愿意考虑其他的解决方案也是如此。 下面是说明问题（有两名工人图片） 工人1 + -----
..
我怎么IModel.BasicAcks火？
我玩的RabbitMQ的首次.NET API，我想出了似乎是合理给我一个用例：我想创建出版商出版的消息，并做一些事情后，他们已经确认-ED 。在IModel.BasicAcks事件似乎是一个体面的方式来了解这一点，所以 - 我写了一个出版商： 私有静态无效后（字符串消息）{ model.ExchangeDeclare（“MyExchange”，ExchangeType.Fanou
..
什么开源消息队列软件提供了耐用性，严格的排序？
我们需要的是RabbitMQ的实际工作为队列，不这样做。消息应该留在队列中，直到客户离队他们明确的负责人。 这似乎是一个非常简单的方案，但由于某些原因，我无法找到任何经纪人。支持它。一个经纪人应该在Windows操作系统上运行。 解决方案 的 Apache的Qpid 可能是你最好的选择。所有的消息队列中，这其中有很多有趣的事情去为它，其中的严格的顺序。
..
发布/ .NET与RabbitMQ的订阅样本
我已经建立了这个示例：入门：在.NET RabbitMQ的，但做2个节目： 一个出版商 一户 我用 BasicPublish 公布和 BasicAck 来聆听示例所示。如果我的用户运行一个发布和若干从每只有个出版者一个用户得到它“发送消息”。所以，有一些顺序（如用户已启动），其中发行人发送消息给用户，我想发一条消息给所有用户。什么是错的样品？可能是你能提供通过RabbitMQ的工作出
..
怎么办误差EasyNetQ / RabbitMQ的处理
我使用C＃中的RabbitMQ与EasyNetQ库。我在这里使用的是发布/订阅模式。我仍然有，我希望有人能帮助我有几个问题： 当同时使用消息有一个错误，它会自动移到错误队列。我如何能实现重试（因此它被放回原始队列，当它无法处理X倍，它的移动到一个死信队列）？ 至于我可以看到有总是的用于从所有其他队列将消息1错误队列。怎样才可以有每类错误队列，使每个队列都有自己相关的错误队列？ 如何轻松地
..
不能建造的RabbitMQ-C适用于iOS应用
我想在iOS应用程序使用RabbitMQ的。由于推荐，我用这Objective-C中的包装，其中规定：的没有什么建设。只是包括源文件和头文件到你的X code的项目，并将其链接againt librabbitmq-C。的不过，我一直无法构建应用程序为止。我使用GitHub上可用的最新稳定版本。 1 /我曾试图在自己的项目中的所有文件（包括RabbitMQ的-objc和RabbitMQ的-C），并
..
从某些线程运行preventing任务
我一直在努力与一些异步一点等待的东西。我使用RabbitMQ的一些程序之间发送/接收消息。 作为一个有点背景下，RabbitMQ的客户机使用3左右线程我可以看到：连接线和两个心跳线程。每当通过TCP接收到消息，连接线程处理它，并调用我已经通过接口提供一个回调。文档说，这是最好避免，因为它的这个调用在同一线程上完成的连接，东西都需要继续做的过程中大量的工作。它们提供一个 QueueingBasic
..
RabbitMQ的C＃API基于事件信息消费
，而（真） { BasicDeliverEventArgs E =（BasicDeliverEventArgs）Consumer.Queue.Dequeue（）; IBasicProperties性能= e.BasicProperties; 字节[] =身体e.Body; Console.WriteLine（“：收到消息：”+ Encoding.UTF8.GetSt
..
骆驼RaabitMQ确认
我使用骆驼我的消息应用程序。在我的使用情况下，我有一个制片人（这是RabbitMQ的在这里），而消费者是一个bean。from(\"rabbitmq://127.0.0.1:5672/exDemo?queue=testQueue&username=guest&password=guest&autoAck=false&durable=true&exchangeType=direct&autoDele
..
避免自动与RabbitMQ的骆驼和绑定
我试图使用RabbitMQ的骆驼。我使用的骆驼2.14.1。 我想打开一个的RabbitMQ交换扇出，再后来队列绑定到它。这似乎很好地工作。然而，每次我创建Exchange，它是自动绑定到队列系统名（数字）。我能不能避免？ 下面是一个简单的例子，哪些职位100条消息到Exchange。但他们得到传送到自动创建的队列，我想避免这种情况。 @覆盖 公共无效配置（）抛出异常 {
..
骆驼ShutdownStrategy：机上的邮件不会减少
我使用的是默认关闭的策略在我camelcontext。该路线开始与从队列中消耗超过10k的消息的RabbitMQ消费者。当我停止的路线，消费者不断从队列消耗新的消息。因此，空中交换计数从未递减和路线等待关机，直到默认的超时值（300秒）。有什么办法改变这种行为？基本上停止从消费新邮件时，正在关机的RabbitMQ的消费。 解决方案 我有同样的跟你的问题。问题的关键是关闭的时候，骆驼preF
..
实时应用的新手 - Node.js的+ Redis的或RabbitMQ的 - ＆GT;客户机/服务器怎么样？
我是一个新手，实时应用程序的开发，我试图总结我的头周围无数的选择了。我读过许多博客文章，笔记和论文在那里人们一直认为还跟大家分享。然而，一个简单的问题似乎在我的小脑中没有答案。我想一些其他人可能有同样的问题，所以我也可以注册并张贴在这里的SO。这里所说： 我建立一个微小的实时应用程序，它是异步聊天+另一个有趣的功能。我煮了我的选择，倒在以下两个选项： LAMP +的RabbitMQ 的N
..
如何获得一个工人的RabbitMQ通知我的手机前端？
我有一个移动应用程序发送到REST服务的请求。 REST服务将持续存在的数据，并创建RabbitMQ的请求。 在我的RabbitMQ消费者开始处理队列中的要求，我想以某种方式通知我的移动应用程序，请求正在处理中。 请你能给我提供一些想法，我怎么能通知我的移动应用？ 也许使用像SignalR？ 解决方案 您需要将您的移动应用程序与REST服务器之间启用2路的消息，喜欢的东西Signal
..