# Aix.MessageBus

**Repository Path**: aix01/Aix.MessageBus

## Basic Information

- **Project Name**: Aix.MessageBus
- **Description**: Messbus封装
- **Primary Language**: C#
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2021-04-21
- **Last Updated**: 2021-04-21

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# Aix.MessageBus
### 程序启动参考Sample
发布和订阅消息支持分布式部署

### 1 配置kafka信息,参考Sample
### 2 启动服务，参考Sample

### 3 发布消息
```
 var messageData = new KafkaMessage { MessageId = i.ToString(), Content = $"我是内容_{i}", CreateTime = DateTime.Now };
  await _messageBus.PublishAsync(messageData);
 ```
  
### 4 订阅消息 根据泛型类型区分不同类型的订阅
```
   await _messageBus.SubscribeAsync<KafkaMessage>(async (message) =>
   {
       var current = Interlocked.Increment(ref Count);
       Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss fff")}消费数据：MessageId={message.MessageId},Content=                         {message.Content},count={current}");
       await Task.CompletedTask;
   });
  ```