Spring Data redisのいくつかのオブジェクトの順序付けについての比較

22905 ワード

スプリング

本論は次から次へhttp://stamen.iteye.com/blog/1907984
問題最近はspring data redisを整理していますが、ネット上に「Spring Data」という電子書籍があります.(友達が翻訳しています.今年は中国語版が出てきます.郵送されています.). redisは、list set hashなどのデータタイプに対するサポートを提供していますが、POJOオブジェクトに対するサポートは提供されていません.下の階には、オブジェクトを順番に並べて文字列で保存しています.したがって、Spring dataはいくつかのSerializerを提供しています.

Jackson JRedis Serializer

JdkSerialization

Oxm Serializer

参照:http://static.springsource.org/spring-data/data-keyvalue/docs/1.0.x/api/ ここで、まず3つの使用をテストしたいです.2番目はそれらの効果を見たいです.ダウンロードの準備私は直接『Spring Data』のソースコードをもとに、このダウンロード書のソースコードを変更しました.https://github.com/SpringSource/spring-data-bookからredisサブプロジェクトを開きました.Mavenで組織したので、カバンの問題に関心を持たなくてもいいです.テストのEntityを追加します.私たちはRedisを使ってPOJOオブジェクトを保存したいので、comple.orilly.springdata.redisパッケージの下でUserオブジェクトを作成します.以下のようにします.

package com.oreilly.springdata.redis;



import javax.xml.bind.annotation.XmlAccessType;

import javax.xml.bind.annotation.XmlAccessorType;

import javax.xml.bind.annotation.XmlAttribute;

import javax.xml.bind.annotation.XmlRootElement;

import java.io.Serializable;



/**

 * @author : stamen

 * @date: 13-7-16

 */

@XmlAccessorType(XmlAccessType.FIELD)

@XmlRootElement(name = "user")

public class User implements Serializable {



    @XmlAttribute

    private String userName;



    @XmlAttribute

    private int age;



    public String getUserName() {

        return userName;

    }



    public void setUserName(String userName) {

        this.userName = userName;

    }



    public int getAge() {

        return age;

    }



    public void setAge(int age) {

        this.age = age;

    }

}

後はOXMおよびJacksonを使用して対象シーケンスを行い、制御対象の順序化のためにJSR 175の注釈を付けます.Apple Configを変更します. Apple ConfigはSpring容器の配置類で、あなたの環境によって変更します.

package com.oreilly.springdata.redis;



import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.data.redis.connection.RedisConnectionFactory;

import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;

import org.springframework.data.redis.core.RedisTemplate;

import org.springframework.data.redis.serializer.OxmSerializer;

import org.springframework.data.redis.serializer.RedisSerializer;

import org.springframework.data.redis.serializer.SerializationException;

import org.springframework.oxm.jaxb.Jaxb2Marshaller;



import javax.xml.bind.JAXBContext;

import javax.xml.bind.Marshaller;

import java.util.HashMap;

import java.util.Map;

import java.util.concurrent.ConcurrentHashMap;



/**

 * @author Jon Brisbin

 */

@Configuration

public abstract class ApplicationConfig {



    @Bean

    public RedisConnectionFactory redisConnectionFactory() {

        JedisConnectionFactory cf = new JedisConnectionFactory();

        cf.setHostName("10.188.182.140");

        cf.setPort(6379);

        cf.setPassword("superman");

        cf.afterPropertiesSet();

        return cf;

    }



    @Bean

    public RedisTemplate redisTemplate() {

        RedisTemplate rt = new RedisTemplate();

        rt.setConnectionFactory(redisConnectionFactory());

        return rt;

    }



    private static Map<Class, JAXBContext> jaxbContextHashMap = new ConcurrentHashMap<Class, JAXBContext>();



    @Bean

    public OxmSerializer oxmSerializer() throws Throwable{

        Jaxb2Marshaller jaxb2Marshaller = new Jaxb2Marshaller();

        Map<String,Object> properties = new HashMap<String, Object>();//    ，    Marshaller  

        properties.put(Marshaller.JAXB_FORMATTED_OUTPUT, Boolean.TRUE);   //  xml      

        properties.put(Marshaller.JAXB_ENCODING,"utf-8");   //  xml      

        jaxb2Marshaller.setClassesToBeBound(User.class);//   xml   JAXB   

        jaxb2Marshaller.setMarshallerProperties(properties);//  Marshaller  

        return  new OxmSerializer(jaxb2Marshaller,jaxb2Marshaller);

    }



    public static enum StringSerializer implements RedisSerializer<String> {

        INSTANCE;



        @Override

        public byte[] serialize(String s) throws SerializationException {

            return (null != s ? s.getBytes() : new byte[0]);

        }



        @Override

        public String deserialize(byte[] bytes) throws SerializationException {

            if (bytes.length > 0) {

                return new String(bytes);

            } else {

                return null;

            }

        }

    }



    public static enum LongSerializer implements RedisSerializer<Long> {

        INSTANCE;



        @Override

        public byte[] serialize(Long aLong) throws SerializationException {

            if (null != aLong) {

                return aLong.toString().getBytes();

            } else {

                return new byte[0];

            }

        }



        @Override

        public Long deserialize(byte[] bytes) throws SerializationException {

            if (bytes.length > 0) {

                return Long.parseLong(new String(bytes));

            } else {

                return null;

            }

        }

    }





    public static enum IntSerializer implements RedisSerializer<Integer> {

        INSTANCE;



        @Override

