使用redis进行消息推送详解数据库

　　Redis支持这样一种特性，你可以将数据推到某个信息管道中，然后其它客户端可以通过订阅这些管道来获取推送过来的信息。使用Redis的Pub/Sub，接收方在某个channel注册为一个订阅者，然后监听这个channel,一旦有消息发到这个channel上则自动接收消息，利用这个特性可以轻易的实现消息推送功能。

　　1. 使用Rediscli测试

　　客户端A订阅通道：

redis 127.0.0.1:6379> SUBSCRIBE channeltest

　　客户端B往该通道发送消息：

redis 127.0.0.1:6379> PUBLISH channeltest hello 
(integer) 1 
redis 127.0.0.1:6379> PUBLISH channeltest world 
(integer) 1

　　然后客户端A就能获取到推送的信息

redis 127.0.0.1:6379> SUBSCRIBE channeltest 
Reading messages... (press Ctrl-C to quit) 
1) "subscribe" 
2) "channeltest" 
3) (integer) 1 
1) "message" 
2) "channeltest" 
3) "hello" 
1) "message" 
2) "channeltest" 
3) "world"

　　2. 批量订阅测试

　　客户端A订阅通道：

redis 127.0.0.1:6379> SUBSCRIBE channeltest*

　　客户端B往该通道发送消息：

redis 127.0.0.1:6379> PUBLISH channeltest1 hello 
(integer) 1 redis 127.0.0.1:6379> PUBLISH channeltest2 world (integer) 1

　　然后客户端A就能获取到推送的信息：

redis 127.0.0.1:6379> PSUBSCRIBE channeltest* 
Reading messages... (press Ctrl-C to quit) 
1) "psubscribe" 
2) "channeltest*" 
3) (integer) 1 
1) "pmessage" 
2) "channeltest*" 
3) "channeltest1" 
4) "hello" 
1) "pmessage" 
2) "channeltest*" 
3) "channeltest2" 
4) "world"

　　3. C#客户端实现

　　客户端使用TeamDev.Redis

class Program 
{ 
    static void Main(string[] args) 
    { 
        try 
        { 
            RedisDataAccessProvider redisDataAccessProvider = new RedisDataAccessProvider(); 
            redisDataAccessProvider = new RedisDataAccessProvider(); 
            redisDataAccessProvider.Configuration.Host = "192.168.1.10"; 
            redisDataAccessProvider.Configuration.Port = 6379; 
            redisDataAccessProvider.Connect(); 
 
            redisDataAccessProvider.ChannelSubscribed += new ChannelSubscribedHandler(redisDataAccessProvider_ChannelSubscribed); 
            redisDataAccessProvider.MessageReceived += new MessageReceivedHandler(redisDataAccessProvider_MessageReceived); 
            redisDataAccessProvider.Messaging.Subscribe("al"); 
            redisDataAccessProvider.Messaging.Subscribe("b1"); 
        } 
        catch (Exception e) 
        { 
            Console.WriteLine("连接Redis错误:" + e.Message); 
        } 
 
        Console.ReadLine(); 
    } 
 
    static void redisDataAccessProvider_MessageReceived(string channelname, string message) 
    { 
        if (channelname == "a1") 
        { 
            Console.WriteLine(message); 
            Console.ReadKey(); 
        } 
    } 
 
    static void redisDataAccessProvider_ChannelSubscribed(string channelname) 
    { 
        Console.WriteLine(channelname); 
    } 
}

原创文章，作者：Maggie-Hunter，如若转载，请注明出处：https://blog.ytso.com/4961.html

使用redis进行消息推送详解数据库

相关推荐

发表回复