streams流的使用

初始化四步

• 通过添加空数据来创建队列alg_task_queue

  xadd alg_task_queue * data null
  

• 为队列alg_task_queue创建消费者组worker_group，该组从0-0任务号开始消费队列

  xgroup create alg_task_queue worker_group 0-0
  

• 以c1的名义在消费者组worker_group中从队列alg_task_queue读取1个任务

  xreadgroup group worker_group c1 count 1 streams alg_task_queue >
  

• 对任务进行处理完成后的应答

  xack alg_task_queue worker_group 任务号比如1664161245216-0
  

其他操作

• 查询消费者组的信息

  xinfo consumers alg_task_queue worker_group
  

xpending alg_task_queue worker_group - + 10 c1