zoukankan      html  css  js  c++  java
  • StackExchange.Redis实现Redis发布订阅

    由于ServiceStack.Redis最新版已经收费,所以现在大家陆陆续续都换到StackExchange.Redis上了,关于StackExchange.Redis详细可以参看Github

    https://stackexchange.github.io/StackExchange.Redis/的官方文档

    先看一下效果图

    这是项目解决方案,COMMON里面放置的是StackExchange.Redis 通用类的封装,已经在实际项目中使用,目前感觉良好

    该Demo主要包括两部分,

    一:发布

    static async Task Pub()
            {
                Console.WriteLine("请输入要发布向哪个通道?");
                var channel = Console.ReadLine();
    
                await Task.Delay(10);
                for(int i = 0; i < 10; i++)
                {
                    await _redis.PublishAsync(channel, i.ToString());
                }
                    
            }

    二:订阅

    static async Task Sub()
            {
                Console.WriteLine("请输入您要订阅哪个通道的信息?");
                var channelKey = Console.ReadLine();
                await _redis.SubscribeAsync(channelKey, (channel, message) =>
                {
                    Console.WriteLine("接受到发布的内容为:" + message);
                });
                Console.WriteLine("您订阅的通道为:<< " + channelKey + " >> ! 请耐心等待消息的到来!!");
            }
    View Code

    最后附上GitHub地址

    https://github.com/xiaopotian1990/RedisDemo

  • 相关阅读:
    spark学习进度18(SparkSQL读写)
    查看及修改centos的系统时间
    第3章 串
    linux就该这么学 简介
    1 快速入门
    rocketMQ实战与原理解析 简介
    绪论
    数据结构java版 第4版 叶核亚著 简介
    数据结构java语言版 简介
    数据结构与问题求解java版 简介
  • 原文地址:https://www.cnblogs.com/xiaopotian/p/6884568.html
Copyright © 2011-2022 走看看