在c#中使用servicestackredis操作redis的实例代码

2024-02-19 11:40:04 49

声明一个客户端对象：


protectedRedisClientRedis=newRedisClient("127.0.0.1",6379);//redis服务IP和端口

一.基本KEY/VALUE键值对操作：

1.添加/获取:

ListstoreMembers=newList();
storeMembers.ForEach(x=>Redis.AddItemToList("test",x));
//注：也可直接使用AddRangeToList方法将一组数据装入如：
Redis.AddRangeToList("testt",storeMembers);

2.获取数据

varmembers=Redis.GetAllItemsFromList("test");
members.ForEach(s=>Response.Write("
test:"+s));

3.获取指定索引位置数据

varitem=Redis.GetItemFromList("test",2);

4.移除：

varlist=Redis.Lists["test"];
list.Clear();//清空
list.Remove("two");//移除指定键值
list.RemoveAt(2);//移除指定索引位置数据

二.存储对象：

[Serializable]
publicclassUserInfo
{
publiclongId{set;get;}
publicstringUserName{get;set;}
publicintAge{get;set;}
}

1.通常方式（底层使用json序列化）：

Redis.Set("userinfo",newUserInfo(){UserName="李四",Age=45});
UserInfouserinfo=Redis.Get("userinfo");

注：当然上面方式也适合于基本类型，如：

Redis.Set("my_age",12);//或Redis.Set("my_age",12);
intage=Redis.Get("my_age");

2.object序列化方式存储：

varser=newObjectSerializer();//位于namespaceServiceStack.Redis.Support;
boolresult=Redis.Set("userinfo",ser.Serialize(newUserInfo(){UserName="张三",Age=12}));
UserInfouserinfo=ser.Deserialize(Redis.Get("userinfo"))asUserInfo;
//也支持列表
ListuserinfoList=newList();
userinfoList.Add(newUserInfo(){UserName="pool_daizhj",Age=1});
userinfoList.Add(newUserInfo(){UserName="pool_daizhj1",Age=2});
Redis.Set("userinfolist_serialize",ser.Serialize(userinfoList));
ListuserList=ser.Deserialize(Redis.Get("userinfolist_serialize"))asList;

需要说明的是在测试过程中发现JSON序列化的效率要比object序列化高一些。

三.存储表格对象，比如：

using(varredisUsers=Redis.As())
{
redisUsers.Store(newUserInfo{Id=redisUsers.GetNextSequence(),UserName="test1",Age=22});
redisUsers.Store(newUserInfo{Id=redisUsers.GetNextSequence(),UserName="test2",Age=23});
varallUsers=redisUsers.GetAll();//就像操作ado对象一样，可以进行CRUD等操作
}

四.使用客户端链接池模式提升链接速度：

publicstaticPooledRedisClientManagerCreateManager(string[]readWriteHosts,string[]readOnlyHosts)
{
//支持读写分离，均衡负载
returnnewPooledRedisClientManager(readWriteHosts,readOnlyHosts,newRedisClientManagerConfig
{
MaxWritePoolSize=5,//“写”链接池链接数
MaxReadPoolSize=5,//“读”链接池链接数
AutoStart=true,
});
}

声明链接池对象（这里只使用一个redis服务端）：

PooledRedisClientManagerprcm=CreateManager(newstring[]{"127.0.0.1:6379"},newstring[]{"127.0.0.1:6379"});

ListuserinfoList=newList();
userinfoList.Add(newUserInfo(){UserName="pool_daizhj",Age=1});
userinfoList.Add(newUserInfo(){UserName="pool_daizhj1",Age=2});

从池中获取一个链接：

using(IRedisClientRedis=prcm.GetClient())
{
Redis.Set("userinfolist",userinfoList);
ListuserList=Redis.Get>("userinfolist");
}

注：

如只想使用长链接而不是链接池的话，可以直接将下面对象用static方式声明即可：

protectedstaticRedisClientRedis=newRedisClient("127.0.0.1",6379);

这样在redis服务端显示只有一个客户链接

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。

在c#中使用servicestackredis操作redis的实例代码

热门推荐

随机推荐