Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

wcx-cn/DistributedMessage4RabbitMQ

Repository files navigation

DistributedMessage4RabbitMQ

An open-source lightweight message bus library (RabbitMQ) that supports publish/subscribe and RPC.

nuget stats
nuget stats

Install DistributedMessage4RabbitMQ

You can install via NuGet:

Install-Package DistributedMessage4RabbitMQ
# Getting Started
## Add Service Support
```csharp 
services.AddDistributedMessage4RabbitMQ(configure =>
{
 configure.HostName = "localhost";
 configure.VirtualHost = "/";
 configure.Port = 5672;
 configure.UserName = "admin";
 configure.Password = "admin";
},
Assembly.GetExecutingAssembly());

Event Subscription

Define Event

public class HelloMessage : DistributedEventBase
{
 public string Message { get; set; }
}
or
[ExchangeDeclare("Hello")]
[QueueDeclare("Hello")]
[QueueBind("HelloMessage")]
public class HelloMessage : DistributedEventBase
{
 public string Message { get; set; } = default!;
}

Subscribe to Event

public class HelloMessageHandler : IDistributedEventHandler<HelloMessage>
{
 public async Task HandleAsync(HelloMessage message, CancellationToken cancellationToken)
 {
 Console.WriteLine("Hello");
 await Task.CompletedTask;
 }
}

Publish Event

await messageBus.PublishAsync(new HelloMessage() { Message = "Hello" });
or 
var hello = new HelloMessage()
{
 Message = "Hello World"
};
hello.Metadata.AddMessageHeader("key1", "value");
messageBus.PublishAsync(hello);

Event Wrapper Subscription

Define Wrapped Data

public class WrappedData 
{
 public string Message { get; set; }
}

Subscribe to Event

public class DistributedEventWrapperHandler : IDistributedEventHandler<DistributedEventWrapper<WrappedData>>
{
 public async Task HandleAsync(DistributedEventWrapper<WrappedData> eventData, CancellationToken cancellationToken = default)
 {
 await Task.CompletedTask;
 Console.WriteLine("DistributedEventWrapper");
 }
}

Publish Event

await messageBus.PublishAsync(new WrappedData());

3、RPC Request

Define Request

public class Ping : IRpcRequest<Pong>
{
 public string SendBy { get; set; }
}

Define Response

 public class Pong
 {
 public string ReplyBy { get; set; }
 }

Subscribe to Request

 public class PingHandler : IRpcRequestHandler<Ping, Pong>
 {
 public Task<Pong> HandleAsync(Ping message, CancellationToken cancellationToken = default)
 {
 Console.WriteLine("Ping");
 return Task.FromResult(new Pong() { ReplyBy = "B" });
 }
 }

Send Request

var pongMessage = messageBus.SendAsync(ping);

4、Dead Letter

Define Message

[QueueBind("HelloMessage", QueueName = "Hello")]
[DeadLetter(messageType: typeof(HelloMessageDeadLetter))]
public class HelloMessage : DistributedEventBase
{
 public string Message { get; set; } = default!;
}

Define Dead Letter Message

[QueueBind("HelloMessageDeadLetter", QueueName = "HelloDeadLetter", ExchangeName = "DeadLetter")]
public class HelloMessageDeadLetter : DistributedEventBase
{
}

License

MIT

About

An open-source lightweight message bus library (RabbitMQ) that supports publish/subscribe and RPC.

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

Contributors

Languages

AltStyle によって変換されたページ (->オリジナル) /