rabbitMQ 的channel是不是跟quene_name是绑定的？
rabbitMQ的客户端代码有如下示例： package com.zhy.rabbit._01; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; imp…
分布式系统的事务问题
1.分布式系统事务都是说的要保证一个方法里面的所有都成功了,才会成功,我有一个问题,比如: method() { 1 do something 2 boolean b = sendMsg('123')…
为什么win10下 kafka 0.11重启时报timeindex文件被占用？
[2017-08-15 14:28:29,406] WARN Found a corrupted index file due to requirement failed: Corrupt index found, index file (D:kafka-stackkafka-…
redis使用list做消息队列,为什么推送用lpush,而消费用的是brpop?
最近尝试使用redis做消息队列, 奇怪的是redis使用list做消息队列的话,为什么推送用lpush,而消费用的是brpop? 写代码的时候消费者大致如下:while(true)…
rmq队列有问：queue什么时候创建？
在看rmq的时候，发现生产者只将信息发送到了exchange，此时还没有queue，就是消息还没到queue，然后消费者再去（根据routing_key）绑定exchange和queu…
如果消费者在收到消息后处理的结果会影响后续生产者消息的发送，那么用消息队列合适吗？
场景：使用rabbitmq，生产者消费者模式 消息队列收到一个删除某条数据的信息 一个客户端收到后，进行删除业务操作（假如业务操作比较繁琐，数据在10…
