在c#中使用servicestackredis操作redis

下载地址: https://github.com/mythz/ServiceStack.Redis

添加dll引用:

using ServiceStack.Common.Extensions;
using ServiceStack.Redis;
using ServiceStack.Redis.Generic;
using ServiceStack.Text;
using ServiceStack.Redis.Support;

声明一个客户端对象:
protected RedisClient Redis = new RedisClient("127.0.0.1", 6379);//redis服务IP和端口

一 .基本KEY/VALUE键值对操作:
    1. 添加/获取:

List<string> storeMembers = new List<string>();
  storeMembers.ForEach(x => Redis.AddItemToList("test", x));

注:也可直接使用AddRangeToList方法将一组数据装入如:

Redis.AddRangeToList("testt", storeMembers);

2. 获取数据

var members = Redis.GetAllItemsFromList("test");
  members.ForEach(s => Response.Write("<br/>test :" + s));
  
    3. 获取指定索引位置数据

var item = Redis.GetItemFromList("test", 2);
  
    4. 移除:

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

二.存储对象:

public class UserInfo
    {
        public long Id { set; get; }
        public string UserName { get; set; }
        public int Age { get; set; }
    }
  
    1.通常方式(底层使用json序列化):

Redis.Set<UserInfo>("userinfo", new UserInfo() { UserName = "李四", Age = 45 });
  UserInfo userinfo = Redis.Get<UserInfo>("userinfo");
  
    注:当然上面方式也适合于基本类型,如:

Redis.Set<int>("my_age", 12);//或Redis.Set("my_age", 12);
    int age = Redis.Get<int>("my_age");

2.object序列化方式存储:

var ser = new ObjectSerializer();    //位于namespace ServiceStack.Redis.Support;
  bool result = Redis.Set<byte[]>("userinfo", ser.Serialize(new UserInfo() { UserName = "张三", Age = 12 }));
  UserInfo userinfo = ser.Deserialize(Redis.Get<byte[]>("userinfo")) as UserInfo;
  //也支持列表
  Redis.Set<byte[]>("userinfolist_serialize", ser.Serialize(userinfoList));
  List<UserInfo> userList = ser.Deserialize(Redis.Get<byte[]>("userinfolist_serialize")) as List<UserInfo>;

需要说明的是在测试过程中发现JSON序列化的效率要比object序列化高一些。
  
三.存储表格对象,比如:

using (var redisUsers = Redis.GetTypedClient<UserInfo>())
  {
      redisUsers.Store(new UserInfo { Id = redisUsers.GetNextSequence(), UserName = "test1", Age = 22 });
      redisUsers.Store(new UserInfo { Id = redisUsers.GetNextSequence(), UserName = "test2", Age = 23 });

var allUsers = redisUsers.GetAll();//就像操作ado对象一样,可以进行CRUD等操作
      allUsers.ForEach(s => Response.Write("<br/>user :" + s.UserName + " age:" + s.Age));
  }

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

public static PooledRedisClientManager CreateManager(string[] readWriteHosts, string[] readOnlyHosts)
  {
       //支持读写分离,均衡负载
       return new PooledRedisClientManager(readWriteHosts, readOnlyHosts, new RedisClientManagerConfig
       {
           MaxWritePoolSize = 5,//“写”链接池链接数
           MaxReadPoolSize = 5,//“写”链接池链接数
           AutoStart = true,
       });          
  }

声明链接池对象(这里只使用一个redis服务端):

PooledRedisClientManager prcm = CreateManager(new string[] { "127.0.0.1:6379" }, new string[] { "127.0.0.1:6379" });
 
  List<UserInfo> userinfoList = new List<UserInfo>();
  userinfoList.Add(new UserInfo() { UserName = "pool_daizhj", Age = 1 });
  userinfoList.Add(new UserInfo() { UserName = "pool_daizhj1", Age = 2 });
          
    从池中获取一个链接:

using (IRedisClient Redis = prcm.GetClient())
  {              
       Redis.Set("userinfolist", userinfoList);
       List<UserInfo> userList = Redis.Get<List<UserInfo>>("userinfolist");
  }

