amqp

amqp

文章 19 浏览 68

如何在RabbitMQ服务器上设置超时检测?

我正在尝试 RabbitMQ 和 这个 python 绑定。 我注意到的一件事是,如果我不干净地杀死一个消费者(模拟崩溃的程序),服务器会认为这个消费者仍然存在…

如梦 2024-08-03 03:27:08 8 0

AMQP延迟传递并防止重复消息

我有一个会偶尔生成消息的系统,我只想每 5 分钟提交零条或一条消息。 如果没有生成消息,队列使用者将不会处理任何内容。 如果 5 分钟内生成一百条相…

归属感 2024-07-27 21:46:29 9 0

Django 中消息队列消费者放在哪里?

我在 Django 项目中使用 Carrot 作为消息队列,并遵循教程,而且效果很好。 但该示例在控制台中运行,我想知道如何在 Django 中应用它。 我从 models.…

伪心 2024-07-27 03:51:44 5 0

如何对 Map进行编码? 使用协议缓冲区?

我正在尝试使用 用于消息序列化的协议缓冲区。 我的消息格式应包含 Map 条目...但是我该如何编写 .proto 定义? 据我所知,Protocol Buffers 没有内置…

乖乖哒 2024-07-27 02:39:49 9 0

我应该在 Django 项目中使用 Celery 还是 Carrot?

我有点困惑我应该使用哪一个。 我认为两者都可以,但其中一个比另一个更好或更合适吗? http://github.com/ask/carrot/tree/master http://github.com…

国粹 2024-07-26 01:17:11 5 0

从客户端检查 RabbitMQ 队列大小

有谁知道是否有办法从客户端应用程序检查 RabbitMQ 队列中的消息数量? 我正在使用 .NET 客户端库。…

樱娆 2024-07-25 04:01:01 9 0

RabbitMQ C# 客户端不与 Apache Qpid Java Broker 对话

我已在 Windows 机器上安装了 Apache Qpid Java 代理的 M4 版本,并使用开箱即用的配置(通过 qpid-server.bat 脚本)启动它。 我现在尝试使用 Rabbit…

夏有森光若流苏 2024-07-14 22:33:30 11 0

使用哪种群组消息技术?

我感到有点困惑——大约 24 小时以来,我一直在思考在我的项目中使用哪种群组广播技术。 基本上,我需要的是: 创建组(通过某些后端进程) 由任何客…

郁金香雨 2024-07-13 21:03:19 16 0

将多播传送到多个不同的地理位置

我需要在应用程序中使用一个基于 PGM 的逻辑多播地址,同时使此类应用程序能够“无缝”运行在多个不同的地理位置(即美国/欧洲/澳大利亚)。 应用程序…

痞味浪人 2024-07-10 05:24:52 18 0

AMQP 是否适合作为机器内和机器间软件总线?

我正在尝试了解 AMQP。 它看起来非常适合应用程序之间的机器间(集群、LAN、WAN)通信,但我不确定它是否适合(在架构和当前实现方面)用作一台机器内…

别念他 2024-07-08 20:44:28 17 0

rabbitmq并发消费问题?

新建一个队列,我插入了1到999 这样的数字,消费端监听用concurrency并发消费 ,看控制台打印,为什么消费的时候数字跨度这么大,队列不是先进先出么…

分分钟 2022-09-13 01:10:37 26 0

RabbitMQ 是否应该 一个 channel 对应 一个 queue?

看了一下公司以前的项目, 一个项目就创建了一个 connection 和一个 channel , 一个 channel 承担了好几个 queue 的发布和消费. 但是项目也还算稳定. …

Spring初心 2022-09-11 23:24:26 30 0

rabbitmq的发送确认机制和事务的区别在哪里?

rabbitmq的发送确认机制中需要confirm或者return需要broker确认这个感觉和事务没啥区别了啊事务也是broker确认啊为什么说发送确认机制就是轻量级,对…

浅听莫相离 2022-09-11 22:47:29 16 0

Error: Address already in use[98]

laravel+swoole+amqp实现异步的方式推送消息,之前都是自己手写redis队列,这次想用下amqp。创建websocket_server,接收到消息放到队列。然后另外一个…

九厘米的零° 2022-09-11 21:08:12 15 0

阿里云 amqp node 为啥连接的时候一直报错 报错链接错误

如题:// 连接amqp服务器 const open = amqplib.connect('amqp://${endPointer}/${vhost}?heartbeat=${heartbeat}&channelMax=${channelMax}&frameMa…

善良天后 2022-09-11 19:52:15 28 0
更多

推荐作者

苍风燃霜

文章 0 评论 0

悸初

文章 0 评论 0

撧情箌佬

文章 0 评论 0

森罗

文章 0 评论 0

lyn1245

文章 0 评论 0

    我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
    原文