Sindika.AspNet.Connection 1.5.4

Sindika.AspNet.Connection

Sindika.AspNet.Connection is a .NET library designed to simplify and standardize connection management for various services such as Citus, Kafka, PostgreSQL, RabbitMQ, and Redis. It provides robust tools to configure, validate, and manage these connections efficiently.

Features

• Citus Connection Management:

  • Simplified connection setup for Citus DB.
  • Health checks to ensure availability and performance.
  • Configurable settings for database tuning.

• Kafka Integration:

  • Streamlined connection handling for Kafka brokers.
  • Support for producer and consumer setup.

• PostgreSQL Support:

  • Easy-to-configure connection for PostgreSQL databases.
  • Built-in health checks and validation.

• RabbitMQ Support:

  • Efficient connection management for RabbitMQ messaging.
  • Support for queues and message validation.

• Redis Integration:

  • Configurable connection settings for Redis caching and data storage.
  • Supports connection pooling and health checks.

Usage

Citus Connection

1. Configuration: Use CitusSettings.cs to define the necessary settings for connecting to the Citus database.

   var settings = new CitusSettings
   {
       Host = "localhost",
       Port = 5432,
       Database = "my_database",
       Username = "user",
       Password = "password"
   };
   

2. Connection Manager: Use CitusConnectionManager to establish and manage the connection.

   var manager = new CitusConnectionManager(settings);
   var connection = manager.GetConnection();
   

3. Health Check: Ensure the connection is healthy using CitusHealthChecker.

   var healthChecker = new CitusHealthChecker();
   bool isHealthy = healthChecker.CheckHealth(connection);
   

RabbitMQ

1. RabbitMQ Configuration in appsettings.json

To connect the application with RabbitMQ, add the following configuration in appsettings.json or appsettings.Development.json:

"RabbitmqSettings": {
    "HostName": "rabbitmq-host",
    "Port": 5672,
    "UserName": "rabbitmq-username",
    "Password": "rabbitmq-password"
}

Note:

• Replace rabbitmq-host, rabbitmq-username, rabbitmq-password with the appropriate RabbitMQ address.
• Do not store sensitive credentials in the code. Use environment variables or secret manager if needed.

2. Register RabbitMQ in Program.cs

Add the following code in Program.cs to configure RabbitMQ:

using Sindika.AspNet.Connection.Rabbitmq;

var builder = WebApplication.CreateBuilder(args);

var Configuration = builder.Configuration;
Configuration.AddEnvironmentVariables();

// Register RabbitMQ Extensions
builder.Services.AddRabbitMQ(Configuration);

3. Using RabbitMQ Service

Example how to use RabbitmqService

public class OrderService
{
    private readonly RabbitmqService _rabbitmqService;
    
    public OrderService(RabbitmqService rabbitmqService)
    {
        _rabbitmqService = rabbitmqService;
    }
    
    public async Task SendMessageAsync()
    {
        var exchangeConfig = new RabbitmqExchangeConfig
        {
            Name = "order-exchange",
            Type = ExchangeType.Direct,
            Durable = true
        };

        var routingKey = "order.created";
        var message = "New order placed";
        
        await _rabbitmqService.PublishMessageAsync(exchangeConfig, routingKey, message);
    }
}

Future Plans

• Add implementation for Kafka connection management.
• Extend PostgreSQL, RabbitMQ, and Redis connection support.
• Provide detailed examples for each service.
• Include performance optimization tools.