FilesExpand file tree

 master

/

ExpireHandler.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

29 lines (25 loc) · 1.11 KB

 master

/

ExpireHandler.java

Top

File metadata and controls

• Code
• Blame

29 lines (25 loc) · 1.11 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

package RedisCommand;

import Common.Logger;

import Common.RedisInputStringPair;

import Common.RedisUtil;

import MessageOutput.MessageOutput;

import RedisDataBase.RedisDb;

import RedisDataBase.RedisObject;

import RedisDataBase.RedisString;

import io.netty.channel.ChannelHandlerContext;

/** Expire命令需要覆盖原来的过期时间 **/

public class ExpireHandler implements RedisCommandHandler<RedisString> {

static private final RedisString expireConstant = new RedisString("expire");

@Override

public void handle(ChannelHandlerContext ctx, RedisString requestId, RedisString pair){

// 执行 expire key 的命令

int len1 = RedisString.readInt(pair,0);

RedisString key = RedisString.copyRedisString(pair,4,len1);

int len2 = RedisString.readInt(pair,4 + len1);

RedisString delay = RedisString.copyRedisString(pair,8 + len1,len2);

pair.release();

RedisDb.expire(key,RedisUtil.parseInt(delay));

// 这里的key不能轻易的release,因为会放在expired dict里面

ctx.writeAndFlush(new MessageOutput(requestId,expireConstant,"ok"));

}

}