Peak.Lib.RabbitMQ
1.0.3
dotnet add package Peak.Lib.RabbitMQ --version 1.0.3
NuGet\Install-Package Peak.Lib.RabbitMQ -Version 1.0.3
<PackageReference Include="Peak.Lib.RabbitMQ" Version="1.0.3" />
paket add Peak.Lib.RabbitMQ --version 1.0.3
#r "nuget: Peak.Lib.RabbitMQ, 1.0.3"
// Install Peak.Lib.RabbitMQ as a Cake Addin #addin nuget:?package=Peak.Lib.RabbitMQ&version=1.0.3 // Install Peak.Lib.RabbitMQ as a Cake Tool #tool nuget:?package=Peak.Lib.RabbitMQ&version=1.0.3
**1、生产者**
```
var publisher = new RabbitMQPublisher("127.0.0.1", 5672, "admin", "admin");
while (true)
{
//生产信息
bool ispublish = publisher.Publish("通道值", "通道名称");
bool ispublish = publisher.Publish<T>(T);
Thread.Sleep(1);
}
//关闭生产者
publisher.CloseAt();
```
**2、消费者-订阅**
```
var publisher = new RabbitMQSubscriber("127.0.0.1", 5672, "admin", "admin");
publisher.Subscribe("通道名称", (data, deliverytag) =>
{
Console.WriteLine(data);
//信息处理完毕删除该信息
publisher._channel.BasicAck(deliverytag, false);
});
//关闭消费者
publisher.CloseAt();
```
**3、多线程消费者-订阅**
此功能无关闭功能,启动线程数多的时候,会提示链接RabbitMQ失败,无需理会,一会会自动链接成功
```
TaskRabbitMQ rabbitMQ = new TaskRabbitMQ("127.0.0.1", 5672, "admin", "admin", 20, true);
rabbitMQ.Subscribe("通道名称", (data, deliverytag) => {
Console.WriteLine($" 接收:{data}");
deliverytag(false);//此功能是处理完业务是否保留队列中
});
```
**4、Appsetting.json配置**
如果手动传参,这里就无需配置
```
//RabbitMQ客户端
"RabbitMQ": {
//客户端地址
"IP": "127.0.0.1",
//端口
"Port": 5672,
//用户名
"UserName": "admin",
//用户密码
"PassWord": "admin"
},
```
Product | Versions Compatible and additional computed target framework versions. |
---|---|
.NET | net5.0 was computed. net5.0-windows was computed. net6.0 was computed. 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. |
.NET Core | netcoreapp3.0 was computed. netcoreapp3.1 was computed. |
.NET Standard | netstandard2.1 is compatible. |
MonoAndroid | monoandroid was computed. |
MonoMac | monomac was computed. |
MonoTouch | monotouch was computed. |
Tizen | tizen60 was computed. |
Xamarin.iOS | xamarinios was computed. |
Xamarin.Mac | xamarinmac was computed. |
Xamarin.TVOS | xamarintvos was computed. |
Xamarin.WatchOS | xamarinwatchos was computed. |
-
.NETStandard 2.1
- Peak.Lib.Basics (>= 1.0.6)
- RabbitMQ.Client (>= 6.5.0)
NuGet packages
This package is not used by any NuGet packages.
GitHub repositories
This package is not used by any popular GitHub repositories.