RabbitMQ.Bus 0.0.1

使用方法

在asp.net core中

public IServiceProvider ConfigureServices(IServiceCollection services)
{
   services.AddMvc();
   services.AddSingleton(options =>
   {
       return new RabbitMQBusService(new RabbitMQConfig("amqp://guest:guest@172.0.0.1:5672/"));
   });
}
public void Configure(IApplicationBuilder app, IHostingEnvironment env, RabbitMQBusService busService)
{
   //订阅
   busService.Subscribe<PersonHandler, Person>("队列名");
}

订阅处理方法

public class PersonHandler : IRabbitMQBusHandler<Person>
{
    public Task Handle(Person obj)
    {
        Console.WriteLine($"收到消息:{obj.Name}");
        return Task.CompletedTask;
    }
}
public class Person
{
    public string Name { set; get; }
}

发送消息

[Route("api/v1/[controller]")]
public class IndexController : Controller
{
   private readonly RabbitMQBusService _rabbit;
   public IndexController(RabbitMQBusService rabbit)
   {
      _rabbit = rabbit ?? throw new ArgumentNullException(nameof(rabbit));
   }
   [HttpPost]
   public async Task<IActionResult> Send()
   {
      _rabbit.Publish("队列名", new { Name = "Hello RabbitMQ" });
   }
}