redis優化秒殺系統

用redis提升基於mss的秒殺系統

使用背景：

      普通的基於mss框架的系統在併發量不是很高的狀況下，對redis的需求不是很高。redis在系統中的角色至關於一個對象緩存器，在高併發的系統中（好比秒殺系統），在某一刻對數據庫中的一條數據多是成千上萬的用戶同時去訪問，系統的用戶體驗度直接受到數據庫的性能的影響。爲了保證數據的完整性，用戶只能串行訪問數據庫中的某一條記錄。redis則是把記錄對應的對象序列化存儲在自身的容器中，減小數據庫的壓力。廢話很少說，接下來簡單介紹redis的使用。

redis服務器的下載：

http://www.newasp.net/soft/67186.html#downloaded

該地址有redis的介紹，安裝以及啓動。

maven項目中引入redis的依賴：

<dependency>

   <groupId>redis.client</groupId>

   <artifactId>jedis</artifactId>

   <version>2.7.3</version>

</dependency>

redis核心類：

Jedis jedis = jedisPool.getResource();

    返回一個操做redis對象池的對象，該對象的存儲方式相似於map同樣也是採用鍵值對來存儲對象的。jedisPool的初始化採用構造函數指明redis服務器所在的ip地址跟監聽的接口，若是實驗的redis服務器在本機則ip地址填寫localhost便可。

   如以上所說，redis服務器以鍵值對來存儲對象，可是值得存儲方式是將對象序列化再進行存儲。jdk爲用戶提供了一套對象序列化API，此時你們想到的應該是讓被序列化類去實現Serializable接口。這種方法是可行的，可是缺點在與sun提供的這套API是比較低效率的，並且壓縮以後的對象仍是比較佔空間的。此時咱們能夠採用Protostuff對象提供的序列化API，測試證實了這套API的序列化效率更高切壓縮空間更小。

Protostuff依賴：

<dependency>
　　<groupId>com.dyuproject.protostuff</groupId>
　　<artifactId>protostuff-core</artifactId>
　　<version>1.0.8</version>
</dependency>
<dependency>
　　<groupId>com.dyuproject.protostuff</groupId>
　　<artifactId>protostuff-runtime</artifactId>
　　<version>1.0.8</version>
</dependency>
<dependency>
<groupId>velocity</groupId>
　　<artifactId>velocity</artifactId>
　　<version>1.4</version>
　　<scope>test</scope>
</dependency>
<dependency>
　　<groupId>commons-collections</groupId>
　　<artifactId>commons-collections</artifactId>
　　<version>3.2</version>
</dependency>

protostuffIOUtil使用：

序列化：

RuntimeSchema<T> schema = RuntimeSchema.createFrom(T.class);

首先是告知protostuffIOUtil即將要序列化的對象的序列化規則。

byte[] bytes = ProtostuffIOUtil.toByteArray(Object, schema,LinkedBuffer.allocate(LinkedBuffer.DEFAULT_BUFFER_SIZE));

將Object對象進行序列化，schema則是序列化規則，參數三是序列過過程當中使用到的緩衝區。

反序列化：

  如上面提到的，schema表明序列化規則，因此經過Object object = schema.newMessage();可讓容器按規則生成一個空對象，在根據衝redis中拿到的序列值進行反化

ProtostuffIOUtil.mergeFrom(bytes,object,schema);

該方法是根據參數三的對象序列化規則，對參數一的序列值進行操做，而後將對象封裝在空對象object中。

redis的存取：

　　講了這麼對先在該說說redis的存取方法了，如同上面我所說的同樣，跟map集合很類似的是redis的取值也是使用get（「key」）方法。不過傳入的參數必須是字節數組，並且方法的返回值也是一個字節數組，因此只要將返回的字節數組使用Protostuff的反序列化便可獲得所要的對象。

　　byte[] bytes = jedis.get(key.getBytes());

　　不一樣的是redis的存儲並非使用put（）方法，而是setex(key.getBytes(), timeout, bytes)；方法。方法中的參數一是鍵值對中的鍵，參數三是序列化後的對象字節數組，參數二是指明該對象在redis服務器中緩存多長時間，它的單位是秒。

int timeout = 60 * 60;
String result = jedis.setex(key.getBytes(), timeout, bytes);

實戰案例：

package org.seckill.dao.cache;import com.dyuproject.protostuff.LinkedBuffer;import com.dyuproject.protostuff.ProtostuffIOUtil;import com.dyuproject.protostuff.runtime.RuntimeSchema;import org.seckill.entity.Seckill;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisPool;/** * Created by Administrator on 2016/8/10 0010. */public class RedisDao{    private final Logger logger = LoggerFactory.getLogger(this.getClass());    private JedisPool jedisPool;    //序列化工具類，泛型指明該類序列化的規則    private RuntimeSchema<Seckill> schema = RuntimeSchema.createFrom(Seckill.class);    public RedisDao(String ip,int port){        jedisPool = new JedisPool(ip,port);    }    public Seckill getSeckill(long seckillId){        //redis操做邏輯        try {            Jedis jedis = jedisPool.getResource();            try {                String key = "seckill:" + seckillId;                //並無實現內部序列化操做                //get->byte[]->反序列化->Object(Seckill)                //採用自定義序列化                byte[] bytes = jedis.get(key.getBytes());                //緩存從新取到                if(bytes != null){                    //空對象                    Seckill seckill = schema.newMessage();                    ProtostuffIOUtil.mergeFrom(bytes,seckill,schema);                    //seckill 被反序列了                    return seckill;                }            }finally {                jedis.close();            }        }catch (Exception e){            logger.error(e.getMessage(),e);        }        return null;    }    public String putSeckill(Seckill seckill){        //set Object(Seckill)->序列化->byte[]        try{            Jedis jedis = jedisPool.getResource();            try {                String key = "seckill:" + seckill.getSeckillId();                byte[] bytes = ProtostuffIOUtil.toByteArray(seckill, schema,                        LinkedBuffer.allocate(LinkedBuffer.DEFAULT_BUFFER_SIZE));                //超時緩存                int timeout = 60 * 60;                String result = jedis.setex(key.getBytes(), timeout, bytes);                return result;            }finally{                jedis.close();            }        }catch (Exception e){            logger.error(e.getMessage(),e);        }        return null;    }}若有什麼不足或者錯誤的地方但願你們留言指出，轉載的話請標明出處；