go~在阿里mse上利用redis.call

相关依赖

• github.com/higress-group/proxy-wasm-go-sdk
  
• github.com/alibaba/higress/plugins/wasm-go
  

标准的redis

下面是一个读取redis指定key的方法，利用了higress的wasm-go组件实现的

1.         err := config.Client.SMembers("online", func(response resp.Value) {
2.                 for _, item := range response.Array() {
3.                         str := item.String()
4.                         if strings.HasPrefix(str, """) {
5.                                 str = str[1:]
6.                         }
7.                         if strings.HasSuffix(str, """) {
8.                                 str = str[:len(str)-1]
9.                         }
10.                         if str == val {
11.                                 msg := fmt.Sprintf("your %v (%v) is illegality.", blackType, val)
12.                                 fmt.Println(msg)
13.                                 ctx.SetContext("X-Blacklist-Reason", msg)
14.                                 proxywasm.SendHttpResponse(ERROR_CODE, nil, []byte(msg), -1)
15.                                 break
16.                         }
17.                 }
18.                 proxywasm.ResumeHttpRequest() // 恢复
19.         })

复制代码

扩展的Lua方式

在Redis的Lua脚本中，可以利用redis.call来实行Redis命令。如果需要在Lua脚本中设置键的过期时间，可以通过调用EXPIRE命令来实现。
下面是一个示例，演示如安在Lua脚本中利用redis.call实行EXPIRE命令来设置键的过期时间：

1. local key = KEYS[1]
2. local ttl = ARGV[1]
4. redis.call('SET', key, 'value')
5. redis.call('EXPIRE', key, ttl)
7. return 'Key set with expiration time'

复制代码

在上面的示例中，首先通过KEYS[1]获取传入的键名，通过ARGV[1]获取传入的过期时间（以秒为单位）。然后利用redis.call('SET', key, 'value')设置键值对，并利用redis.call('EXPIRE', key, ttl)设置键的过期时间为ttl秒。最后返回一个提示信息。
通过这种方式，你可以在Lua脚本中利用redis.call实行EXPIRE命令来设置键的过期时间。
github.com/alibaba/higress/plugins/wasm-go中的Eval

阿里封装的wasm-go插件，在2024-03-18这一天支持了redis，同时也支持利用redis.call，你可以调用wasm-go中的Eval方法

• 方法原型
  

1. Eval(script string, numkeys int, keys, args []interface{}, callback RedisResponseCallback) error

复制代码

• 开发人员调用它
  

1.         redisKey := "business:username"
2.         redisKey2 := "business:session_state"
3.         var keyArr []interface{}
4.         keyArr = append(keyArr, redisKey, redisKey2)
5.         var valueArr []interface{}
6.         valueArr = append(valueArr, logger.Username, logger.Username+"_"+logger.SessionState, 60*60*24*30)
7.         err2 := config.Client.Eval("redis.call('ZINCRBY', KEYS[1], 1, ARGV[1]) redis.call('ZINCRBY', KEYS[2], 1, ARGV[2]) redis.call('EXPIRE', KEYS[1], ARGV[3]) redis.call('EXPIRE', KEYS[2], ARGV[3]) return 1", 2, keyArr, valueArr, func(response resp.Value) {
8.                 if response.Integer() == 1 {
9.                         proxywasm.ResumeHttpRequest()
10.                 }
11.         })
12.         if err2 != nil {
13.                 return types.ActionContinue
14.     }
15.    return types.ActionPause

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。