# matrix

**Repository Path**: wang11111/matrix

## Basic Information

- **Project Name**: matrix
- **Description**: 消息流转中心
- **Primary Language**: Unknown
- **License**: MulanPSL-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 3
- **Created**: 2022-04-27
- **Last Updated**: 2022-05-24

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

![输入图片说明](image_.png)

[![](https://img.shields.io/badge/Author-uptown-orange.svg)](https://gitee.com/atuptown/matrix)
[![star](https://gitee.com/atuptown/matrix/badge/star.svg?theme=dark)](https://gitee.com/atuptown/matrix)
[![fork](https://gitee.com/atuptown/matrix/badge/fork.svg?theme=dark)](https://gitee.com/atuptown/matrix)


#### 介绍
- 实现redis stream、kafka、rocketmq服务内部消息流转中心
- 注解实现消费者
    - redis消费者类必须继承StreamListener<String, ObjectRecord<String, Object>> 统一消息风格、注解加载类上与onMessage方法上
    - kafka、rocketmq消费者类只需要在对应方法加该注解，对方法名无要求
  
- api实现生产者发送

- martix-stream 提供流式环境，动态统计内部消息流转状态

#### todo
- 分布式校验消息消费者线程存活
- 白名单限制
- 统一消息风格
- 使用文档

#### 使用说明
matrix-web为总启动类