33 lines
977 B
C#
33 lines
977 B
C#
|
using StackExchange.Redis;
|
||
|
|
|
||
|
|
namespace BotSharp.Core.Infrastructures.Events;
|
||
|
|
|
||
|
|
public class RedisPublisher : IEventPublisher
|
||
|
|
{
|
||
|
|
private readonly IConnectionMultiplexer _redis;
|
||
|
|
private readonly ISubscriber _subscriber;
|
||
|
|
private readonly ILogger _logger;
|
||
|
|
|
||
|
|
public RedisPublisher(IConnectionMultiplexer redis, ILogger<RedisPublisher> logger)
|
||
|
|
{
|
||
|
|
_redis = redis;
|
||
|
|
_logger = logger;
|
||
|
|
_subscriber = _redis.GetSubscriber();
|
||
|
|
}
|
||
|
|
|
||
|
|
public async Task BroadcastAsync(string channel, string message)
|
||
|
|
{
|
||
|
|
await _subscriber.PublishAsync(channel, message);
|
||
|
|
}
|
||
|
|
|
||
|
|
public async Task PublishAsync(string channel, string message)
|
||
|
|
{
|
||
|
|
var db = _redis.GetDatabase();
|
||
|
|
// Add a message to the stream, keeping only the latest 1 million messages
|
||
|
|
await db.StreamAddAsync(channel, "message", message,
|
||
|
|
maxLength: 1000 * 10000);
|
||
|
|
|
||
|
|
_logger.LogInformation($"Published message {channel} {message}");
|
||
|
|
}
|
||
|
|
}
|