Quick.RabbitMQPlus.Furion 1.0.7

1、🍹更新日志

• 1.0.7

  • 去掉了必须要设置实体特性的控制（如果没有实体特性，那么就需要在配置文件中将相关属性配置齐全），默认使用的是配置中的第一个配置；

  • 在路由模式下，可指定将消息发送到对应的队列中，需要配置QueueNames和RouteKeys的集合数量保持一一对应的关系；

  • Send方法增加了第二个参数，路由Key名称；

  • 实例化对象的方法Instance增加了参数Instance(bool isReceive = false)，当前实例化对象是否为接收消息。

• 1.0.6

  • 新增加了可动态切换连接的方法ChangeConn；

  • 去掉了Furion的依赖；

  • 去掉了Newtonsoft.Json的依赖；

  • 同时将原来的Quick.RabbitMQPlus分为了Quick.RabbitMQPlus和Quick.RabbitMQPlus.Furion这两个版本。

2、🍟Quick.RabbitMQPlus.Furion使用说明

该组件是基于RabbitMQ.Client和Furion组件进行封装使用的，目的在于集合.Net Core更快、更简单和更灵活的使用RabbitMQ！！！

功能说明：

• 支持发布订阅模式、路由模式,通配符模式和Headers属性模式；

• 可根据配置文件读取RabbitMQ连接的各个配置（如：RabbitMQ服务地址、账号、密码和交换机名称等）；

• 支持配置多个RabbitMQ的连接配置；

• 支持动态切换RabbitMQ的连接配置；

• 可根据实体定义的特性发布和订阅消息；

• 支持配置将多个队列绑定到交换机；

• 一个消费端支持可以同时消费多个多列的消息等；

• 支持使用同一个实体，将不同的消息发送到不同的队列中（使用路由模式，同时在发送的时候将路由Key传入）。

3、🍖安装

安装命令如下所示：

Install-Package Quick.RabbitMQPlus.Furion

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,
                "ExchangeType": "fanout",
                "ExchangeName": "TestExchangeName",
                "QueueNames": [ "TestRabbitMQName1", "TestRabbitMQName2" ],
                "RouteKey": "TestRouteKey",
                "ExchangeDurable": true,
                "QueueDurable": true,
                "MessageDurable": true
            },
            {
                "ConnId": 2,
                "UserName": "admin",
                "Password": "123456",
                "HostName": "192.168.3.2",
                "Port": 5672,
                "ExchangeType": "fanout",
                "ExchangeName": "TestExchangeName",
                "QueueNames": [ "TestRabbitMQName1", "TestRabbitMQName2" ],
                "RouteKey": "TestRouteKey",
                "ExchangeDurable": true,
                "QueueDurable": true,
                "MessageDurable": true
            }
        ]
    }
}

配置说明（消费端通用）：

4.2、🍞配置Program.cs

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

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

4.3、🧀定义发送消息实体

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

namespace Quick.RabbitMQPlus.Publisher
{
    [QuickRabbitMQPlusConfig(
        connId: 2,
        exchangeType: "fanout",
        exchangeName: "TestExchangeName",
        queueName: "TestRabbitMQName1,TestRabbitMQName2",
        routeKey: "TestExchangeName",
        exchangeDurable: 1,
        queueDurable: 1,
        messageDurable: 1)]
    public class TestRabbitMQModel
    {
        public int UserId { get; set; }

        public string UserName { get; set; }

        public int UserAge { get; set; }

        public DateTime CreateTime { get; set; }
    }
    
    //或者
    [QuickRabbitMQPlusConfig(connId: 2)]
    public class TestRabbitMQModel
    {
        public int UserId { get; set; }

        public string UserName { get; set; }

        public int UserAge { get; set; }

        public DateTime CreateTime { get; set; }
    }
    
