43 lines
1.1 KiB
C#
43 lines
1.1 KiB
C#
using StackExchange.Redis;
|
|
using System;
|
|
using System.Threading.Tasks;
|
|
using WX.CRM.DAL.Redis;
|
|
|
|
namespace DAL.Redis
|
|
{
|
|
public class PubSub : RedisStore
|
|
{
|
|
internal ISubscriber Subscriber
|
|
{
|
|
get { return Connection.GetSubscriber(); }
|
|
}
|
|
|
|
|
|
public long Publish(string channel, string message)
|
|
{
|
|
return Subscriber.Publish(channel, message);
|
|
}
|
|
|
|
public async Task<long> PublishAsync(string channel, string message)
|
|
{
|
|
return await Subscriber.PublishAsync(channel, message);
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 订阅？
|
|
/// </summary>
|
|
/// <param name="channel"></param>
|
|
/// <param name="action"></param>
|
|
public void Subscribe(string channel, Action<RedisChannel, RedisValue> action)
|
|
{
|
|
Subscriber.Subscribe(channel, action);
|
|
}
|
|
|
|
public async Task SubscribeAsync(string channel, Action<RedisChannel, RedisValue> action)
|
|
{
|
|
await Subscriber.SubscribeAsync(channel, action);
|
|
}
|
|
}
|
|
}
|