rabbitmq相关内容

Docker 容器未启动，因为 rabbit 磁盘空间不足

RabbitMQ 似乎占用了太多磁盘空间并且无法启动.如何在我的 Mac 上删除它?我似乎找不到它.我已经尝试删除所有图像和容器，然后从头开始重建，希望它能解决问题. $docker 日志 rabbitmq兔MQ 3.6.6.版权所有 (C) 2007-2016 Pivotal Software, Inc.## ## 在 MPL 下获得许可.见 http://www.rabbitmq.com/# ..
发布时间：2022-01-11 18:00:15 其他开发

使用具有多个线程的rabbitmq消息队列(Python Kombu)

我有一个带有单个队列的 RabbitMQ 交换.我希望创建一个运行多个线程并尽快通过该队列工作的守护进程. “工作"涉及与外部服务的通信，因此每个消费者内部都会发生相当多的阻塞.因此，我希望多个线程都处理来自同一个队列的消息. 我可以通过使用主线程上的队列，然后将传入的工作分配给其他线程池来实现这一点，但是有没有办法在各自的线程上下文中启动多个消费者? 解决方案 看看 cele ..
发布时间：2022-01-11 17:59:37 Python

如何使用 MQTT Paho 订阅 RabbitMQ 队列

我正在尝试从我的 Android 应用程序连接到一个名为“消息"的队列. 生产者(AMQP协议下的一个网络服务)已经连接，可以通过RabbitMQ管理面板查看. 要从我的 Android 设备连接，我是这样编码的. private void connect() 抛出异常 {this.sampleClient = new MqttClient(this.broker, this.cli ..
发布时间：2022-01-11 17:59:26 其他开发

Celery 动态队列创建和路由

我正在尝试调用一个任务并为该任务创建一个队列，如果它不存在，则立即将调用的任务插入该队列.我有以下代码: @taskdef 问候(姓名):返回“你好 %s！"％ 名称定义运行():结果 = greet.delay(args=['marc'], queue='greet.1',routing_key='greet.1')打印结果.ready() 然后我有一个自定义路由器: 类 MyRouter ..
发布时间：2022-01-11 17:59:16 Python

调用 celery 任务挂起延迟和 apply_async

