Commit c9688c9a by wang

删除test文件

parent d2cb5033
......@@ -24,4 +24,4 @@ cmd.exe~
/controller/test.lua
/open/redisLock
/tests
/controller/test.go
package controller
import (
"fmt"
"github.com/gin-gonic/gin"
"github.com/gogf/gf/util/gconv"
"golang_open_platform/model"
......@@ -60,7 +59,6 @@ func GetClassList(ctx *gin.Context) {
common.NResponse("parent_id 必填",open.PARAM1,nil).OutPut(ctx)
return
}
fmt.Printf(parent_id)
rsp,err:=service.NewClassService().GetClassList(gconv.Int(parent_id))
e.CheckError(err)
common.NResponse("",0,rsp).OutPut(ctx)
......
package controller
import (
"fmt"
"github.com/gin-gonic/gin"
"github.com/gomodule/redigo/redis"
"golang_open_platform/pkg/common"
"golang_open_platform/pkg/e"
"golang_open_platform/pkg/gredis"
)
func TestRequest(ctx *gin.Context) {
ctx.JSON(200,nil)
}
func LuaTest() {
}
func LockTest(ctx *gin.Context) {
defer delOnlyLock("test_lock")
err:=addOnlyLock("test_lock")
if(err!=nil){
common.PrintStdout().Printf("加锁失败")
return
}
num,err:=getRedisFlowNum("abc")
fmt.Println(num)
if(err!=nil){
common.PrintStdout().Printf(err.Error())
}
if(num>=2100){
common.PrintStdout().Printf("频率限制")
ctx.JSON(200,"频率限制")
return
}
num,err=incrRedisFlowNum("abc")
if(err!=nil){
common.PrintStdout().Printf("新增报错")
}
common.PrintStdout().Printf("新增后的值"+string(num))
ctx.JSON(200,"锁测试")
}
func incrRedisFlowNum(key string) (num int,err error){
redisWriteConn := gredis.Conn("search_w")
defer redisWriteConn.Close()
num,err= redis.Int(redisWriteConn.Do("INCR", key))
if(err!=nil){
common.PrintStdout().Printf("INCR redis "+key+"错误")
//return 0,e.NewApiError("service error",FLOWERR1)
}
return num,nil
}
func abc() {
redisWriteConn := gredis.Conn("search_w")
defer redisWriteConn.Close()
}
//如果锁不存在并设置锁
func addOnlyLock(key string)error{
redisWriteConn := gredis.Conn("search_w")
defer redisWriteConn.Close()
name:="flow_lock_"+key
//common.PrintStdout().Printf("加锁 key:%s",name)
//for{
r, err:= redisWriteConn.Do("SET", name, "1", "EX", "100","NX")//锁两秒没主动删就自动关闭(防止某个流程卡死,没执行到删除锁)
if(err!=nil){
common.PrintStdout().Printf("读取redis 锁 key:%d 报错",key)
}
if(r!=nil){
return nil
}
//}
incrRedisFlowNum("err_num")
//common.PrintStdout().Printf("没读到")
return fmt.Errorf("请重试")
}
//删除锁
func delOnlyLock(key string){
redisWriteConn := gredis.Conn("search_w")
defer redisWriteConn.Close()
name:="flow_lock_"+key
_, err:= redisWriteConn.Do("DEL", name)
if(err!=nil){
println(err.Error())
}
common.PrintStdout().Printf("解锁完成")
}
func getRedisFlowNum(key string) (num int,err error){
redisReadConn := gredis.Conn("search_r")
defer redisReadConn.Close()
num,err= redis.Int(redisReadConn.Do("Get", key))
if(err!=nil && err!=redis.ErrNil){
common.PrintStdout().Printf("读取redis "+key+"错误"+err.Error())
return 0,e.NewApiError("service error",80000)
}
return num,nil
}
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment