rabbitmq相关内容

Django Celery:只执行一个长时间运行的进程的实例

我有一个长时间运行的进程，必须每五分钟运行一次，但不应同时运行多个进程实例.该过程通常不应超过五分钟，但我想确保第二个实例在运行结束时不会启动. 根据 上一页推荐，我正在使用 Django Celery 来安排这个长时间运行的任务. 我认为周期性任务不会起作用，因为如果我有 5 分钟的周期，如果另一个任务实例已经在运行，我不希望执行第二个任务. 我目前的实验如下:8:55，任务的 ..
发布时间：2022-01-11 17:51:49 其他开发

RabbitMQ 启动失败，TCP 连接成功但 Erlang 分发失败

我是新人，刚开始学习并在Windows系统上安装RabbitMQ. 我将 Erlang VM 和 RabbitMQ 安装在自定义文件夹中，而不是默认文件夹(两者). 然后我重新启动了我的计算机. 顺便说一句，我的电脑名是“NULL" 我 cd 到 RabbitMQ/sbin 文件夹并使用命令: rabbitmqctl 状态 但是返回的信息是: 节点rabb ..
发布时间：2022-01-11 17:51:15 其他开发

何时使用直接交换而不是扇出交换

据我所知，直接交换没有合适的用例，就像你可以用它做的任何事情一样，你可以用扇出交换做任何事情，只是更具可扩展性. 更具体地说，在阅读 RabbitMQ in Action 时，作者多次提到类似的用例 - “假设当用户上传图片时，您需要生成缩略图.但是后来的营销也告诉你上传照片奖励积分.使用 RabbitMQ，您只需创建另一个队列，而无需在生产者端执行任何操作！" 但这只有如果你有远见在 ..
发布时间：2022-01-11 17:51:07 其他开发

如何禁用 RabbitMQ 默认 tcp 监听端口 - 5672

