Quick.RabbitMQPlus 1.0.0

1、🍟Quick.RabbitMQPlus使用说明

该组件是基于RabbitMQ.Client和Furion组件进行封装使用的，目的是为了结合.Net Core更简单的使用RabbitMQ！！！

功能说明：

• 可根据配置文件读取RabbitMQ连接的各个配置等；
• 可根据实体定义的特性发布和订阅消息等。

2、🍖安装

安装命令如下所示：

Install-Package Quick.RabbitMQPlus

3、🧀生产端

3.1、🥞配置appsettings.json

在appsettings.json配置文件中创建节点QuickRabbitMQPlus>QuickRabbitMQPlusConfigs，QuickRabbitMQPlusConfigs为数组类型（即可配置多个RabbitMQ服务地址），具体配置如下所示：

{
    "QuickRabbitMQPlus": {
        "QuickRabbitMQPlusConfigs": [
            {
                "ConnId": 1,
                "UserName": "admin",
                "Password": "123456",
                "HostName": "192.168.3.1",
                "Port": 5672,
                "ExchangeName": "TestExchangeName",
                "QueueNames": [ "TestRabbitMQName1", "TestRabbitMQName2" ],
                "RouteKey": "TestRouteKey"
            }
        ]
    }
}

配置说明：

3.2、🍞配置Program.cs

由于我们使用的是Furion，因此，我们可在程序启动文件中配置如下代码（具体可参考Furion入门指南）：

Serve.Run(RunOptions.DefaultSilence.ConfigureBuilder(builder =>
{
	//注册RabbitMQ连接配置对象
	builder.Services.AddConfigurableOptions<QuickRabbitMQPlusOptions>();
}).Configure(app =>
{
}));

3.3、🧀定义发送消息实体

如下所示我们可以定义一个消息实体：

namespace Quick.RabbitMQPlus.Publisher
{
    //[QuickRabbitMQPlusQueueName(1, "TestExchangeName", "TestRabbitMQName1")]
    [QuickRabbitMQPlusQueueName(connId: 1)]
    public class TestRabbitMQModel
    {
        public int UserId { get; set; }

        public string UserName { get; set; }

        public int UserAge { get; set; }

        public DateTime CreateTime { get; set; }
    }
}

实体特性配置说明：

3.4、🥐发送消息Demo

如下所示为具体的发送消息代码：

//发送10条数据
for (int i = 0; i < 10; i++)
{
	var msgModel = new TestRabbitMQModel
	{
		UserId = rand.Next(1, 9999),
		UserName = "Quick" + (i + 1),
		UserAge = rand.Next(20, 80),
		CreateTime = DateTime.Now
	};

	var sendRet = await QuickRabbitMQPlusInstance<TestRabbitMQModel>.Instance().Send(msgModel);

	if (sendRet.Item1)
	{
		//发送成功
	}
	else
	{
		//发送失败
		var errMsg = $"失败原因：{sendRet.Item2}";
	}

	//间隔2秒发送一次
	await Task.Delay(2000);
}

4、🥪消费端

4.1、🍝配置appsettings.json

在appsettings.json配置文件中创建节点QuickRabbitMQPlus>QuickRabbitMQPlusConfigs，QuickRabbitMQPlusConfigs为数组类型（即可配置多个RabbitMQ服务地址），具体配置如下所示：

{
    "QuickRabbitMQPlus": {
        "QuickRabbitMQPlusConfigs": [
            {
                "ConnId": 1,
                "UserName": "admin",
                "Password": "123456",
                "HostName": "192.168.3.1",
                "Port": 5672,
                "ExchangeName": "TestExchangeName",
                //"QueueNames": [ "TestRabbitMQName1", "TestRabbitMQName2" ],
                "RouteKey": "TestRouteKey"
            }
        ]
    }
}

4.2、🌮配置Program.cs

由于我们使用的是Furion，因此，我们可在程序启动文件中配置如下代码（具体可参考Furion入门指南）：

Serve.Run(RunOptions.DefaultSilence.ConfigureBuilder(builder =>
{
	//注册RabbitMQ连接配置对象
	builder.Services.AddConfigurableOptions<QuickRabbitMQPlusOptions>();
}).Configure(app =>
{
}));

4.3、🧆定义接收消息实体

如下所示我们可以定义一个消息实体：

namespace Quick.RabbitMQPlus.Consumer
{
    [QuickRabbitMQPlusQueueName(connId: 1, queueName: "TestRabbitMQName1")]
    public class TestRabbitMQModel
    {
        public int UserId { get; set; }

        public string UserName { get; set; }

        public int UserAge { get; set; }

        public DateTime CreateTime { get; set; }
    }
}

4.4、🍨接收消息Demo

如下所示为具体的接收消息代码：

var retRec = await QuickRabbitMQPlusInstance<TestRabbitMQModel>.Instance().Receive((data, msg) =>
{
    Console.ForegroundColor = ConsoleColor.Green;
    Console.WriteLine($"\r\n接收消息：{msg}");
});