message-queue 第6页 - IT屋-程序员软件开发技术分享社区

设计 Kafka 主题 - 许多主题与一个大主题

考虑到一系列不同的事件，推荐的方法是一个包含所有事件的大主题针对不同类型活动的多个主题哪个选项会更好? 我了解消息不在主题的同一分区中，这意味着没有顺序保证，但是在进行此操作时是否有任何其他要考虑的因素决定? 解决方案主题是一个逻辑抽象，应该包含相同类型的消息.假设您监控网站并捕获点击流事件，另一方面，您有一个数据库将其更改填充到更改日志主题中.您应该有两个不同 ..

发布时间：2021-06-02 20:32:04 apache-kafka message-queue messaging distributed-computing kafka-producer-api 其他开发

示例 mq_timedreceive

我找不到如何使用 mq_timedreceive 正常工作，谁能给我举个例子? ssize_t mq_timedreceive(mqd_t mqdes, char *msg_ptr,size_t msg_len, 无符号 *msg_prio,const struct timespec *abs_timeout); 我希望 timereceive 等待的时间不要超过 20 秒. 非常感谢. ..

发布时间：2021-06-02 20:31:23 c linux timeout message-queue 服务器开发

发送消息到任意虚拟主机/与 RabbitMQ/Spring AMQP 交换

我使用 RabbitMQ 和 Spring AMQP 发送消息. 我有这个片段: rabbitTemplate.convertAndSend(exchange, key, object); 这在我操作单个 VHOST 时有效. 我必须从 1 个队列接收消息并将它们重新发送到 N 个交换机(在许多不同的 VHOST 上).我如何在 Spring AMQP (ver 1.2) 中做到这 ..

发布时间：2021-06-02 20:31:20 java rabbitmq message-queue spring-amqp Java开发

在 RabbitMQ 上拒绝和拒绝

