基于Go语言，实现对Redis Stream消息队列客户端接口的封装，支持单条/批量添加消息，也支持阻塞和非阻塞的无消费组模式的消费，以及阻塞和非阻塞的消费组模式的消费，支持对消息队列，消费组和消费者基本信息的监控，并且包含生产者和消费者客户端测试代码。
2021-06-03 13:03:47
12KB
1