注:
如只想使用长链接而不是链接池的话,可以直接将下面对象用static方式声明即可:  
      protected static RedisClient Redis = new RedisClient("127.0.0.1", 6379); 
这样在redis服务端显示只有一个客户链接

时间: 2024-10-05 13:17:20

在c#中使用servicestackredis操作redis的相关文章

c#中使用servicestackredis操作redis

下载地址: https://github.com/mythz/ServiceStack.Redis 添加dll引用: using ServiceStack.Common.Extensions;using ServiceStack.Redis;using ServiceStack.Redis.Generic;using ServiceStack.Text;using ServiceStack.Redis.Support; 声明一个客户端对象:protected RedisClient Redis

Java中使用Jedis操作Redis

转载:http://www.cnblogs.com/liuling/p/2014-4-19-04.html 使用Java操作Redis需要jedis-2.1.0.jar,下载地址:http://files.cnblogs.com/liuling/jedis-2.1.0.jar.zip 如果需要使用Redis连接池的话,还需commons-pool-1.5.4.jar,下载地址:http://files.cnblogs.com/liuling/commons-pool-1.5.4.jar.zip

java中使用jedis操作redis(连接池方式)

1 package com.test; 2 3 import java.util.HashMap; 4 import java.util.Iterator; 5 import java.util.List; 6 import java.util.Map; 7 8 import org.junit.Before; 9 import org.junit.Test; 10 11 import redis.clients.jedis.Jedis; 12 13 public class TestRedis

【转载】Java中使用Jedis操作Redis

1 package com.test; 2 3 import java.util.HashMap; 4 import java.util.Iterator; 5 import java.util.List; 6 import java.util.Map; 7 8 import org.junit.Before; 9 import org.junit.Test; 10 11 import redis.clients.jedis.Jedis; 12 13 public class TestRedis

Spring中使用RedisTemplate操作Redis(spring-data-redis)

Redis 数据结构简介 Redis可以存储键与5种不同数据结构类型之间的映射,这5种数据结构类型分别为String(字符串).List(列表).Set(集合).Hash(散列)和 Zset(有序集合). 下面来对这5种数据结构类型作简单的介绍: 结构类型 结构存储的值 结构的读写能力 String 可以是字符串.整数或者浮点数 对整个字符串或者字符串的其中一部分执行操作:对象和浮点数执行自增(increment)或者自减(decrement) List 一个链表,链表上的每个节点都包含了一个字

Java操作Redis之Jedis用法详解

Redis(Remote Dictionary Server,远程数据字典服务器)是一个开源的高性能内存数据库,常用作缓存缓存服务器使用,也已做消息队列使用.因其高性能.丰富的数据类型.可扩展等特性受开发者青睐,这里介绍在java中使用Jedis操作Redis的基本用法. 1. 字符串String. package com.zws.redis.examples; import java.util.concurrent.TimeUnit; import redis.clients.jedis.Je

Java中Jedis操作Redis与Spring的整合

Redis是一个key-value存储系统.它支持存储的value类型相对更多,包括string(字符串).list(链表).set(集合)和zset(有序集合).这些数据类型都支持push/pop.add/remove及取交集并集和差集及更丰富的操作,而且这些操作都是原子性的.在此基础上,redis支持各种不同方式的排序.为了保证效率,数据都是缓存在内存中.redis会周期性的把更新的数据写入磁盘或者把修改操作写入追加的记录文件,并且在此基础上实现了master-slave(主从)同步.以下是

Redis的安装、使用以及php中扩展redis并实现php操作redis的一个例子

1.下载源码包redis-2.8.21.tar.gz,并将其上传到指定目录/urs/src,然后对其进行解压: [[email protected] src]# tar -xvf redis-2.8.21.tar.gz 进入解压后的目录,并执行下面命令,指定安装目录为/urs/local/redis: [[email protected] src]# cd redis-2.8.21 [[email protected] redis-2.8.21]# make PREFIX=/usr/local/

java中操作redis

1 package com.redis; 2 3 import java.io.IOException; 4 import java.util.concurrent.ConcurrentHashMap; 5 6 import redis.clients.jedis.Jedis; 7 import redis.clients.jedis.Transaction; 8 /** 9 * java中操作redis 10 * 11 * @author Administrator 12 * 13 */ 14