Comment ajouter une liste générique à Redis via StackExchange.Redis?

Par exemple, si j'ai un modèle de la Clientèle

public class Customer
    {
        public string FirstName { get; set; }
        public string LastName { get; set; }
        public string Address1 { get; set; }
        public string City { get; set; }
        public string State { get; set; }
    }

Exemple:

var customers = new List<Customer>();

Comment j'ai ajouté une Liste de Clients? Comment puis-je faire?

 using (var redis = ConnectionMultiplexer.Connect(this.redisServer))
            {
                var db = redis.GetDatabase();

                db.SetAdd(key, ?????);
}

Je pense que SetAdd est la bonne méthode, mais je ne vois pas comment obtenir mon générique de la liste des Clients (c'est à dire la Liste dans le format de RedisValue.

source d'informationauteur Shane

  1. 14

    StackExchange.Redis est un raw client, il parle dans le Redis. Il ne cherche pas à être un ORM de toute nature. Cependant, il permettra de stocker tout string ou byte[] que vous pouvez jeter à elle - ce qui signifie que vous devriez avoir votre choix de sérialiseurs. JSON raisonnable serait de défaut (Jil est génial), même si nous avons tendance à utiliser le protocole tampons de nous-mêmes (via protobuf-net).

    Il vous avez l'intention d'utiliser la liste de la sémantique, je conseille fortement de partir avec la Liste* des commandes - ensembles ont des sémantiques différentes listes - ensembles sont non ordonnée et seulement stocker des valeurs uniques; des listes de préserver l'ordre et autoriser les doublons.

  2. 14

    Peut-être que ça aide. J'ai aussi été confrontés à la même question au début de ma plongée dans StackExchange.Redis. Dans mon projet, j'ai créé 2 méthodes d'extension, qui m'aident à sérialiser/désérialiser de type complexe pour le Redis. Vous pouvez les étendre à vos besoins.

    Méthodes:

        public static class RedisUtils
        {
//Serialize in Redis format:
            public static HashEntry[] ToHashEntries(this object obj)
            {
                PropertyInfo[] properties = obj.GetType().GetProperties();
                return properties.Select(property => new HashEntry(property.Name, property.GetValue(obj).ToString())).ToArray();
            }
    //Deserialize from Redis format
            public static T ConvertFromRedis<T>(this HashEntry[] hashEntries)
            {
                PropertyInfo[] properties = typeof(T).GetProperties();
                var obj = Activator.CreateInstance(typeof(T));
                foreach (var property in properties)
                {
                    HashEntry entry = hashEntries.FirstOrDefault(g => g.Name.ToString().Equals(property.Name));
                    if (entry.Equals(new HashEntry())) continue;
                    property.SetValue(obj, Convert.ChangeType(entry.Value.ToString(), property.PropertyType));
                }
                return (T)obj;
            }
        }

    Utilisation:

    var customer = new Customer
{
//Initialization
};

Db.HashSet("customer", customer.ToHashEntries());
Customer result = Db.HashGetAll("customer").ConvertFromRedis<Customer>();

Assert.AreEqual(customer.FirstName, result.FirstName);
Assert.AreEqual(customer.LastName, result.LastName);
Assert.AreEqual(customer.Address1, result.Address1);
  3. 7

    Une amélioration de Andrey Gubal's réponse, pour gérer nullable propriétés ou valeurs null:

    public static class RedisUtils
{
    //Serialize in Redis format:
    public static HashEntry[] ToHashEntries(this object obj)
    {
        PropertyInfo[] properties = obj.GetType().GetProperties();
        return properties
            .Where(x=> x.GetValue(obj)!=null) //<-- PREVENT NullReferenceException
            .Select(property => new HashEntry(property.Name, property.GetValue(obj)
            .ToString())).ToArray();
    }

    //Deserialize from Redis format
    public static T ConvertFromRedis<T>(this HashEntry[] hashEntries)
    {
        PropertyInfo[] properties = typeof(T).GetProperties();
        var obj = Activator.CreateInstance(typeof(T));
        foreach (var property in properties)
        {
            HashEntry entry = hashEntries.FirstOrDefault(g => g.Name.ToString().Equals(property.Name));
            if (entry.Equals(new HashEntry())) continue;
            property.SetValue(obj, Convert.ChangeType(entry.Value.ToString(), property.PropertyType));
        }
        return (T)obj;
    }
}
  4. 3

    C'est une option

    public static class StackExchangeRedisExtensions
{
public static T Get<T>(string key)
{
var connect = AzureredisDb.Cache;
var r = AzureredisDb.Cache.StringGet(key);
return Deserialize<T>(r);
}
public static List<T> GetList<T>(string key)
{                       
return (List<T>)Get(key);
}
public static void SetList<T>(string key, List<T> list)
{
Set(key, list);
}
public static object Get(string key)
{
return Deserialize<object>(AzureredisDb.Cache.StringGet(key));
}
public static void Set(string key, object value)
{
AzureredisDb.Cache.StringSet(key, Serialize(value));
}
static byte[] Serialize(object o)
{
if (o == null)
{
return null;
}
BinaryFormatter binaryFormatter = new BinaryFormatter();
using (MemoryStream memoryStream = new MemoryStream())
{
binaryFormatter.Serialize(memoryStream, o);
byte[] objectDataAsStream = memoryStream.ToArray();
return objectDataAsStream;
}
}
static T Deserialize<T>(byte[] stream)
{
if (stream == null)
{
return default(T);
}
BinaryFormatter binaryFormatter = new BinaryFormatter();
using (MemoryStream memoryStream = new MemoryStream(stream))
{
T result = (T)binaryFormatter.Deserialize(memoryStream);
return result;
}
}
}

    AzureredisDb.Le Cache est ConnectionMultiplexer.Connecter et GetDatabase();