zoukankan      html  css  js  c++  java
  • 使用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);
        }
    }
  • 相关阅读:
    Arpa's weak amphitheater and Mehrdad's valuable Hoses
    Arpa's loud Owf and Mehrdad's evil plan
    穷游中国在统题
    2016 ACM Amman Collegiate Programming Contest D Rectangles
    区间求和
    Redis 连接池的问题
    eBay 使用ReviseInventoryStatusCall调整库存和价格
    eBay Notification介绍
    Quartz.Net 配置模板范例
    Quartz.net misfire实践
  • 原文地址:https://www.cnblogs.com/silent2012/p/4443554.html
Copyright © 2011-2022 走看看