    //或者
    //如果此时不要实体属性，那么就需要在配置文件中将需要的各个配置都配置齐全
    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

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

发送单条消息（fanout模式）：

//定义发送对象
var sendInstance = QuickRabbitMQPlusInstance<TestRabbitMQModel>.Instance();

//发送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 sendInstance.Send(msgModel);

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

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

//消息发送完成后，关闭通道
sendInstance.Close();

发送单条消息（direct模式）：

//当i % 2为0时，发送给路由TestRouteKey1对应的队列TestRabbitMQName1，否则发送给路由TestRouteKey2对应的队列TestRabbitMQName2
//此处就实现了在路由模式下，将不同的消息发送给不同的队列
//需要注意的时候，此方式需要将交换机类型配置为direct路由模式，同时需要设置配置的QueueNames和RouteKeys属性（这两属性的集合数量需要保持一致，一一对应的关系）
var sendRet = await _sendInstance.Send(msgModel, i % 2 == 0 ? "TestRouteKey1" : "TestRouteKey2");

发送单条消息（direct模式对应的配置）：

{
    "QuickRabbitMQPlus": {
        "QuickRabbitMQPlusConfigs": [
            {
                "ConnId": 1,
                "UserName": "admin",
                "Password": "123456",
                "HostName": "192.168.3.1",
                "Port": 5672,
                "ExchangeType": "direct",
                "ExchangeName": "TestExchangeName",

                //TestRouteKey1对应的是队列TestRabbitMQName1，TestRouteKey2对应的是队列TestRabbitMQName2
                "QueueNames": [ "TestRabbitMQName1", "TestRabbitMQName2" ],
                "RouteKeys": [ "TestRouteKey1", "TestRouteKey2" ] //ExchangeType=direct才起作用，并且和QueueNames一一对应
            }
        ]
    }
}

发送多条消息：

var sendList = new List<TestRabbitMQModel>{
	new TestRabbitMQModel(),
	new TestRabbitMQModel()
};

var sendRet = await sendInstance.Send(sendList);

切换连接：

//切换到connId=2的配置
_sendInstance.ChangeConn(2);

var sendRetConn2 = await _sendInstance.Send(msgModel);

//切换到connId=3的配置
_sendInstance.ChangeConn(3);

var sendRetConn3 = await _sendInstance.Send(msgModel);

5、🥪消费端

5.1、🍝配置appsettings.json

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

{
    "QuickRabbitMQPlus": {
        "QuickRabbitMQPlusConfigs": [
            {
                "ConnId": 1,
                "UserName": "admin",
                "Password": "123456",
                "HostName": "192.168.3.1",
                "Port": 5672,
                "ExchangeType": "fanout",
                "ExchangeName": "TestExchangeName",
                //"QueueNames": [ "TestRabbitMQName1", "TestRabbitMQName2" ],
                "RouteKey": "TestRouteKey",
                //"ExchangeDurable": true,
                //"QueueDurable": true,
                //"MessageDurable": true
            },
            {
                "ConnId": 1,
                "UserName": "admin",
                "Password": "123456",
                "HostName": "192.168.3.2",
                "Port": 5672,
                "ExchangeType": "fanout",
                "ExchangeName": "TestExchangeName",
                //"QueueNames": [ "TestRabbitMQName1", "TestRabbitMQName2" ],
                "RouteKey": "TestRouteKey",
                //"ExchangeDurable": true,
                //"QueueDurable": true,
                //"MessageDurable": true
            }
        ]
    }
}

配置说明：

配置说明请参见生产端的具体说明，需要注意的是，如果消费端中的QueueNames属性或者实体特性queueName设置了多个队列，就代表这一个消费端同时接收多个队列的消息

5.2、🌮配置Program.cs

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

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

5.3、🧆定义接收消息实体

如下所示我们可以定义3个消息实体（第一个用于接收队列TestRabbitMQName1的消息，第二个用于接收队列TestRabbitMQName2的消息，第三个用于接收队列TestRabbitMQName1和TestRabbitMQName2）：

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

        public string UserName { get; set; }

        public int UserAge { get; set; }

        public DateTime CreateTime { get; set; }
    }
}

namespace Quick.RabbitMQPlus.Consumer
{
    [QuickRabbitMQPlusConfig(connId: 2, queueName: "TestRabbitMQName2")]
    public class TestRabbitMQModel2
    {
        public int UserId { get; set; }

