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

转载于:https://www.cnblogs.com/xiaopotian/p/6884568.html

StackExchange.Redis实现Redis发布订阅相关推荐

Redis总结之发布订阅
绪论理论知识先介绍一下发布与订阅的基础知识: Redis 发布订阅(pub/sub)是一种消息通信模式:发送者(pub)发送消息,订阅者(sub)接收消息. 发布者不是直接将消息发送给特定的接收者 ...
硬核 | Redis Pub/Sub 发布订阅与宅男有什么关系？
"65 哥,如果你交了个漂亮小姐姐做女朋友,你会通过什么方式将这个消息广而告之给你的微信好友?" "那不得拍点女朋友的美照 + 亲密照弄一个九宫格图文消息在朋友圈发布大肆 ...
redis的观察者模式----------发布订阅功能
2019独角兽企业重金招聘Python工程师标准>>> 众所周知,Java,C++等面向对象有一种常见的设计模式:观察者模式,redis这种机制叫做发布订阅功能. 以下假设已redi ...
redis中的发布订阅
分为频道与模式发布订阅两类 1.相关数据结构 1.1 redisServer /* Pubsub */dict *pubsub_channels; /* Map channels to list o ...
事物与持久化_揭开Redis面纱，发布订阅、事务、安全、持久化
一.Redis发布订阅 Redis 发布订阅(pub/sub)是一种消息通信模式:发送者(pub)发送消息,订阅者(sub)接收消息. 打开两个窗口:session1 和 session2 在sess ...
Redis中的发布订阅模式
列表的局限前面我们说通过队列的rpush 和lpop 可以实现消息队列(队尾进队头出),但是消费者需要不停地调用lpop 查看List 中是否有等待处理的消息(比如写一个while 循环).为了减少 ...
【Redis】Redis Jedis实现发布订阅功能
文章目录 1.概述 1.1 console案例 1.2 原理 2.定义Subscriber类 3.定义SubThread线程类 4.定义Publisher类 5.定义入口代码 1.概述 Redis发布 ...
Java实现redis消息队列发布/订阅模式
最近在一个老项目中需要用消息队列,本来想着用卡夫卡,但是试了几个版本之后发现jdk和卡夫卡版本一直对不上,最后选择用redis来实现消息队列的发布/订阅模式.感谢这位大佬的博客给了我很多的帮助,htt ...
Redis 中的发布/订阅功能
发布/ 订阅系统是 Web 系统中比较常用的一个功能.简单点说就是发布者发布消息,订阅者接受消息,这有点类似于我们的报纸/ 杂志社之类的: 虽然可以使用一个 list 列表结构结合 lpush 和 ...
redis __实现发布订阅
第一步:创建订阅发布类 ## xx.py import redis class RedisHelper:def __init__(self):self.__conn = redis.Redis(hos ...

StackExchange.Redis实现Redis发布订阅

StackExchange.Redis实现Redis发布订阅相关推荐

最新文章

热门文章