messaging

7热度

2回答

我有多个运行在不同机器上的RabbitMQ节点。安装完每个节点后，我无法为每个节点指定一个通用的Cookie，因此我必须返回并手动更改文件.erlang.cookie。我的问题是，这样做后，我得到了冲突的错误消息。如果我做rabbitmqctl状态我得到以下错误： DIAGNOSTICS attempted to contact: ['[email protected]'] [email pro

0热度

1回答

Kafka优于RabbitMQ的优势是什么？

寻找在RabbitMQ上使用Apache Kafka的优缺点。还要决定是否应该将现有基础架构迁移到Kafka。

0热度

1回答

处理消息依次用竞争消费者

问题： I接收消息（说订单）上的队列中的特定序列（FIFO）我已在队列中的竞争消费者为了进一步添加到复杂，消费者可能有兴趣取决于其状态的命令只有特定版本。（说VERSION1，版本2和版本5）顺序版本号是可用的顺序，但由于不能用于测序我的听众可能不感兴趣所有版本（消费者可能只对版本说感觉版本1，版本2和版本5）我如何确保我处理邮件消费者的顺序我收到他们？

0热度

1回答

Apache Kafka：我们可以限制只能由1位消费者阅读的消息吗？

我是卡夫卡的新手，我试图用Apache Kafka实现的场景是：我有一位3位制片人向卡夫卡的特定主题发送指令。我有大约35位消费者一次拿起一条指令并执行指令集中提到的任务。完成后，它会将更新发布到卡夫卡的另一个主题。要求。 1名消费者读取指令不应该给另一个用于处理消息优先级* - 并非强制性要求只有1个指令在一个时间处理有所回升。我知道这可以通过使用JMS来实现。但是我的组织已经准备好了

1热度

2回答

服务请求/响应：你会使用路由密钥并将消息存储在同一个RabbitMQ队列中吗？

例如，我已经实现了搜索索引服务，该服务接收搜索请求并使用消息生成响应。目前，我已经定义了一个队列排队搜索请求等一个入队搜索结果。你重构这个刚刚入队的唯一队列，其中的消息有要求和响应路由键？或者在这种特殊情况下是否过度使用RabbitMQ？

0热度

1回答

腓高效地将消息标记为已读

我有一个消息传送系统（PHP/MYSQL）和I已经制备的字段用于读/未读的简单消息表 Table - msgbody - datetime - receipent - read/unread - sent/unsent (this field is for sending of notification) 我有2个问题我明白当用户创建消息时，我会将字段插入到未读的字段中，并且当我第

0热度

3回答

火力地堡云消息崩溃接到通知

当你好，大家好我今天有这个问题与FCM我是之前使用它工作正常，但现在我得到这个错误火力云消息，debuger https://dpaste.de/DpeH MyFirebaseMessagingService的Java https://dpaste.de/hRVk 感谢您的帮助

0热度

1回答

从sql获取当前用户和其他人之间的最后一条消息

我想要检索当前用户和其他用户之间的最后一条消息，并将其显示在用户的消息页面中，如Facebook的操作。我用这个 <pre> select * from ch_messages where receiver='$current_user_id' or sender='$current_user_id' && (least(sender, receiver), greatest(sender,

24热度

1回答

卡夫卡的基于关键/值对的消息传递的目的是什么？

全部examples的Kafka | producers显示ProducerRecord的键/值对不仅为相同类型（所有示例均显示<String,String>），但值为。例如： producer.send(new ProducerRecord<String, String>("someTopic", Integer.toString(i), Integer.toString(i))); 但在卡

0热度

1回答

用于环形拓扑的ZeroMQ - 如何配置套接字？

我想用ZeroMQ连接环形拓扑中的几台主机。但是我经过很长时间的努力，现在希望能得到一些帮助。基本上我有一个客户端C，它通过多个主机H1 ... Hn发送消息M给自己S.这是一个环形通讯。 C -> H2 -> H1 -> S # where C and S are on the same host. IP addresses: C, S: 192.168.100.165 H2: 192