Biotekno.RabbitMq 8.1.1

Biotekno.RabbitMq

Türkçe Açıklama

Biotekno.RabbitMq, .NET 8 projelerinde RabbitMQ ile kolayca publish ve consume işlemleri yapmanızı sağlayan, performanslı ve esnek bir NuGet paketidir. Object pooling desteği ile yüksek performanslı mesajlaşma altyapısı sunar.

Kurulum

NuGet üzerinden yükleyin: dotnet add package Biotekno.RabbitMq

appsettings.json Örneği

"RabbitMqSettings": { "Connections": { "DefaultConnection": { "HostName": "localhost", "UserName": "guest", "Password": "guest", "Port": 5672, "VirtualHost": "/", "RequestedHeartbeat": 60, "SslOptionConfigs": { "Enabled": false, "Path": "certPath.p12", "Password": "certPassword" } } }, "ConsumerSettings": [ { "Connections": ["DefaultConnection"], "Queue": "test-queue", "ConsumerCount": 1, "Exchange": "test-exchange", "PrefetchCount": 10, "RetryCount": 3 } ] }

Program.cs Entegrasyonu

builder.Services.AddBioteknoRabbitMqServices(builder.Configuration);

Publish Kullanımı

public class MyService { private readonly IMessagePublisher _publisher; public MyService(IMessagePublisher publisher) { _publisher = publisher; } public void Publish() { var data = new { Id = 1, Name = "Test" }; _publisher.PublishMessage(data, "test-queue", "test-exchange"); } }

Consume Kullanımı

Consumer için kendi BackgroundService veya Worker sınıfınızı oluşturup IMessageConsumer arayüzünü kullanabilirsiniz.

English Description

Biotekno.RabbitMq is a high-performance and flexible NuGet package for .NET 8 projects to easily publish and consume messages with RabbitMQ. It provides object pooling for efficient channel management.

Installation

Install via NuGet: dotnet add package Biotekno.RabbitMq

appsettings.json Example

"RabbitMqSettings": { "Connections": { "DefaultConnection": { "HostName": "localhost", "UserName": "guest", "Password": "guest", "Port": 5672, "VirtualHost": "/", "RequestedHeartbeat": 60, "SslOptionConfigs": { "Enabled": false, "Path": "certPath.p12", "Password": "certPassword" } } }, "ConsumerSettings": [ { "Connections": ["DefaultConnection"], "Queue": "test-queue", "ConsumerCount": 1, "Exchange": "test-exchange", "PrefetchCount": 10, "RetryCount": 3 } ] }

Program.cs Integration

builder.Services.AddBioteknoRabbitMqServices(builder.Configuration);

Publish Usage

public class MyService { private readonly IMessagePublisher _publisher; public MyService(IMessagePublisher publisher) { _publisher = publisher; } public void Publish() { var data = new { Id = 1, Name = "Test" }; _publisher.PublishMessage(data, "test-queue", "test-exchange"); } }

Consume Usage

For consumers, implement your own BackgroundService or Worker class using the IMessageConsumer interface.

Daha fazla bilgi için kaynak kodu inceleyebilirsiniz. / For more details, see the source code.