对Hiredis进行了简单封装1、API进行统一，对外只提供一个接口；2、屏蔽上层应用对连接的细节处理；3、底层采用队列的方式保持连接池，保存连接会话；4、重连时采用时间戳进行控制，每隔一定时间(3s)重连一次，防止频繁重试造成的不必要浪费。先看一下Hiredis的常用数据结构与API：//hiredis/hiredis.h/* Context for a connection to Redis */typedef struct redisContext { int err; /* Error flags, 0 when there is no error...
import redisdef create_redis_pool():REDIS_DB = ‘127.0.0.1‘REDIS_PORT = 6379pool = redis.ConnectionPool(host=REDIS_DB, port=REDIS_PORT, max_connections=1024)conn = redis.Redis(connection_pool=pool)print(‘创建redis连接池成功‘)return connconn = create_redis_pool()
print(len(conn.smembers(‘all_urls‘)))
list1 = [i.decode().split(‘-‘)[-1] for i in conn.smembers(‘all_urls‘)]
print(list1)
原文：...
在新的项目中用到了Redis做ORM的二级缓存，一开始是每次New一个新的Client去连接服务器，发现没过多久，服务器的连接池就爆掉了，于是用PooledRedisClientManager来做客户端连接池的管理，但是发现，无论怎么设置链接池的数量，客户端发起的连接数根本不受控制，还是一次一个新连接，很是郁闷，上Stackoverflow上搜了很久，没有一个办法能解决问题的，无奈之下只能连ServiceStack.Redis的源码进行调试，百般努力下终于发现端倪，罪...
package com.lee.utils;import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;public final class RedisPool {//Redis服务器IPprivate static String ADDR = "127.0.0.1";//Redis的端口号private static Integer PORT = 6379;//访问密码private static String AUTH = "12345";//可用连接实例的最大数目，默认为8；//如果赋值为-1，则表示不限制，如果pool已经分配...
服务进程中的服务方法blpop阻塞在redis队列下(等待请求)， 使用方（客户代码）向该队列push请求以促使服务方法在阻塞的代码行继续运行下去。
服务方法使用了mybatis的SqlSessionTemplate， 在进入服务方法时spring为mybatis调用了连接池druid的getConnection，
假设很久没有请求来，一直阻塞在blpop处，直到mysql的wait_timeout默认8小时到达（导致mysql实际上已经关闭了该连接），
而此时处在方法内...
: // 从redis当中获取返回值int IntegerResult(OUT long long &result);int StringResult(OUT string &result);int StatusResult(OUT string &result);int StringArrayResult(OUT vector<string> &result);int ArrayResult(OUT vector<redisReply*> &result); 同样也是因为Redis不是关系型数据库，所以需要对返回值的pResult的type进行检查。检查之后再执行对应的函数。 #ifndef _REDIS_OBJ_H
#define _REDIS_OBJ_H#include <hire...
分享一下 golang 实现的 redis 和 mysql 连接池，可以在项目中直接引用连接池句柄，调用对应的方法。 举个栗子：
1 mysql 连接池的使用
（1） 在项目子目录放置 mysql.go
（2）在需要调用的地方导入连接池句柄 DB
（3）调用 DB.Query()
2 redis 连接池的使用
（1）在项目子目录放置 redis.go
（2）在需要调用的地方导入连接池句柄 Cache
（3）调用 Cache.SetString (“test_key”, “test_value”)
最新代码地址：
https://githu...
NoSQL 泛指非关系型的数据库。非关系型数据库与关系型数据库的差别
非关系型数据库的优势：
1.性能NOSQL 是基于键值对的，可以想象成表中的主键和值的对应关系，而且不需要经过SQL 层的解析，所以性能非常高。
2.可扩展性同样也是因为基于键值对，数据之间没有耦合性，所以非常容易水平扩展。
关系型数据库的优势：
1. 复杂查询可以用SQL语句方便的在一个表以及多个表之间做非常复杂的数据查询。
2.事务支持使得对于安全性能很高...
NodeJS 上图中，nodejs共有俩连接，分别发送查询请求到redis服务器上。因为redis是单线程作业，不管两个查询任务是由一个连接发来还是多个连接发来，也不管任务是串行一前一后先后发送到服务器，还是并行的同时发送到服务器上，redis都将他们一个个按顺序执行，并通过当前连接返回给客户端(这里是nodejs)。nodejs接受到redis的返回后，也管不了并行不并行，都得等他nodejs的主线程空闲的时候才能来一个个处理服务器返回的数据。所以...
import redisdef create_redis_pool():REDIS_DB = '127.0.0.1'REDIS_PORT = 6379pool = redis.ConnectionPool(host=REDIS_DB, port=REDIS_PORT, max_connections=1024)conn = redis.Redis(connection_pool=pool)print('创建redis连接池成功')return connconn = create_redis_pool()
print(len(conn.smembers('all_urls')))
list1 = [i.decode().split('-')[-1] for i in conn.smembers('all_urls')]
print(list1)
Java连接Redis
Jedis连接Redis,Lettuce连接Redis
Jedis连接Redis
1. 创建maven项目
2. 引入依赖<dependencies><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.11</version><scope>test</scope></dependency><dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>2.9.0</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombo...
什么是连接池
通常情况下, 当我们需要做redis操作时, 会创建一个连接, 并基于这个连接进行redis操作, 操作完成后, 释放连接,
一般情况下, 这是没问题的, 但当并发量比较高的时候, 频繁的连接创建和释放对性能会有较高的影响
于是, 连接池就发挥作用了
连接池的原理是, 通过预先创建多个连接, 当进行redis操作时, 直接获取已经创建的连接进行操作, 而且操作完成后, 不会释放, 用于后续的其他redis操作
这样就达到了避免频繁的redis连...
Redis持久化
1.概述：Redis的高性能是由于其将所有数据都存储在了内存中，为了使Redis在重启之后仍能保证数据不丢失，需要将数据从内存中同步到硬盘中，这一过程就是持久化。Redis支持两种方式的持久化，一种是RDB方式，一种是AOF方式。可以单独使用其中一种或将二者结合使用。
2.Rdb持久化(默认支持，无需配置）*该机制是指在指定的时间间隔内将内存中的数据集快照写入磁盘。
3.AOF持久化*该机制将以日志的形式记录服务器所处理的...
1.为什么要使用连接池
一个数据库服务器只拥有有限的连接资源，一旦所有的连接资源都在使用，那么其它需要连接的资源就只能等待释放连接资源。所以，在连接资源有限的情况下，提高单位时间的连接的使用效率，缩短连接时间，就能显著缩短请求时间。
所以就有了连接池的概念，在初始化时，创建一定数量的连接，先把所有连接存起来，然后，谁需要使用，从这里取走，干完活立马放回来。 如果请求数超出连接池容量，那么就排队等待或者直...
在之前spring boot集成redis的文章中曾今指出如果没有配置redis连接池的信息（即使存在默认的连接信息），那么在使用redisTemplate的时候，是不会使用连接池的。这一篇文章我们将从源码中分析这其中的原因。
首先我们需要看一下redisTemplate获取redis连接的源码：
//redisTemplate获取连接实际上是通过JedisConnectionFactory来获取的
protected Jedis fetchJedisConnector() {try {//由这里可以看出，如果pool对象为null，那么每...
