CSRedis.CSRedisClient Redis = RedisBase.RedisSentinelX; var s1 = Redis.Increment(k

poolsize设置多少，最好写一个接口，监控pool状态 <div class="snippet-clipboard-content notranslate po

如何释放一个链接？ about csredis HOT 4 OPEN

2881099 commented on July 21, 2024

如何释放一个链接？

from csredis.

Comments (4)

zsy619 commented on July 21, 2024

CSRedis.ConnectionPool.GetConnection 连接池获取超时（10秒）

from csredis.

2881099 commented on July 21, 2024

poolsize设置多少，最好写一个接口，监控pool状态

	[HttpGet(@"connection/redis")]
	public object GetConnectionRedis() {
		var ret = new Hashtable();
		foreach(var pool in RedisHelper.ClusterNodes) {
			List<Hashtable> list = new List<Hashtable>();
			foreach (var conn in pool.Value.AllConnections) {
				list.Add(new Hashtable() {
					{ "最后活动", conn.LastActive },
					{ "获取次数", conn.UseSum }
				});
			}
			ret.Add(pool.Key, new {
				FreeConnections = pool.Value.FreeConnections.Count,
				AllConnections = pool.Value.AllConnections.Count,
				GetConnectionQueue = pool.Value.GetConnectionQueue.Count,
				GetConnectionAsyncQueue = pool.Value.GetConnectionAsyncQueue.Count,
				List = list
			});
		}
		return ret;
	}

from csredis.

zsy619 commented on July 21, 2024

RedisHelper.ClusterNodes 这个是否为所有的节点
我这边用了5个redis库，
public static CSRedis.CSRedisClient RedisClusterX { get; set; }
public static CSRedis.CSRedisClient RedisSentinelX { get; set; }
public static CSRedis.CSRedisClient RedisCacheX { get; set; }
public static CSRedis.CSRedisClient RedisQueueX { get; set; }
public static CSRedis.CSRedisClient RedisBalanceX { get; set; }
这个方法是否能监控到这5个redis的所有链接情况

from csredis.

2881099 commented on July 21, 2024

不是，RedisHelper有自己的CSRedisClient实例。你的这五个实例，各种有独立的连接池，循环上面我发的链接池监控

	[HttpGet(@"connection/redis")]
	public object GetConnectionRedis() {
var redisclients = new [] { 你定义的五个对象 };
var allret = new Hashtable();
foreach (var redis in redisclients) {
		var ret = new Hashtable();
		foreach(var pool in redis.ClusterNodes) {
			List<Hashtable> list = new List<Hashtable>();
			foreach (var conn in pool.Value.AllConnections) {
				list.Add(new Hashtable() {
					{ "最后活动", conn.LastActive },
					{ "获取次数", conn.UseSum }
				});
			}
			ret.Add(pool.Key, new {
				FreeConnections = pool.Value.FreeConnections.Count,
				AllConnections = pool.Value.AllConnections.Count,
				GetConnectionQueue = pool.Value.GetConnectionQueue.Count,
				GetConnectionAsyncQueue = pool.Value.GetConnectionAsyncQueue.Count,
				List = list
			});
		}
		allret.Add(1, ret);
}
    return allret;

}

from csredis.

Recommend Projects