        public string UserName { get; set; }

        public int UserAge { get; set; }

        public DateTime CreateTime { get; set; }
    }
}

namespace Quick.RabbitMQPlus.Consumer
{
    [QuickRabbitMQPlusConfig(connId: 2, queueName: "TestRabbitMQName1,TestRabbitMQName2")]
    public class TestRabbitMQModel3
    {
        public int UserId { get; set; }

        public string UserName { get; set; }

        public int UserAge { get; set; }

        public DateTime CreateTime { get; set; }
    }
}

实体特性配置说明：

实体特性配置说明请参见生产端的具体说明。

5.4、🍨接收消息Demo

定义两个消费端，一个消费端消费一个队列，具体的接收消息代码如下所示（接收单条消息）：

//接收队列1的消息
var retRec1 = await QuickRabbitMQPlusInstance<TestRabbitMQModel1>.Instance().Receive(async (data, msg) =>
{
    await Task.Delay(1000);

    Console.ForegroundColor = ConsoleColor.Green;
    Console.WriteLine($"\r\n队列1消息：{msg}");

    //返回true代表业务逻辑处理成功，会告知MQ这条消息已经接收成功，会从MQ队列中删除
    //返回false代表业务逻辑处理失败，会告知MQ这条消息没有处理成功，则MQ会继续推送这条消息
    return true;
}, 1);
if (!retRec1.Item1)
{
    Console.ForegroundColor = ConsoleColor.Red;
    Console.WriteLine($"\r\n队列1接收失败：{retRec1.Item2}");
}

//接收队列2的消息
var retRec2 = await QuickRabbitMQPlusInstance<TestRabbitMQModel2>.Instance().Receive(async (data, msg) =>
{
    await Task.Delay(2500);

    Console.ForegroundColor = ConsoleColor.Magenta;
    Console.WriteLine($"\r\n队列2消息：{msg}");

    //返回true代表业务逻辑处理成功，会告知MQ这条消息已经接收成功，会从MQ队列中删除
    //返回false代表业务逻辑处理失败，会告知MQ这条消息没有处理成功，则MQ会继续推送这条消息
    return true;
});
if (!retRec2.Item1)
{
    Console.ForegroundColor = ConsoleColor.Red;
    Console.WriteLine($"\r\n队列2接收失败：{retRec2.Item2}");
}

定义一个消费端，同时消费两个队列，具体的接收消息代码如下所示（接收单条消息）：

//接收队列1的消息
var retRec = await QuickRabbitMQPlusInstance<TestRabbitMQModel3>.Instance().Receive(async (data, msg) =>
{
    await Task.Delay(1000);

    Console.ForegroundColor = ConsoleColor.Green;
    Console.WriteLine($"\r\n队列1、2消息：{msg}");

    //返回true代表业务逻辑处理成功，会告知MQ这条消息已经接收成功，会从MQ队列中删除
    //返回false代表业务逻辑处理失败，会告知MQ这条消息没有处理成功，则MQ会继续推送这条消息
    return true;
}, 1);
if (!retRec.Item1)
{
    Console.ForegroundColor = ConsoleColor.Red;
    Console.WriteLine($"\r\n队列1、2接收失败：{retRec.Item2}");
}

如果需要接收多条消息，请使用Receives方法：

//接收队列1的消息
var retRec = await QuickRabbitMQPlusInstance<TestRabbitMQModel3>.Instance().Receives(async (dataList, msg) =>
{
	//此处的dataList为List<TestRabbitMQModel3>
	
    return true;
}, 1);

注意：

如果是路由模式direct，需要在实例化对象方法中传入true，如下所示：

var retRec = await QuickRabbitMQPlusInstance<TestRabbitMQModel1>.Instance(true).……

5.5、🍱预览效果

