# Naruto.Subscribe

**Repository Path**: haiboi/naruto.-subscribe

## Basic Information

- **Project Name**: Naruto.Subscribe
- **Description**: 本项目是一个基于.net core 开发的事件总线
- **Primary Language**: C#
- **License**: MIT
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 8
- **Forks**: 1
- **Created**: 2020-09-05
- **Last Updated**: 2025-08-19

## Categories & Tags

**Categories**: message-server

**Tags**: None

## README

# Naruto.Subscribe

#### 介绍
发布订阅

#### 软件架构
1.    基于 net core 3.1
2. Redis使用的是自己根据StackExchanges.Redis封装的仓储 <https://gitee.com/haiboi/Naruto.Data>
3.    Rabbit 使用的RabbitMQ.Client
4.    kafka使用的Confluent.Kafka

#### 安装教程
1. 安装 <b>Naruto.Subscribe</b> 核心包
2. 安装 <b>Naruto.Subscribe.Provider.Redis</b> ，基于redis的发布订阅
3. 安装 <b>Naruto.Subscribe.Provider.RabbitMQ</b> ，基于RabbitMQ的发布订阅,使用的是Direct 直连交换机
4. 安装 <b>Naruto.Subscribe.Provider.Kafka</b> ，基于kafka的发布订阅
#### 使用说明

1.  当前框架 已经实现了redis版本的消息订阅，和rabbitmq,以及kafka的消息订阅，更多mq的订阅正在接入中
##### 
        1.1 使用redis提供者的时候，当消息处理失败的时候，将会隔10分钟进行重试
        1.2 redis每条消息只能有一个消费者处理消息
        1.3 rabbitmq使用的是direct交换机模式
2.  如果需要实现自己的订阅方式，需要实现接口 <b>INarutoPublish</b>发布接口，和<b>ISubscribeEvent</b>订阅接口
3. 书写自己的订阅业务的时候，需要继承<b>ISubscribe</b>接口,继承此接口的对象自动会注入生命周期为Scope的对象,可以使用DI的功能
4. ![subscribe](/subscribe.png)
5. 给需要订阅的方法标记<b>Subscribe</b>特性
6. 使用<b>NarutoMessageAopEvent</b>，可以处理消息发送前后的aop事件
7. #### 注入方法
    ![use](/use.png)
#### 参与贡献 

1.  Fork 本仓库
2.  新建 Feat_xxx 分支
3.  提交代码
4.  新建 Pull Request