        public byte[] serialize(Integer i) throws SerializationException {

            if (null != i) {

                return i.toString().getBytes();

            } else {

                return new byte[0];

            }

        }



        @Override

        public Integer deserialize(byte[] bytes) throws SerializationException {

            if (bytes.length > 0) {

                return Integer.parseInt(new String(bytes));

            } else {

                return null;

            }

        }

    }



}

1)RedisConnection Factory()Redsiサーバの接続方法を設定しています. 2)oxmSerializer()は、Jaxb 2 marsharlerに基づくOxmSerializer Beanを定義するために追加しました. KeyValue SerializerTestを開きます.私たちはいくつかの追加的なテストケースをこのテストクラスに書きます.JdkSerializationRedis Serializerを使ってプログレッシブ化します.

    @Test

    public void testJdkSerialiable() {

        RedisTemplate<String, Serializable> redis = new RedisTemplate<String, Serializable>();

        redis.setConnectionFactory(connectionFactory);

        redis.setKeySerializer(ApplicationConfig.StringSerializer.INSTANCE);

        redis.setValueSerializer(new JdkSerializationRedisSerializer());

        redis.afterPropertiesSet();



        ValueOperations<String, Serializable> ops = redis.opsForValue();



        User user1 = new User();

        user1.setUserName("user1");

        user1.setAge(20);



        String key1 = "users/user1";

        User user11 = null;



        long begin = System.currentTimeMillis();

        for (int i = 0; i < 100; i++) {

            ops.set(key1,user1);

            user11 = (User)ops.get(key1);

        }

        long time = System.currentTimeMillis() - begin;

        System.out.println("jdk time:"+time);

        assertThat(user11.getUserName(),is("user1"));

    }

JdkSerialization Redis SerializerサポートはすべてSerializableを実現したクラスに対して序列化を行います.このテストケースを実行して、私達はredis-cliを通じて「users/user 1」キーで対応する値を見ることができます.内容は以下の通りです.
参照
redis 127..0.1:6379>get users/user 1
「\xac\xed\x 00\x 05 sr\x 00!comp.orilly.springdata.redis.User\xb 1\x 1 c\xcd\xd8\x 02\x 00\x 02\x 00\x 03 ageL\x 00\buserNamet\x 00\x 00\lance/lanch 1
streenで対応する文字の長さを調べます.
参照
redis 127..0.1:6379>stren users/user 1
(integer)104
上のコードは全部で100回の保存と取得を行いました.時間は以下の通りです.
参照
jdk time:266
Jackson JsonRedis Serializerを使ってプログレッシブ化します.

    @Test

    public void testJacksonSerialiable() {

        RedisTemplate<String, Object> redis = new RedisTemplate<String, Object>();

        redis.setConnectionFactory(connectionFactory);

        redis.setKeySerializer(ApplicationConfig.StringSerializer.INSTANCE);

        redis.setValueSerializer(new JacksonJsonRedisSerializer<User>(User.class));

        redis.afterPropertiesSet();



        ValueOperations<String, Object> ops = redis.opsForValue();



        User user1 = new User();

        user1.setUserName("user1");

        user1.setAge(20);

        

        User user11 = null;

        String key1 = "json/user1";



        long begin = System.currentTimeMillis();

        for (int i = 0; i < 100; i++) {

            ops.set(key1,user1);

            user11 = (User)ops.get(key1);

        }

        long time = System.currentTimeMillis() - begin;



        System.out.println("json time:"+time);

        assertThat(user11.getUserName(),is("user1"));

    }

    運転後、redisの内容と内容の長さを確認します.
参照
redis 127..0.1:6379>get Json/user 1
"\"userName\":\"user 1\",\"age\"20\"
redis 127..0.1:6379>streen json/user 1
(integer)29
    実行にかかる時間は以下の通りです.
参照
    json time:224
Oxm Serialiableを使って逐次化します.

    @Test

    public void testOxmSerialiable() throws Throwable{

        RedisTemplate<String, Object> redis = new RedisTemplate<String, Object>();

        redis.setConnectionFactory(connectionFactory);

        redis.setKeySerializer(ApplicationConfig.StringSerializer.INSTANCE);



        redis.setValueSerializer(oxmSerializer);

        redis.afterPropertiesSet();



        ValueOperations<String, Object> ops = redis.opsForValue();



        User user1 = new User();

        user1.setUserName("user1");

        user1.setAge(20);





        User user11 = null;

        String key1 = "oxm/user1";



        long begin = System.currentTimeMillis();

        for (int i = 0; i < 100; i++) {

            ops.set(key1,user1);

            user11 = (User)ops.get(key1);

        }

        long time = System.currentTimeMillis() - begin;



        System.out.println("oxm time:"+time);

        assertThat(user11.getUserName(),is("user1"));

    }

    運転後、redisの内容と内容の長さを確認します.
参照
redis 127..0.1:6379>get oxm/user 1
"
redis 127..0.1:6379>streen oxm/user 1
(integer)90
    実行にかかる時間は以下の通りです.
参照
    oxmタイム:335
結び目    実行時間から見れば、JdkSerialzationRedis Serializerが最も効率的である(やはりJDK元のものである)が、プログレッシブな結果の文字列が一番長い.JSONはデータフォーマットのコンパクトさのために,序列化の長さが最小であり,時間が前者より多い.Oxm Serialiablerは時間的に一番長いです.個人的な選択は、Jackson Json Redis SerializerをPOJOのシーケンサとして使う傾向があります.

ノード.JS識別画像タイプ