十年网站开发经验 + 多家企业客户 + 靠谱的建站团队
量身定制 + 运营维护+专业推广+无忧售后,网站问题一站解决
java操作redis中如何使用expire模拟指定时间段内限制ip访问的次数,很多新手对此不是很清楚,为了帮助大家解决这个难题,下面小编将为大家详细讲解,有这方面需求的人可以来学习下,希望你能有所收获。
惠济网站建设公司创新互联建站,惠济网站设计制作,有大型网站制作公司丰富经验。已为惠济上千提供企业网站建设服务。企业网站搭建\成都外贸网站制作要多少钱,请找那个售后服务好的惠济做网站的公司定做!
首先加入maven依赖,使用JUinit做单元测试。
redis.clients jedis 2.7.0 junit junit 3.8.1 test
redisutil类,创建一个线程池,可以返回redis连接资源以及释放资源
/** * redis工具类,从redis链接池中获取一个链接资源 * @author Hades * time:2015年12月14日 */ public class RedisUtils { //定义连接池 public static JedisPool pool = null; /** * 获取链接资源 * @return */ public static synchronized Jedis getJedis() { if(pool==null){ JedisPoolConfig jedisPoolConfig = new JedisPoolConfig(); jedisPoolConfig.setMaxTotal(100);//最大连接数 jedisPoolConfig.setMaxIdle(10); jedisPoolConfig.setMaxWaitMillis(1000);//类似于超时时间 jedisPoolConfig.setTestOnBorrow(true); pool = new JedisPool(jedisPoolConfig,"192.168.57.133",6379);//创建连接池 } Jedis jedis = pool.getResource(); return jedis; } /** * 释放链接资源 * @param jedis */ public static void returnJedis(Jedis jedis) { pool.returnResourceObject(jedis); }
redis客户端类,使用的是juinit做单元测试哈
/** * redis测试类 * @author Hades * */ public class RedisTest { static Jedis jedis =RedisUtils.getJedis(); @Test public void test3() throws Exception { String ip ="192.168.57.2";//访问的ip //测试 for (int i = 0; i < 20; i++) { boolean flag = testLogin(ip); System.out.println(flag); } } /** * 模拟限制ip指定时间段内访问次数 * @param ip * @return */ public boolean testLogin(String ip) { String value = jedis.get(ip); if(value==null){ jedis.set(ip, "1"); jedis.expire(ip, 60);//设置过期时间60秒 return true; }else{ int parseInt = Integer.parseInt(value); //60秒内访问超过10次,就禁止访问 if(parseInt>10){ System.out.println("访问受限!!!!"); return false; } jedis.incr(ip); } return true; } /** * 不使用管道 向jedis插入一万条数据消耗时间:3184 */ @Test public void test2() throws Exception{ // TODO Auto-generated method stub long start = System.currentTimeMillis(); for (int i = 0; i < 10000; i++) { jedis.set("a"+i, i+""); jedis.expire("a"+i, 60); } System.out.println(System.currentTimeMillis()-start); } /** * 使用管道命令批量导入数据 所需时间:204 * @throws Exception */ @Test public void test4() throws Exception { long start = System.currentTimeMillis(); Pipeline pipelined = jedis.pipelined(); for (int i = 0; i < 10000; i++) { pipelined.set("a"+i, i+""); pipelined.expire("a"+i, 60); } pipelined.sync(); System.out.println(System.currentTimeMillis()-start); } }
看完上述内容是否对您有帮助呢?如果还想对相关知识有进一步的了解或阅读更多相关文章,请关注创新互联行业资讯频道,感谢您对创新互联的支持。