Quick.RabbitMQPlus 1.0.1

There is a newer version of this package available.
See the version list below for details.
dotnet add package Quick.RabbitMQPlus --version 1.0.1
NuGet\Install-Package Quick.RabbitMQPlus -Version 1.0.1
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package.
<PackageReference Include="Quick.RabbitMQPlus" Version="1.0.1" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add Quick.RabbitMQPlus --version 1.0.1
#r "nuget: Quick.RabbitMQPlus, 1.0.1"
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package.
// Install Quick.RabbitMQPlus as a Cake Addin
#addin nuget:?package=Quick.RabbitMQPlus&version=1.0.1

// Install Quick.RabbitMQPlus as a Cake Tool
#tool nuget:?package=Quick.RabbitMQPlus&version=1.0.1

1、🍟Quick.RabbitMQPlus使用说明

该组件是基于RabbitMQ.ClientFurion组件进行封装使用的,目的是为了结合.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"
            }
        ]
    }
}

配置说明:

属性名称 属性说明 是否必填 备注
ConnId 连接配置Id 需要和QuickRabbitMQPlusQueueName特性中的ConnId一致
UserName RabbitMQ连接账户
Password RabbitMQ连接密码
HostName RabbitMQ连接IP
Port RabbitMQ连接端口
ExchangeName 交换机名称
QueueNames 队列名称集合(与交换机ExchangeName进行绑定),如果同时设置了实体特性的队列名称集合,那么会优先采用实体的队列集合 此处为集合,目的是在发布消息时将消息存储到该队列集合中去
RouteKey 路由名称

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; }
    }
}

实体特性配置说明:

属性名称 属性说明 是否必填 备注
ConnId 连接配置Id 需要和配置文件中的ConnId一致
ExchangeName 交换机名称
QueueName 队列名称(多个队列名称请使用逗号,分隔),如果同时设置了实体特性的队列名称和配置中的_QueueNames_属性,那么会优先采用实体的队列名称
RouteKey 路由名称

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}");
});
Product Compatible and additional computed target framework versions.
.NET net6.0 is compatible.  net6.0-android was computed.  net6.0-ios was computed.  net6.0-maccatalyst was computed.  net6.0-macos was computed.  net6.0-tvos was computed.  net6.0-windows was computed.  net7.0 was computed.  net7.0-android was computed.  net7.0-ios was computed.  net7.0-maccatalyst was computed.  net7.0-macos was computed.  net7.0-tvos was computed.  net7.0-windows was computed.  net8.0 was computed.  net8.0-android was computed.  net8.0-browser was computed.  net8.0-ios was computed.  net8.0-maccatalyst was computed.  net8.0-macos was computed.  net8.0-tvos was computed.  net8.0-windows was computed. 
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.

NuGet packages

This package is not used by any NuGet packages.

GitHub repositories

This package is not used by any popular GitHub repositories.

Version Downloads Last updated
1.0.10 783 12/30/2022
1.0.9 813 9/30/2022
1.0.8 832 9/28/2022
1.0.7 920 9/27/2022
1.0.6 879 9/21/2022
1.0.5 911 9/20/2022
1.0.4 844 9/11/2022
1.0.3 803 9/10/2022
1.0.2 853 9/6/2022
1.0.1 894 9/6/2022
1.0.0 886 9/5/2022