FilesExpand file tree

 master

/

SetCommandHandler.java

Copy path

BlameMore file actions

BlameMore file actions

Latest commit

 

History

History

History

34 lines (30 loc) · 1.5 KB

 master

/

SetCommandHandler.java

Top

File metadata and controls

• Code
• Blame

34 lines (30 loc) · 1.5 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

29

30

31

32

33

package RedisCommand;

import Common.Logger;

import Common.RedisInputStringPair;

import MessageOutput.MessageOutput;

import RedisDataBase.RedisDb;

import RedisDataBase.RedisObject;

import RedisDataBase.RedisString;

import io.netty.channel.ChannelHandlerContext;

/*** 处理常见的命令 ***/

public class SetCommandHandler implements RedisCommandHandler<RedisString> {

static private final RedisString setConstant = new RedisString("set");

static private final RedisString TrueConstant = new RedisString("true");

// todo 这里需要进行池化

@Override

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

// 执行 set key value 的命令

// Logger.debug(requestId + " " + ctx.channel() + ": set recv :" + message.getSecond());

// todo 注意需要在里面释放

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

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

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

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

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

RedisString nx = RedisString.copyRedisString(pair,12 + len1 + len2,len3);

pair.release();

boolean addSucc = RedisDb.set(key, RedisObject.redisStringObject(val),nx.equals(TrueConstant));

// key可能可以释放,val也是可能可以释放

ctx.writeAndFlush(new MessageOutput(requestId,setConstant,addSucc ? "ok" : "fail"));

}

}