我想处理消费者从队列中获取的不成功消息并将它们重新排队. 想象一下我有这样的情况: P =>|富|酒吧|巴兹|=>C 其中 foo、bar 和 baz 是消息. 如果消费者读取 baz 但出现问题，我可以使用 basic.reject 或 basic.nack ( https://www.rabbitmq.com/nack.html).使用这两个命令之一，我将传递参数以重新排队消息 ..

发布时间：2021-06-02 20:31:17 queue rabbitmq message-queue 其他开发

Azure 服务总线队列消息处理

所以我有一个 azure 函数充当调用内部托管 API 的队列触发器. 在线似乎没有关于如何处理由于有毒以外的问题而无法处理的消息的明确答案. 示例: 收到我的消息，函数尝试调用 API.消息有效负载是正确的并且可以处理，但是无论出于何种原因 API/服务关闭(这次可能会超过 10 分钟).目前发生的情况是消息传递计数达到最大值(10)，然后被推送到死信队列，这反过来又发生在每条 ..

发布时间：2021-06-02 20:31:06 azure message-queue azure-servicebus-queues brokeredmessage 其他开发

RabbitMQ 无法声明队列并且侦听器无法在服务器上获取队列

我有 spring boot rabbitmq 应用程序，我必须将 Employee 对象发送到队列中.然后我设置了一个监听器应用程序.对employee对象做一些处理，把这个对象放到回调队列中. 为此，我在我的应用程序中创建了以下对象. 创建ConnectionFactory. 使用 ConnectionFactory 创建了 RabbitAdmin 对象.. 请求队列. 回调 ..

发布时间：2021-06-02 20:30:42 spring-boot rabbitmq message-queue spring-amqp spring-rabbit 其他开发

为什么使用消息队列而不是多线程?

我有以下查询，需要有人帮助我.我是消息队列的新手，最近开始查看 Kestrel 消息队列.据我了解，线程和消息队列都用于应用程序中的并发，那么使用消息队列比多线程有什么优势? 请帮忙谢谢. 解决方案消息队列允许您在程序外进行通信. 这允许您将生产者与消费者分离.您可以将要完成的工作分散到多个进程和机器上，并且可以相互独立地管理/升级/移动这些程序. 消息队列通常还由一个 ..

发布时间：2021-06-02 20:30:39 multithreading message-queue 其他开发

如何在 RBDMS 或 NOSQL 数据存储或其他消息传递系统(例如，rabbitmq)之上实现类似分布式队列的东西?

来自wouldnt-it-be-cool-if 类别的问题...... “类似队列的东西"是指支持以下操作: append(entry:Entry) - 将条目添加到队列尾部 take(): Entry - 从队列头部移除条目并返回它 promote(entry_id) - 将条目移到靠近头部的位置；当前占据该位置的条目移动到旧位置 demote(entry_id) - 与pro ..

发布时间：2021-06-02 20:30:36 java python nosql message-queue rabbitmq Java开发

为什么`multiprocessing.Queue.get` 这么慢?

我需要帮助来理解 multiprocessing.Queue.我面临的问题是，与调用 queue.put(...) 和队列的缓冲区(双端队列). 这种泄漏的抽象使我调查了队列的内部结构.它简单的源代码只是将我指向双端队列实现，这似乎也很简单，我无法用它来解释我看到的行为.我还读到 Queue 使用管道，但我似乎无法在源代码中找到它. 我已将其归结为重现问题的最小示例，并在其下方指定了 ..

发布时间：2021-06-02 20:30:34 python-3.x message-queue python-multiprocessing 其他开发

使用 mosca MQTT 请求响应模式

是否有任何方法可以使用 mosca MQTT 实现请求-响应模式，以“检查来自客户端的回复并重新发布，如果我在预期时间内没有收到预期回复". 我相信这在 Mqtt 5 中是可能的，但截至目前，我必须使用具有 QoS 1 的 Mosca 代理(支持直到 Mqtt 3.1.1) 我正在寻找一种 Node js 解决方法来实现这一点. 解决方案根据我的评论，您可以使用任何 MQTT ..

发布时间：2021-06-02 20:30:21 node.js mqtt message-queue publish-subscribe mosca 其他开发

在Typescript中实现Bull Queue

我尝试在Typescript和NestJS中实现Bull队列，我的代码: @Injectable()导出类MailService {构造函数(@InjectQueue('mail')私人只读mailQueue:队列){}异步addToQueue():Promise{this.mailQueue.add(()=> {返回this.sendMail();})}异步sendMail() ..

发布时间：2021-05-20 19:09:15 javascript typescript queue message-queue job-scheduling 前端开发

我有我的自定义WndProc，它应该根据我的ImGui菜单是否打开来处理输入. if(Menu :: isOpen){ImGui_ImplWin32_WndProcHandler(hWnd，msg，wParam，lParam);如果(msg == WM_LBUTTONDOWN||味精== WM_LBUTTONUP||味精== WM_LBUTTONDBLCLK||味精== WM_MBUTTOND ..

发布时间：2021-05-04 21:09:57 windows winapi events mouseevent message-queue 其他开发

定义具有多种消息类型的消息传递域

到目前为止，我所看到的大多数F#消息传递示例都在处理2-4种消息类型，并且能够利用模式匹配将每条消息定向到其适当的处理函数. 对于我的应用程序，由于它们处理和所需参数的不同性质，我需要数百种独特的消息类型.到目前为止，每种消息类型都是其自己的记录类型，并附加了一个标记接口，因为在一个单独的联合中包含数百种类型并不是一件很漂亮的事，而这些类型的模式匹配也不会很漂亮.结果，我目前正在使用反射来查 ..

发布时间：2021-05-02 20:20:53 reflection f# rabbitmq domain-driven-design message-queue 其他开发

具有作业亲和力的作业队列

我目前遇到一个问题，我可以肯定有一个正式名称，但是我不知道该在网上搜索什么.我希望如果我描述问题和解决方案时想到的，有人能够告诉我设计模式的名称(如果有一个与我要描述的内容相匹配的设计模式). 基本上，我想拥有一个工作队列:我有多个创建工作的客户端(发布者)，以及许多处理这些工作的工人(消费者).现在，我想将发布者创建的作业分发给各个使用者，这基本上可以使用几乎任何消息队列并在队列之间进行负 ..

发布时间：2021-04-30 19:25:28 design-patterns message-queue distributed dispatcher job-queue 其他开发

boost ::进程间消息队列timed_receive()内部过程

im当前使用 boost :: interprocess 库中的 timed_receive()方法接收数据.由于接收到的消息的时间会有所不同，因此我在 receive()方法上使用了此方法. msgque-> timed_receive((void *)& message，sizeof(int)，recvd_size，priority，boost :: posix_time :: ptime ..

发布时间：2021-04-15 20:52:33 c++ boost message-queue C/C++开发

一个监听器，用于多个天蓝色队列

我想创建一个Web作业(侦听器)以侦听存储中的所有队列.如果有任何新消息，它将触发处理程序. Azure WebJobs SDK提供了一种仅侦听一个队列的解决方案: 公共类函数{//写入新消息时将触发/执行此函数//在称为队列的Azure队列上.公共静态异步任务ProcessQueueMessage([QueueTrigger(“％test％")] CloudQueueMessage消息， ..

发布时间：2021-04-13 20:00:30 c# azure message-queue azure-webjobs C#/.NET

使用Windows Azure队列将消息锁定在队列中

我正在使用Windows Azure消息队列.我想知道是否有一种在收到消息时将消息锁定在队列中的方法吗? 解决方案从队列中检索消息时，该消息被标记为不可见，直到将其删除(或达到超时期限)为止.标记为不可见时，其他人看不到该消息.我想这与您将要获得的“锁定"功能几乎一样. 如果在处理过程中感觉需要更多时间，则可以修改消息并延长隐身超时时间. 您确实需要关注Windows Azu ..

发布时间：2021-04-13 19:14:34 azure message-queue azure-storage azure-queues 其他开发

如何在服务器之间平衡地分配(纸牌游戏桌)发牌人?

我目前正在从事类似于二十一点的在线纸牌游戏，该游戏将由一系列桌子组成，其中每个桌子都有一个“经销商"和多个人类玩家.发牌人(计算机机器人)负责发牌和洗牌.表将存储在PostgreSQL数据库表中，管理员可以添加/删除/编辑表. 游戏将由一个Web前端和一个REST/websocket API后端组成.我可能会使用Kubernetes和Nginx作为后端服务器的负载平衡器. 我的问题.假 ..

发布时间：2021-04-09 19:06:10 architecture load-balancing message-queue distributed-computing consistent-hashing 其他开发

卡夫卡使用者关机后丢失消息状态

感谢您抽出时间回答问题.我在与Python使用者一起使用kafka.当消费者启动并运行并且消息被推送到kafka，然后由消费者读取时，一切工作都很好. 但是，如果使用者由于某种原因而掉线，则当它重新启动时，它只会读取在使用者重新启动后发布到kafka的NEW消息.关机-开机之间的消息会丢失，也就是说，消费者在恢复后不会阅读这些消息. consumer = KafkaConsumer(.. ..

发布时间：2021-04-08 19:09:28 python message-queue apache-kafka Python

RabbitMQ中消息，队列和交换的限制是什么?

允许的消息类型是什么(字符串，字节，整数等)? 邮件的最大大小是多少? 队列和交换的最大数量是多少? 解决方案理论上，任何东西都可以存储/发送为消息.您实际上不想在队列上存储任何内容.如果队列大多数时间都是空的，则系统将最有效地工作.您可以使用两个先决条件将想要发送的任何内容发送到队列: 您要发送的内容可以与字节串相互转换消费者确切地知道得到了什么以及如何将其转换为原始 ..

发布时间：2021-04-03 20:04:47 rabbitmq message-queue message amqp rabbitmq-exchange 其他开发

message-queue相关内容