Home

RabbitMQ.EventBus.AspNetCore

使用方法

在asp.net core中

public IServiceProvider ConfigureServices(IServiceCollection services)
{
    services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_1);
    services.AddRabbitMQEventBus("amqp://guest:guest@192.168.0.252:5672/", eventBusOptionAction: eventBusOption =>
    {
        eventBusOption.ClientProvidedAssembly("RabbitMQEventBusTest");
        eventBusOption.EnableRetryOnFailure(true, 5000, TimeSpan.FromSeconds(30));
    }); 
    services.AddButterfly(butterfly =>
    {

        butterfly.CollectorUrl = "http://192.168.0.252:6401";
        butterfly.Service = "RabbitMQEventBusTest";
    });
    return services.BuildServiceProvider();
}
public void Configure(IApplicationBuilder app, IHostingEnvironment env, IServiceTracer tracer)
{
    //自动订阅
    app.RabbitMQEventBusAutoSubscribe();
    app.RabbitMQEventBusModule(moduleOptions =>
    {
        moduleOptions.AddButterfly(tracer);
    });
}

订阅处理方法

[EventBus(Exchange = "dev.ex.temp.topic", RoutingKey = "send.message")]
public class Person : IEvent
{
    public string Name { set; get; }
}
public class PersonHandler : IEventHandler<Person >
{
    public Task Handle(Person message)
    {
        Console.WriteLine($"收到消息:{message.Name}");
        return Task.CompletedTask;
    }
}

发送消息

[Route("api/v1/[controller]")]
public class IndexController : Controller
{
   private readonly IRabbitMQEventBus _eventbus;
   public IndexController(IRabbitMQEventBus eventbus)
   {
      _eventbus= eventbus?? throw new ArgumentNullException(nameof(eventbus));
   }
   [HttpPost]
   public async Task<IActionResult> Send()
   {
      _eventbus.Publish( new { Name = "Hello RabbitMQ" },  "dev.ex", "send.message");
   }
}