NanoRabbit: A C# repository from cxumol

About

NanoRabbit, A Lightweight RabbitMQ .NET API for .NET 6, which makes a simple way to manage Multiple connections, producers, consumers, and easy to use.

NanoRabbit is under development! Please note that some APIs may change their names or usage!

Building

Branch	Building Status
master
dev

Features

Customize the name of connections, producers, consumers.
Dependency injection available.
Multiple connections, producers, and consumers can be created.

Installation

You can get NanoRabbit by grabbing the latest NuGet package.

See Wiki for more details.

Version

NanoRabbit	RabbitMQ.Client
0.0.1, 0.0.2, 0.0.3, 0.0.4, 0.0.5, 0.0.6	6.5.0

Document

The NanoRabbit Document is at NanoRabbit Wiki.

QuickStart

NanoRabbit is designed as a library depends on NAMING Connections, Producers, Consumers. So it's important to set a UNIQUE NAME for each Connections, Producers, Consumers.

For more, please visit the Examples.

Register a Connection

var pool = new RabbitPool(config => { config.EnableLogging = true; });
pool.RegisterConnection(new ConnectOptions("Connection1", option =>
{
    option.ConnectConfig = new(config =>
    {
        config.HostName = "localhost";
        config.Port = 5672;
        config.UserName = "admin";
        config.Password = "admin";
        config.VirtualHost = "FooHost";
    });
    option.ProducerConfigs = new List<ProducerConfig>
    {
        new ProducerConfig("FooFirstQueueProducer", c =>
        {
            c.ExchangeName = "FooTopic";
            c.RoutingKey = "FooFirstKey";
            c.Type = ExchangeType.Topic;
        })
    };
    option.ConsumerConfigs = new List<ConsumerConfig>
    {
        new ConsumerConfig("FooFirstQueueConsumer", c => { c.QueueName = "FooFirstQueue"; })
    };
}));

Simple Publish

After registering the RabbitPool, you can simply publish a message by calling NanoPublish<T>().

Task publishTask = Task.Run(() =>
{
    while (true)
    {
        pool.NanoPublish<string>("Connection1", "FooFirstQueueProducer", "Hello from SimplePublish<T>()!");
        Console.WriteLine("Sent to RabbitMQ");
        Thread.Sleep(1000);
    }
});
Task.WaitAll(publishTask);

There is also a easy-to-use RabbitProducer, which used to publish messages without ConnectionName and ProducerConfig, for more, read Wiki.

Simple Consume

After registering the RabbitPool, you can simply consume a message by calling NanoConsume<T>().

Task consumeTask = Task.Run(() =>
{
    while (true)
    {
        pool.NanoConsume<string>("Connection1", "FooFirstQueueConsumer",
            msg => { Console.WriteLine($"Received: {msg}"); });
        Thread.Sleep(1000);
    }
});
Task.WaitAll(consumeTask);

There is also a easy-to-use RabbitConsumer, which used to consume messages without ConnectionName and ProducerConfig, for more, read Wiki.

Forward messages

Sometimes we have to consume messages from Foo RabbitMQ and publish the same message to Bar RabbitMQ, NanoRabbit provides a simple method to forward message, using the method called NanoForward<T>().

Task forwardTask = Task.Run(() =>
{
     while (true)
     {
         pool.NanoForward<string>("Connection1", "FooFirstQueueConsumer", "Connection2", "FooQueueProducer");
         Thread.Sleep(1000);
     }
});
Task.WaitAll(forwardTask);

DependencyInjection

HostApplicationBuilder builder = Host.CreateApplicationBuilder(args);

// Configure the RabbitMQ Connection
builder.Services.AddRabbitPool(
    globalConfig => { globalConfig.EnableLogging = true; },
    c =>
    {
        c.Add(new ConnectOptions("Connection1", option =>
        {
            option.ConnectConfig = new(config =>
            {
                config.HostName = "localhost";
                config.Port = 5672;
                config.UserName = "admin";
                config.Password = "admin";
                config.VirtualHost = "FooHost";
            });
            option.ProducerConfigs = new List<ProducerConfig>
            {
                new ProducerConfig("FooFirstQueueProducer", c =>
                {
                    c.ExchangeName = "FooTopic";
                    c.RoutingKey = "FooFirstKey";
                    c.Type = ExchangeType.Topic;
                })
            };
            option.ConsumerConfigs = new List<ConsumerConfig>
            {
                new ConsumerConfig("FooFirstQueueConsumer", c => { c.QueueName = "FooFirstQueue"; })
            };
        }));

        c.Add(new ConnectOptions("Connection2", option =>
        {
            // ...
        }));
    });

Then, you can use IRabbitPool at anywhere.

More DI Usage at Wiki.

Contributing

Fork this repository.
Create a new branch in you current repos from the dev branch.
Push commits and create a Pull Request (PR) to NanoRabbit.

Todo

Thanks

License

NanoRabbit is licensed under the MIT license.

cxumol/NanoRabbit