rabbitmq相关内容

捕获芹菜工人的Heroku SIGTERM，优雅地关闭工人

我在这方面做了大量的研究，我很惊讶，我还没有找到一个好的答案，但它在任何地方。 我是在Heroku上运行一个大型应用程序，并且我有一些运行很长时间的芹菜任务，并且在任务结束时保存一个结果。每次我重新部署Heroku时，它都会发送SIGTERM（最终，SIGKILL）并杀死我的正在运行的工作者。我试图找到一种方法让worker实例正常关闭，然后重新排队以便稍后处理，以便最终我们可以保存所需的结 ..

发布时间：2018-06-07 10:54:22 python heroku rabbitmq celery sigterm Python

区分芹菜，kombu，PyAMQP和RabbitMQ / ironMQ

我想将图像上传到S3服务器，但在上传之前，我想生成3种不同大小的缩略图，并且我希望它能够在请求/响应周期内完成，因此我使用了芹菜。我已阅读文档，这是我的理解。如果我错了，请纠正。 Celery可以帮助您管理请求响应周期外的任务队列。 b 然后有一个名为carrot / kombu的东西 - 它是一个django中间件，它包含通过芹菜创建的任务。然后，第三层PyAMQP便于胡萝卜与经纪人。例如 ..

发布时间：2018-06-07 10:52:08 python heroku rabbitmq celery kombu Python

如何在Heroku上使用Node.js与Web和Worker dynos进行通信？

Web Dynos 可以处理HTTP请求 ， Web Dynos 可以处理它们工人Dynos 可以处理作业。 但我不知道如何制作 Web Dynos 和工人Dynos 例如，我希望通过 Web Dynos 接收HTTP请求。 能够相互沟通。 ，发送给工人Dynos ，处理作业并将结果发送到 Web Dynos ，在Web上显示结果。 Node.js中有这种可能 ..

发布时间：2018-06-07 10:44:14 node.js heroku redis rabbitmq kue 其他开发

Heroku上的节点JS消息队列

我需要将运行在Heroku上的Node JS服务器移动到消息队列体系结构中。目前，服务器接收到HTTP请求，进行一些处理并作出响应。问题是处理需要一些时间，特别是当有很多请求时。这种冗长的处理时间会导致服务器超时，超载和崩溃！我的阅读告诉我需要一个后台工作人员来处理。 我对消息队列和后台工作者没有任何经验，我正在寻找一个非常简单的例子来开始。任何人都可以提出一个简单易懂的模块或示例来开始吗？ ..

发布时间：2018-06-07 10:19:48 node.js heroku rabbitmq backgroundworker message-queue 其他开发

解组入接口{}然后执行类型断言

