redis_cell限流模块的使用-docker启动-java集成

最新推荐文章于 2024-01-29 11:49:29 发布

zedomi

最新推荐文章于 2024-01-29 11:49:29 发布

阅读量545

点赞数 2

分类专栏： Redis 文章标签： redis java docker

本文链接：https://blog.csdn.net/zedomi/article/details/113410248

版权

Redis 专栏收录该内容

1 篇文章

订阅专栏

本文介绍了如何在Java应用中利用Redis-cell模块进行限流控制。首先讲解了Redis-cell的基本概念和使用指令，如CL.THROTTLE，然后通过Docker部署Redis-cell，并展示了如何使用Jedis库自定义指令进行集成。最后提供了一个测试类`RedisCellTest`，演示了如何调用限流功能。参考《Redis的深度历险》了解更多。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

Redis-cell限流模块在java中的基本使用

基本介绍

Redis-cell模块是Redis4.0提供的一个限流模块，该模块使用了漏斗算法，提供了原子的限流指令，唯一的一条指令就是

cl.throttle 唯一的指令
		cl.throttle zedomi:reply 15 30 60 1
		漏斗容量15，每60s最多30次(漏水速率)
		返回值：0 运行 1 拒绝
			 15 漏斗容量capacity
			 14 漏斗剩余空间 left_quota
			 -1 被拒绝了，多长时间后重试()
			 2  多长时间后，漏斗完全空出来(单位秒)

Docker安装

docker pull hsz1273327/redis-cell //拉取镜像
docker run -d -p 6380:6379 hsz1273327/redis-cell  //映射至6380端口
redis-cli -p 6380 //启动客户端

JAVA集成

引入Maven包

<!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>3.5.0</version>
        </dependency>

编写指令

//因为是扩展的指令，所以需要自己定义指令
import redis.clients.jedis.commands.ProtocolCommand;
import redis.clients.jedis.util.SafeEncoder;

public enum CellCommand implements ProtocolCommand {

    CLTHROTTLE("CL.THROTTLE");

    private final byte[] raw;

    CellCommand(String alt) {
        raw = SafeEncoder.encode(alt);
    }

    @Override
    public byte[] getRaw() {
        return raw;
    }
}

import redis.clients.jedis.Client;
import redis.clients.jedis.Jedis;
import java.util.List;

/**
 * 测试类
 */
public class RedisCellTest {

    private Jedis jedis;

    public RedisCellTest(Jedis jedis) {
        this.jedis = jedis;
    }


    public boolean isActionAllow(String key, String capacity, String number, String time) {
        Client client = jedis.getClient();
        boolean is;
        client.sendCommand(CellCommand.CLTHROTTLE, key, capacity, number, time);
        List<Long> replay = client.getIntegerMultiBulkReply();

        if (replay.get(2) > 0) {
            is = true;
        } else {
            is = false;
        }

        System.out.println(replay);
        client.close();
        return is;
    }

    public static void main(String[] args) {

        RedisCellTest redisCellTest = new RedisCellTest(new Jedis("192.168.31.149", 6381));

        for (int i = 0; i < 20; i++) {
            System.out.println(redisCellTest.isActionAllow("zedomi:reply", "14", "30", "60"));
        }
        
    }
}