NaiveMq.Client 1.0.0

NaiveMq

.NET Standard message queue server and client.

Implemented so far:

• All async client interface.
• Simple custom client-server messaging protocol.
• User management.
• Queue management, publish message, queue subscriptions and message consuming.
• Message publish/consume confirmation.
• Exchanges, routing with regex.
• Request-response messages with response from consumer passed to producer.
• Durable queues.
• Disk only messages for long queues with big message data.
• Queue limits by length or volume with server behaviour delay, reject or discard the message.
• Server memory limits manual/automatic.
• Management console applicaton.
• Message or any type of request batching.
• Clustering.

Plans:

• Release.
• Better clustering.
• Better durable queues.
• Management UI.
• Unit tests.
• Integration tests.

Performance vs RabbitMQ (3.10.12)

Configuration: server and client on the same pc, Intel Core i5-7200U, DDR3 Dual 16Gb, SSD.

Scenario: 10 queues, 1 consumer, 1 producer per queue.

* RabbitMq .NET Client eats up all memory, so the test is stable for about a minute. Then numbers are jumping around 5.000-10.000.

** Same as * and disk I/O is low, not sure the messages are persistent after all.

Scalability

Since in the cluster mode the node has its own messages then teoretically the queue performance should scale linearly by multiplying one node performance by number of nodes, provided the producers and consumers are spread evenly beetween the nodes or redirect option is selected in consumer subscription as cluster subscription strategy.

Client Example

var client = new NaiveMqClient(new NaiveMqClientOptions());

await client.SendAsync(new AddQueue("test", @try: true));

client.OnReceiveMessageAsync += Client_OnReceiveMessageAsync;

static async Task Client_OnReceiveMessageAsync(NaiveMqClient sender, Message message)
{
    Console.WriteLine($"Received: {Encoding.UTF8.GetString(message.Data.Span)}.");

    if (message.Confirm)
    {
        await sender.SendAsync(MessageResponse.Ok(message));
    };
}

await client.SendAsync(new Subscribe("test"));

for (int i = 0; i < 1000; i++)
{
    var text = $"{i}";    
    await client.SendAsync(new Message("test", Encoding.UTF8.GetBytes($"{i}")));

    Console.WriteLine($"Sent: {text}.");
    await Task.Delay(1000);
}

await client.SendAsync(new Unsubscribe("test"));

Requirements

• .NET Standard for Client and Service
• .NET 6 for Tests, Server and Management Console