<div style="background:#000;padding:10px;"> <div><font color="DarkCyan">####消费端已启动####</div></br> <div><font color="Green">队列1消息：{"UserId":8739,"UserName":"CCCC1","UserAge":40,"CreateTime":"2022-09-06 10:44:37"}</div></br> <div><font color="Magenta">队列2消息：{"UserId":8739,"UserName":"CCCC1","UserAge":40,"CreateTime":"2022-09-06 10:44:37"}</div></br> <div><font color="Green">队列1消息：{"UserId":8646,"UserName":"CCCC2","UserAge":54,"CreateTime":"2022-09-06 10:44:39"}</div></br> <div><font color="Magenta">队列2消息：{"UserId":8646,"UserName":"CCCC2","UserAge":54,"CreateTime":"2022-09-06 10:44:39"}</div></br> <div><font color="Magenta">队列2消息：{"UserId":1966,"UserName":"CCCC3","UserAge":21,"CreateTime":"2022-09-06 10:44:41"}</div></br> <div><font color="Green">队列1消息：{"UserId":1966,"UserName":"CCCC3","UserAge":21,"CreateTime":"2022-09-06 10:44:41"}</div></br> <div><font color="Magenta">队列2消息：{"UserId":8349,"UserName":"CCCC4","UserAge":25,"CreateTime":"2022-09-06 10:44:43"}</div></br> <div><font color="Green">队列1消息：{"UserId":8349,"UserName":"CCCC4","UserAge":25,"CreateTime":"2022-09-06 10:44:43"}</div></br> <div><font color="Magenta">队列2消息：{"UserId":3770,"UserName":"CCCC5","UserAge":31,"CreateTime":"2022-09-06 10:44:45"}</div></br> <div><font color="Green">队列1消息：{"UserId":3770,"UserName":"CCCC5","UserAge":31,"CreateTime":"2022-09-06 10:44:45"}</div></br> </div>

6、🥙Quick.RabbitMQPlus方法

• 首先声明Quick.RabbitMQPlus的实例化对象：

  声明发送实例：

  var mqInstance = QuickRabbitMQPlusInstance<T>.Instance();
  

  声明接收实例，并且交换机类型为路由模式：

  var mqInstance = QuickRabbitMQPlusInstance<T>.Instance(true);
  

• 其次就可以使用使用该实例化对象中的发送和接收方法了，具体说明如下所示：

  方法名称	方法说明	方法参数	备注
  Send	发送消息方法，支持单条消息和多条消息的发送	(data,routeKey)	方法的第一个参数data可以为T或List<T><br />方法的第二个参数为路由名称（当交换机类型为路由模式的时候，该参数起作用，如可以实现使用同一个实体将不同的消息发送到不同的队列中）
  Receive	接收消息（单条消息）	(received, prefetchCount)	方法的第一个参数为回调函数，该回调函数包含2个返回数据（第一个为T，第二个为T对应的字符串），并且该回调函数需要返回bool类型（以便告诉RabbitMQ服务该消息是否处理成功）；<br />方法的第二个参数为设置RabbitMQ一次最多推送多少条消息给消费者，默认为10
  Receives	接收消息（多条消息）	(received, prefetchCount)	方法的第一个参数为回调函数，该回调函数包含2个返回数据（第一个为List<T>，第二个为List<T>对应的字符串），并且该回调函数需要返回bool类型（以便告诉RabbitMQ服务该消息是否处理成功）；<br />方法的第二个参数为设置RabbitMQ一次最多推送多少条消息给消费者，默认为10
  ChangeConn	切换连接（切换配置文件中某个连接配置）	(connId)	方法参数connId为int类型，即与配置和实体特性中的ConnId保持一致
  Close	关闭连接	()	注意，如果调用了该方法，又想重新使用实例化对象mqInstance发送或接收消息，需要重新实例化该对象。

7、🍟Quick.RabbitMQPlus使用说明

Quick.RabbitMQPlus组件的使用方式和Quick.RabbitMQPlus.Furion组件完全一致（包括配置、实体特性和方法等），唯一不同的就是Quick.RabbitMQPlus.Furion需要在启动程序中注册RabbitMQ连接配置对象（builder.Services.AddConfigurableOptions<QuickRabbitMQPlusOptions>();）。