我通过一个rabbitmq消息系统得到了一个字符串。在发送之前，我使用 json.Marshal ，将结果转换为 string code>并通过 发送rabbitmq。 我转换和发送的结构可以是：（更改结构的名称和大小，但它应该没关系） type Somthing1 struct { Thing string`json：“thing”` OtherThing int64`jso ..

发布时间：2018-05-02 17:59:28 go rabbitmq 其他开发语言

php - 大量过期订单的处理问题

问 题 描述你的问题 最近开发遇到一个大量订单过期处理的问题，比如我拍了一个商品，半个小时之后他就不能付款了或者这个订单应该被删除掉。 第一、反应是crontab，但是考虑到每次都要去查mysql，感觉会影响效率； 第二、有人提示我用消息队列rabbitmq，但是我看了半天感觉消息队列好像没啥用，我感觉逻辑还是拍下订单的时候发送消息，然后php进程一直在那sleep？估计是我理解的 ..

发布时间：2017-09-06 12:37:15 crontab rabbitmq php PHP

redis - 关于队列实时消费？

问 题 在项目中是用的cron每分次跑一次，大家做的是实时的吗还是也是跑定时？ 解决方案 使用redis的阻塞队列实时消费，没有消息就会自动阻塞，有了消息会自动消费。 blpop和brpop命令 ..

发布时间：2017-09-06 12:28:34 redis rabbitmq kafka-php kafka 其他开发

rabbitmq - Spring4为我们提供了@Async注解，我们还需要消息中间件作异步消息处理吗？

问 题 我们一般会用rabbitmq或者kafka作异常消息处理，但是今天看到spring4中有个@Async注解，作用就是异步调用，如果是这样的话我们还需要用消息中间件吗？ 代码如下： public String method(){ String result = a(); // 现状：发送kafka事件，在kafka的consumer中处理b方法的内 ..

发布时间：2017-09-06 10:48:57 rabbitmq kafka spring 其他开发

关于springboot和rabbitmq结合的问题

问 题 下面是rabbitmq的相关配置 package com.kindlepocket.cms.service; import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.ObjectMapper; import com.kindlepocket.cms.Rabbit ..

发布时间：2017-09-06 08:32:52 rabbitmq springboot 其他开发

php - 消息队列有什么用？

问 题 我最近写了一个网站，需要不停的轮询一个接口，如果数据有变化就需要发送邮件，现在有人说出现了白天收不到邮件晚上才能收到的情况，我猜是不是白天发邮件频率太高所以有的邮件发不出去？请问这种情况下是不是我需要用消息队列？（我是php写的后端，不知道sf允许发我网站的网址吗，我怕被管理员认为是广告。。。） 另外消息中间件和消息队列是什么关系啊？ 解决方案 使用消息队列的十个理由： ..

发布时间：2017-09-06 07:28:27 消息中间件 rabbitmq handler 消息队列 php PHP

php - Rabbitmq怎么知道消费者执行是否成功.

问 题 场景：下订单，扣库存。 我的想法是把下订单的任务放到队列里面 一个个进行处理，这样库存在扣减的时候，就不会出错了。 就是生产者与消费者 用户在UI中点击“提交订单”时，把任务放到队列，等待队列处理这个任务的结果，根据结果（成功或者失败）进行页面跳转 但是有一个问题：队列处理后，如何把结果通知生产者？ 以RabbitMQ为例子，有哪位大神可以给出代码. 解决方案 ..

发布时间：2017-09-06 07:11:11 rabbitmq erlang php PHP

java - spring-amqp中消费者同步回复消息有没有更简单的方法？

问 题 amqp中使用 provider使用sendAndReceive可以等待消费者取得返回值 consumer使用receiveAndReply，并添加监听器，可以取得provider的message处理并回复 当消息是异步时，直接注册监听器实现onMessage(）方法即可。 但是onMessage()方法的返回值是void 那么如果要实现provider同步的功能 ..

发布时间：2017-09-06 04:28:35 队列 rabbitmq spring java amqp Java开发

java - PHP rabbitmq 如何获取当前所有队列信息？

问 题 需求：我想要遍历rabbitmq中所有队列信息，然后持续输出队列内容。 那么 PHP rabbitmq 如何获取当前所有队列信息？ 解决方案 首先开启web管理界面 rabbitmq-plugins enable rabbitmq_management 然后在web管理界面上可以看到rest api的链接,默认是http://127.0.0.1:15672 ..

发布时间：2017-09-05 23:45:15 java linux rabbitmq php Java开发

php - RabbitMQ未响应ack的消息如何重新回到队列?

问 题 用的php语言,扩展包是php-amqplib。 问题1：未响应ack的消息如何重新发给其他的消费者呢？ 问题2：消费者队列全部死了，如何让发送到exchange的消息不丢失呢？重新启动消费者进程可以获取到之前发送的消息。 谢谢 解决方案 1 basic.nack 2 rabbitmq支持消息持久化 ..

发布时间：2017-09-05 23:12:19 laravel python rabbitmq php PHP

python - celery+rabbitmq异步任务，队列消息一直增加

问 题 celery 配合 rabbitmq 进行异步任务时，发现 rabbitmq 里消息的数量是一直增加的，但是这些消息其实也已经被 task 处理掉. 查看 rabbimtq 自带的后台，发现 Queued messages 里面，ready 和 total 的数量都达到了 5000 多，unacknowledged 的值为 0。不过实际在工作的时候，unacknowledged ..

发布时间：2017-09-05 22:37:36 rabbitmq celery python Python

java - rabbitmq 进行连接时，报错，找不到

问 题 警告: Unable to create rpc client java.io.IOException at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:105) at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:101) at com. ..

发布时间：2017-09-05 21:29:37 java rabbitmq Java开发

python - 如何设置rabbitmq里面的prefetch_count值

问 题 rabbitmq-celery组合使用,如何在/etc/rabbitmq/rabbitmq.config设置prefetch_count的值? 目前设置如下,无法启动rabbitmq,哪里有问题? [ {rabbit, [{tcp_listeners, [5672]}]}, {rabbitmq_shovel,[{shovels,[{my_first_shovel,[{pr ..

发布时间：2017-09-05 20:43:31 rabbitmq celery python linux 服务器开发

在Spring Integration中处理异常时遇到麻烦

我刚刚进入春天的整合，对于如何将错误信息发送到指定的错误队列感到困惑。我想让错误信息成为原始邮件的标题，最后在一个单独的队列中。我读到这可以用一个标题丰富程序，我试图实现，但没有显示在错误队列。 另外，我需要一个单独的异常处理类以使错误消息使其成为错误队列，或者我可以在我的转换方法中抛出异常？ 这是我的xml配置： ..

发布时间：2017-08-28 01:09:56 java error-handling rabbitmq spring-integration Java开发

Red Hat Enterprise Linux 7.2上的RabbitMQ RPM安装失败（即使安装了erlang）

在 RabbitMQ 的首页中，说 首先安装 erlang 然后通过 安装 RabbitMQ rpm --import https://www.rabbitmq.com/rabbitmq-release-signing-key.asc yum install rabbitmq-server-3.6.3-1.noarch.rpm 我安装了 erlang ，但是当安装R ..

发布时间：2017-08-27 14:04:49 installation erlang rabbitmq rhel7 其他开发语言

RabbitMq和“致命错误：握手失败 - handshake_decode_error”

我正在使用Windows Server 2012，Erlang 19.2和RabbitMq 3.6.6。我在使用TLS配置端点之间的连接时遇到困难。我已经尝试了所有的答案，以及所有的RabbitMq文档 here 和这里。不知道我们在做错什么。 在疑难解答链接在这里所有测试通过 ”尝试SSL连接到代理“片段。这是问题所在，我不知道为什么。 当我浏览有关故障排除的文档，看看是否可以获得超 ..

发布时间：2017-08-27 13:44:28 windows ssl openssl erlang rabbitmq 其他开发语言