我创建了一个具有以下目录结构的 celery 应用程序(如 celery 网站中给出的): 项目|-- 芹菜.py|-- 芹菜.pyc|-- __init__.py|-- __init__.pyc|-- 任务.py`--任务.pyc 以下是 celery.py 的内容 from __future__ import absolute_import从芹菜进口芹菜应用 = 芹菜('项目'，经纪人= ..
发布时间：2022-01-11 17:58:58 Python

Apache骆驼，RabbitMQ如何发送消息/对象

我希望有人可以在这个问题上提供一些帮助. 我正在使用骆驼rabbitmq，出于测试目的，我试图向队列发送一条消息，我试图在rabbitmq界面中显示该消息，然后将其读回. 但是我不能让它工作. 我认为可行的是，我在 rabbitmq 管理界面的交换选项卡中创建了一个新的交换.在我的 java 代码中，我将消息发送到该交换.执行代码时，我可以在 Web 界面中看到一个峰值，表明已收 ..
发布时间：2022-01-11 17:58:48 Java开发

阻止任务在某个线程上运行

我一直在为一些异步等待的东西苦苦挣扎.我正在使用 RabbitMQ 在某些程序之间发送/接收消息. 作为背景知识，RabbitMQ 客户端使用了 3 个左右的线程，我可以看到:一个连接线程和两个心跳线程.每当通过 TCP 接收到消息时，连接线程都会处理它并调用我通过接口提供的回调.文档说最好避免在此调用期间做大量工作，因为它在与连接相同的线程上完成，并且需要继续进行.他们提供了一个 Queu ..
发布时间：2022-01-11 17:58:38 C#/.NET

“目录名称无效."等在 Windows 上使用 rabbitmq-plugins

我正在尝试按照 这些说明 让 RabbitMQ 在 Windows 10 上运行. 但是，当尝试通过 powershell 命令启用管理插件时: ./rabbitmq-plugins 启用 rabbitmq_management 我得到以下信息: 目录名无效.文件名、目录名或卷标语法不正确.不受支持的节点名称:主机名无效(可能包含不受支持的字符).如果使用 FQDN 节点名称，请使用 ..
发布时间：2022-01-11 17:58:30 其他开发

在没有 http 的情况下从同一服务器上的 php 向 ngnix 发送信息

我们正在开发一个实时应用程序，我们正在将 nginx 推送流模块用于 websockets 部分.首先，数据从客户端发送到 php 脚本，该脚本执行一些身份验证并将所需信息存储在数据库中，然后将信息推送到 nginx，然后将其发送给特定套接字上的订阅用户.经常会出现从该脚本向本地 nginx 发出超过 30 个 http 请求的情况(我不确定这是一件坏事吗?). 问题 是否可以在没有 ht ..
发布时间：2022-01-11 17:58:23 PHP

Sidekiq VS.兔MQ

我们的 Ruby On Rails 4 Web 应用程序需要一个排队系统 有什么区别，为什么选择/不选择 Sidekiq 优于 RabbitMQ 吗? 解决方案 用不同的用法是完全不同的东西.Sidekiq 是用于作业排队和处理的全功能解决方案，而 RabbitMQ 只是一个消息代理，您可以在其中构建自己的东西. ..
发布时间：2022-01-11 17:58:14 其他开发

Masstransit 使用 RabbitMQ 性能很慢?

我在没有 Masstransit 的情况下使用 RabbitMQ，每秒发送 10,000 条消息和 100 秒内发送 100 万条消息. 但是在将 Masstransit 与 RabbitMQ 一起使用后，我的机器上的性能非常低. 当发布/消费消息时，硬盘非常活跃(99% 的使用率)，并且此进程的 CPU 活动几乎为 0%. 当使用此代码运行发布者/订阅者控制台应用程序时: v ..
发布时间：2022-01-11 17:58:06 C#/.NET

在 Docker 中使用 RabbitMQ 删除容器

我尝试用 RabbitMQ 启动一个 Docker 容器，结果下载了镜像，但是容器没有启动.我在日志中收到以下消息: 错误:RABBITMQ_DEFAULT_PASS 已设置但已弃用错误:RABBITMQ_DEFAULT_USER 已设置但已弃用错误:RABBITMQ_DEFAULT_VHOST 已设置但已弃用错误:RABBITMQ_ERLANG_COOKIE 已设置但已弃用错误:检测到不推荐使 ..
发布时间：2022-01-11 17:57:42 其他开发

在 .NET 中使用 RabbitMQ 发布/订阅示例

我已经构建了这个示例:.net 中的 RabbitMQ 入门，但做了 2 个程序: 单一出版商 一个订阅者 我使用 BasicPublish 发布和 BasicAck 来收听，如示例所示.如果我在来自发布者的每条“发送消息"上运行一个发布者和几个订阅者，那么只有一个订阅者会收到它.因此，发布者向订阅者发送消息时存在某种顺序(当订阅者开始时)，我想向所有订阅者发送一条消息.那个样本有什 ..
发布时间：2022-01-11 17:57:35 C#/.NET

Django、RabbitMQ 和Celery - 为什么在我更新开发中的 Django 代码后，Celery 会运行旧版本的任务?

所以我有一个 Django 应用程序，它偶尔会向 Celery 发送一个任务以进行异步执行.我发现当我在开发中处理我的代码时，Django 开发服务器知道如何自动检测代码何时发生更改，然后重新启动服务器，以便我可以看到我的更改.但是，我的应用程序的 RabbitMQ/Celery 部分并没有注意到开发中的这些变化.如果我更改稍后将在 Celery 任务中运行的代码，Celery 仍将继续运行旧版本 ..
发布时间：2022-01-11 17:57:14 Python

RabbitMQ 未定义:js/tmpl/login.ejs 处没有模板

突然间，当我尝试访问 RabbitMQ 时，它只在屏幕上显示: undefined: js/tmpl/login.ejs 中没有模板 任何帮助将不胜感激. 更新: 现在它显示浏览器默认错误:连接被拒绝 解决方案 由于rabbitMQ命令挂起并需要强制停止，因此通过重新启动Linux服务器解决了问题. 希望这对某人有所帮助. ..
发布时间：2022-01-11 17:56:49 C#/.NET

谁能告诉我 python 中 pika 和 kombu 消息传递库之间有什么区别?

我想在我的应用程序中使用消息传递库与 rabbitmq 进行交互.谁能解释一下 pika 和 kombu 库之间的区别? 解决方案 Kombu 和 pika 是两个不同的 Python 库，它们从根本上服务于相同的目的:向/从消息代理发布和消费消息. Kombu 比 pika 具有更高的抽象级别.Pika 仅支持 AMQP 0.9.1 协议，而 Kombu 可以支持其他传输(例如 R ..
发布时间：2022-01-11 17:56:23 其他开发