查看连接数

controller/sample_controller.go

 package controller
 package controller
 
 
 import (
 import (
-	"github.com/gin-gonic/gin"
 	"go_sku_server/pkg/common"
 	"go_sku_server/pkg/common"
+	"go_sku_server/pkg/gredis"
 	"go_sku_server/service"
 	"go_sku_server/service"
+
+	"github.com/gin-gonic/gin"
 )
 )
 
 
-//获取样片分类列表
+// 获取样片分类列表
 func SampleClassList(ctx *gin.Context) {
 func SampleClassList(ctx *gin.Context) {
 	var sampleClassService service.SampleClassService
 	var sampleClassService service.SampleClassService
 	classList, err := sampleClassService.GetSampleClassList()
 	classList, err := sampleClassService.GetSampleClassList()
@@ -18,7 +20,7 @@ func SampleClassList(ctx *gin.Context) {
 	return
 	return
 }
 }
 
 
-//获取样片列表
+// 获取样片列表
 func SampleList(ctx *gin.Context) {
 func SampleList(ctx *gin.Context) {
 	var sampleClassService service.SampleService
 	var sampleClassService service.SampleService
 	sampleList, err := sampleClassService.GetSampleList(ctx)
 	sampleList, err := sampleClassService.GetSampleList(ctx)
@@ -29,3 +31,8 @@ func SampleList(ctx *gin.Context) {
 	common.Output(ctx, 0, "success", sampleList)
 	common.Output(ctx, 0, "success", sampleList)
 	return
 	return
 }
 }
+
+func TestRedis(ctx *gin.Context) {
+	gredis.GetPoolStats("default_r")
+	gredis.GetPoolStats("spu")
+}

pkg/gredis/redis.go

@@ -206,3 +206,10 @@ func HgetPi2(redisCon string, hkey string, targetIds []string) map[string]string
 	}
 	}
 	return skuArr
 	return skuArr
 }
 }
+
+func GetPoolStats(redisCon string) {
+	pool := ichuntRedis_.RedisList[redisCon]
+	stats := pool.Stats()
+	fmt.Printf("Active: %d, Idle: %d\n",
+		stats.ActiveCount, stats.IdleCount)
+}

routes/router.go

 package routes
 package routes
 
 
 import (
 import (
-	"github.com/gin-gonic/gin"
 	"go_sku_server/controller"
 	"go_sku_server/controller"
+
+	"github.com/gin-gonic/gin"
 )
 )
 
 
-//初始化路由
+// 初始化路由
 func InitRouter() *gin.Engine {
 func InitRouter() *gin.Engine {
 	r := gin.New()
 	r := gin.New()
 
 
@@ -14,27 +15,27 @@ func InitRouter() *gin.Engine {
 
 
 	//联营参数选择搜索
 	//联营参数选择搜索
 	r.GET("synchronization", controller.Synchronization)
 	r.GET("synchronization", controller.Synchronization)
-	r.POST("synchronization",controller.Synchronization)
+	r.POST("synchronization", controller.Synchronization)
 
 
 	//联营参数选择搜索
 	//联营参数选择搜索
 	r.GET("Synchronization", controller.Synchronization)
 	r.GET("Synchronization", controller.Synchronization)
-	r.POST("Synchronization",controller.Synchronization)
+	r.POST("Synchronization", controller.Synchronization)
 
 
-	r.POST("Ladderprice",controller.SkuLadderprice)
-	r.POST("ladderprice",controller.SkuLadderprice)
+	r.POST("Ladderprice", controller.SkuLadderprice)
+	r.POST("ladderprice", controller.SkuLadderprice)
 
 
 	//心跳
 	//心跳
 	r.GET("hbsdata", controller.Hbsdata)
 	r.GET("hbsdata", controller.Hbsdata)
-	r.POST("hbsdata",controller.Hbsdata)
+	r.POST("hbsdata", controller.Hbsdata)
 
 
 	//自营SaveSku
 	//自营SaveSku
-	r.POST("SaveSku",controller.Error_Middleware(),controller.SaveSku)
-	r.POST("SkuEdit",controller.Error_Middleware(),controller.SkuEdit)
+	r.POST("SaveSku", controller.Error_Middleware(), controller.SaveSku)
+	r.POST("SkuEdit", controller.Error_Middleware(), controller.SkuEdit)
 
 
 	//样片相关
 	//样片相关
-	r.POST("/self/sample/class/list",controller.SampleClassList)
-	r.POST("/self/sample/list",controller.SampleList)
-
+	r.POST("/self/sample/class/list", controller.SampleClassList)
+	r.POST("/self/sample/list", controller.SampleList)
+	r.GET("/testRedis", controller.TestRedis)
 
 
 	return r
 	return r
 }
 }