# cjfather-redis-stream-mq

**Repository Path**: c-java-father/cjfather-redis-stream-mq

## Basic Information

- **Project Name**: cjfather-redis-stream-mq
- **Description**: redis stream mq
- **Primary Language**: Unknown
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 2
- **Forks**: 0
- **Created**: 2023-11-08
- **Last Updated**: 2025-08-13

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# cjfather-redis-stream-mq
发布订阅模式消息队列 pub/sub
#### 介绍
	Redis的Stream数据结构实现消息队列、修改配置重启可以动态生成多个消费队列、支持集群部署、启动后访问`http://localhost:port/message/{mess}`产生数据并消费

#### 队列配置1

	参考annotation下的consumers

#### 队列配置2

	application.yml中一个key表示一个队列，放一种数据类型，对应StreamConsumerRunner.getType方法进行消费，一条消息可以被每个group各消费一次，同一group内的consumer轮流消费消息，当消息比较多的时候可以部署为集群模式
   
	group命名规范cjfather:group:{序号}.实现类名，group名字中只能包含一个点，group名字不能重复，同一key可以有多个group进行重复消费做不同业务
   
	[
            {"key":"cjfather:queue:1", 
             "groups":[
                     {"group":"cjfather:group:1.userStreamConsumer" , "consumers":["cjfather:consumer:1","cjfather:consumer:2","cjfather:consumer:3"]}
                    ,{"group":"cjfather:group:2.userStreamConsumer" , "consumers":["cjfather:consumer:21","cjfather:consumer:22","cjfather:consumer:23"]}
             ]}
	]