Zyx.MemoryMQ 1.0.7

用法

• 首先在Services上配置 AddMemoryMQ()
• 然后在中间件中使用 UseMemoryMQ()
• 在要接受处理消息的地方 继承IBus<> 接口
• 在要用到发布消息的地方 先将 IProducer 注入到构造函数中 使用 PublishAsync() 方法发布到消息队列中 消息队列根据 IBus<> 的 topic 进行消息分发(使用多线程同时处理) 发布和接受类型不一致时会提示错误

builder.Services.AddMemoryMQ();

app.UseMemoryMQ();

// 支持构造函数注入
// 当要订阅多个topic时 使用Subscribe特性
public class TestBus : IBus<Test>
{
  public string topic => "123/456";

  private readonly ILogger<TestBus> logger;

  public TestBus(ILogger<TestBus> logger)
  {
    this.logger = logger;
  }

  [Subscribe("123")]
  public Task HandlerAsync(Test data)
  {
    logger.LogInformation("我是TestBus:  " + data.Name);
    return Task.CompletedTask;
  }
}

public class Test
{
  public string Name { get; set; }
}

// 构造函数注入 IProducer 对象
await producer.PublishAsync("123/456",new Test(){Name = name});