redis stream问题?
各位大佬,xread 和 xreadgroup block 阻塞后,一有新值就会立即返回,count 参数没用,就失效了。 例如: XREAD BLOCK 5000 COUNT 100 STREAMS mystr…
rabbitmq内存节点里面的消息可以持久化吗?
先跟各位大佬问个好。最近在研究rabbitmq的集群。rabbitmq集群中有磁盘节点和内存节点,其中的区别就是内存节点的元数据都放在内存中,磁盘节点的元…
rabbitmq镜像队列中的master节点如何分发压力?
请教sf圈中的大佬们一个问题: rabbitmq镜像队列中,只有master节点对外提供服务,而slave节点只是提供备份服务。 如果在某个拥有十个节点的rabbitmq…
RabbitMQ 是否应该 一个 channel 对应 一个 queue?
看了一下公司以前的项目, 一个项目就创建了一个 connection 和一个 channel , 一个 channel 承担了好几个 queue 的发布和消费. 但是项目也还算稳定. …
微服务完全采用最终一致性,即便同一个服务内部对两个表的操作也用最终一致性吗?
微服务架构,如果完全利用可靠消息实施最终一致性,不同服务之间用消息队列进行协调但是单个服务内部的事务,如果对两个表进行操作(譬如操作不同的表…
RabbitMQ中channel和exchange,queue或者message之间有什么关系吗?
RabbitMQ中channel这个概念是NIO中的那个channel概念还是和exchange,queue或者message之间有什么关系?…
事务性消息是什么意思?分布式事务和事务消息有什么区别和联系?
分布式事务应该是涉及两个事务的提交,网上看到的demo代码,都是一个生产者的本地事务,而消费者只是业务处理然后返回接收消息成功的状态,没有写成了…
nsq的hanlder任务执行时间一长会报IO error错误(大概两分钟左右)
小弟正在开发go语言基于nsq的异步任务。但是现在发现,只要任务时间一长,客户端就会报错,报错信息如下:2019/08/28 09:21:59 ERR 2 [free/alfx] (1…
先提交事务还是先触发事件?
/** * 创建一个用户和用户的关联数据 * @param array $userData * @param array $userFinanceData * @return UserModel * @throws \Exception */ pub…