我已经为 RabbitMQ rabbitmq.config 文件配置了新的端口号，即带有 SSL 的 5671. 现在我想禁用默认端口，即 5672. 配置文件如下:- [{兔子， [{ssl_listeners, [5671]},{ssl_options, [{cacertfile,"/ay/app/xxx/softwares/rabbitmq_server-3.1.1/etc/s ..
发布时间：2022-01-11 17:51:02 其他开发

spring rabbit amqp @RabbitListener 配置最小和最大消费者数量

我正在使用spring amqp rabbit @RabbitListener 注解来自:神器 spring-rabbit-1.7.1.RELEASE我想知道是否有办法为每个队列配置消费者数量?我一直在挖掘文档，但一无所获，有没有办法在相关容器中为每个队列配置消费者数量?提前致谢. 解决方案 通过文档中显示的容器工厂bean. @Bean公共 SimpleRabbitListenerCo ..
发布时间：2022-01-11 17:50:51 Java开发

RPC 模型中的correlationId 和临时队列 - AMQP

我正在使用 RabbitMQ 在 AMQP 中阅读 RPC-Model.本教程创建一个临时队列以及 correlationId.临时队列是唯一的，那我们为什么需要correlationId呢?我是 JMS 人，在 JMS 中，我们通过两种方式请求/响应: 为每个请求/响应创建临时队列 创建一个响应队列并使用 correlationId 和消息选择器. 有人能解释一下为什么我们在 ..
发布时间：2022-01-11 17:50:25 其他开发

在 django 中使用 pika 的 Rabbitmq 监听器

我有一个 django 应用程序，我想使用来自 rabbit mq 的消息.我希望监听器在我启动 django 服务器时开始消费.我正在使用 pika 库连接到 rabbitmq.证明一些代码示例确实会有所帮助. 解决方案 首先你需要在 django 项目开始时以某种方式运行你的应用程序https://docs.djangoproject.com/en/2.0/ref/applicatio ..
发布时间：2022-01-11 17:49:44 其他开发

rabbitmq 的 REST API

有没有办法让我从 $.ajax 向 RabbitMQ 发送数据? 我的应用程序由数千个 Web 客户端(用 js 编写)和 WCF REST 服务组成，现在我想弄清楚如何为我的应用程序创建一个可扩展的点.这个想法是有一个 rabbitmq 实例，它从一侧接收来自 js 客户端的消息，以及从队列中获取待处理消息的 WCF 工作流服务实例. 我知道 AMQP 和 HTTP 是完全不同的东西 ..
发布时间：2022-01-11 17:49:35 C#/.NET

Rails 应用程序中的 AMQP 订阅者

是否可以使用我的 Rails 应用程序启动 AMQP 订阅者?可能通过初始化程序或其他方式. 我想让它同时运行，它还可以与 Rails 模型交互.下面是我的意思的伪代码示例. queue.subscribe 做 |msg,body|Foo.create(....)结尾 解决方案 我通常通过加载 rails 环境的单独消息传递守护程序来完成此操作. 因此，rails_root/sc ..
发布时间：2022-01-11 17:49:20 其他开发

ubuntu rabbitmq - 错误:无法连接到节点'rabbit@somename:nodedown

我正在为需要rabbitmq 的django 使用芹菜.大约 4 或 5 个月前，它曾经运作良好.我再次尝试将它用于一个新项目，并在列出队列时遇到 rabbitmq 的错误. 列出队列...错误:无法连接到节点“rabbit@somename":nodedown诊断:- 'somename' 上的节点及其端口:[{rabbitmqctl23014,44910}]- 当前节点:'rabbitmqc ..
发布时间：2022-01-11 17:49:07 其他开发

使用 RabbitMq 锁定和批量获取消息

我正在尝试以更非传统的方式使用 RabbitMq(尽管此时我可以根据需要选择任何其他消息队列实现).消费者没有将 Rabbit 推送消息留给我的消费者，而是连接到一个队列并获取一批 N 条消息(在此期间它会消耗一些消息并可能拒绝一些消息)，然后它会跳转到另一个队列，依此类推.这样做是为了冗余.如果某些消费者崩溃，则所有消息都保证会被其他消费者消费. 问题是我有多个消费者，我不希望他们在同一个 ..
发布时间：2022-01-11 17:49:01 其他开发

将外部 IP 地址绑定到 Rabbit MQ 服务器

我有盒子 A，它上面有一个在 Rabbit MQ 服务器上侦听的消费者 我有框 B，它将向侦听器发布消息 所以只要所有这些都在框 A 上，我启动 Rabbit MQ 服务器 w/默认它就可以正常工作. 端口 5672 上的默认值为 host=127.0.0.1，但是当我从框 B telnet box.a.ip.addy 5672 我得到: 正在尝试 box.a.ip.addy. ..
发布时间：2022-01-11 17:48:54 其他开发

基于多线程的 RabbitMQ 消费者

我们有一个 Windows 服务，它监听单个 RabbitMQ 队列并处理消息. 我们希望扩展相同的 Windows 服务，以便它可以监听多个 RabbitMQ 队列并处理消息. 不确定是否可以通过使用多线程来实现，因为每个线程都必须监听(阻塞)队列. 由于我对多线程非常陌生，因此需要以下几点的高级指南，这将有助于我开始构建原型. 是否可以使用线程在单个应用程序中监听多个队 ..
发布时间：2022-01-11 17:48:25 C#/.NET

我需要在我的单元测试中模拟一个 RabbitMQ

我在我的项目中使用 RabbitMQ. 我的消费者中有rabbitMQ客户端部分的代码，连接需要一个tls1.1来连接真正的MQ. 我想在我的 JUnit 测试中测试此代码并模拟向我的消费者传递的消息. 我在 google 中看到了几个使用不同工具的示例，骆驼兔或 activeMQ 是如何使用的，但此工具适用于 amqp 1.0，而 rabbitMQ 仅适用于 amqp 0.9. ..
发布时间：2022-01-11 17:48:17 Java开发