Silver.RabbitMQ
1.0.3
dotnet add package Silver.RabbitMQ --version 1.0.3
NuGet\Install-Package Silver.RabbitMQ -Version 1.0.3
<PackageReference Include="Silver.RabbitMQ" Version="1.0.3" />
paket add Silver.RabbitMQ --version 1.0.3
#r "nuget: Silver.RabbitMQ, 1.0.3"
// Install Silver.RabbitMQ as a Cake Addin #addin nuget:?package=Silver.RabbitMQ&version=1.0.3 // Install Silver.RabbitMQ as a Cake Tool #tool nuget:?package=Silver.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
- RabbitMQ.Client (>= 6.5.0)
- Silver.Basic (>= 1.0.0)
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.3 | 145 | 9/16/2023 |