C# Redis消息队列例子
2024-08-30 13:48:02
class Program
{ //版本2:使用Redis的客户端管理器(对象池)
public static IRedisClientsManager redisClientManager = new PooledRedisClientManager(new string[]
{
//如果是Redis集群则配置多个{IP地址:端口号}即可
//例如: "10.0.0.1:6379","10.0.0.2:6379","10.0.0.3:6379"
"127.0.0.1:6379"
});
//从池中获取Redis客户端实例
public static IRedisClient redisClient = redisClientManager.GetClient();
static void Main(string[] args)
{
// redisClient.Password = "123";
redisClient.EnqueueItemOnList("test", "Hello World!");
redisClient.EnqueueItemOnList("test", "Hello World2!"); Timer t = new Timer((o) =>
{
var value = redisClient.DequeueItemFromList("test");
if (string.IsNullOrWhiteSpace(value))
{
Console.WriteLine("队列中数据不存在!");
}
else
{
Console.WriteLine(value);
} }, null, , ); Console.Read(); }
}
运行结果
备注:Redis驱动版本:4.0.50.0
最新文章
- linux crontab定时任务调用CI框架PHP代码
- C# 换行符
- Android Volley入门到精通:初识Volley的基本用法
- time模块目录下自己建立一个名为log的文件夹
- 20140122-Application19事件
- BNUOJ-29365 Join in tasks 简单数学
- 1、第一个SpringMVC程序
- oracle恢复一个数据表的方法
- 简单对比git pull和git pull --rebase的使用
- Python基础(二)自定义函数
- django学习之——Model
- unity中让摄像机移动到鼠标点击的位置和鼠标控制平移视角
- vue之v-if和v-show
- 利用Metrics+influxdb+grafana构建监控平台(转)
- POJ3009:Curling 2.0(dfs)
- SQL 2008 R2数据库变为REPLICATION,日志不断增长并且不能截断和收缩的解决方式
- Java精选笔记_面向对象(构造方法、this关键字、static关键字、内部类)
- vuex: 简单(弹窗)实现
- 基于ffmpegSDK的开发
- 15-I hate it (HDU1754:线段树)