go的一些工具类,大量运用了泛型,最低要求 golang 1.18

项目遵守:

• 不引入任何第三方库
• 全力使用泛型
• 尽量优化性能
• 提供优雅可读的函数签名

本项目可能会有破坏性的修改函数签名行为,不要轻易升级

简单说明

• seq
  一个高性能的golang的泛型链式调用库,实现了类似java stream逻辑,不依赖chan和goroutine,支持任意类型的链式调用,支持并行化( 可限制并行数量),排序等

  // 从19开始,每次减3,直到-10,额外添加-100,100,10,0,1,过滤出偶数,再丢弃前5个,从小到大排序,打印到控制台
  FromIntSeq(19, -10, -3).Add(-100,100,10,0,1).Filter(func(i int) bool {
      return i%2 == 0
  }).Drop(5).Sort(LessT[int]).ForEach(func(i int) {
      fmt.Println(i)
  })
  // a 1 b 2 c 3
  // "a,b,c"
  BiFromMap(map[string]int{"a": 1, "b": 2, "c": 3}).OnEach(func(k string, v int) {
      print(k, v)
  }).JoinStringBy(func(k string, v int) string {
      return k
  }, ",")

  更多例子见: seq_test.go biSeq_test.go 如果使用seq处理大interface{},可能会导致编译速度下降,编译缓存磁盘占用大

  参考来源: https://mp.weixin.qq.com/s/v-HMKBWxtz1iakxFL09PDw

• config
  工作模式类似spring配置工具类

  // 构造嵌套配置map
  cfg := map[string]any{
      "database": map[string]any{
          "host": "localhost",
          "port": 3306,
      },
  }
  // 通过路径读取嵌套值,支持自动类型转换和默认值
  host := config.GetByPath(cfg, "database.host")           // "localhost"
  port := config.ValueFromPath(cfg, "database.port").Int()  // 3306
  timeout := config.ValueFromPath(cfg, "database.timeout").IntD(5) // 5 (默认值)

  更多例子见: config/README.md config_test.go

• unsafe
  获取goroutine id,hash等不安全操作

• concurrent
  一些并发相关的工具,包含可重入锁,MPMC队列,滑动窗口限流,原子计数器等

  // Int64Adder: 高并发原子计数器,类似Java LongAdder
  adder := &concurrent.Int64Adder{}
  adder.AddSimple(10) // 原子递增
  adder.AddSimple(20)
  val := adder.Sum() // 30
  
  // 滑动窗口限流: 1秒内最多允许100次请求,分为10个窗口
  sw := concurrent.NewSlidingWindow(1000, 100, 10)
  if sw.CanDo() {
      // 允许执行
  } else {
      // 被限流,拒绝
  }

  更多例子见: README.md int64_adder_test.go sliding_window_test.go

• pool
  一些池化工具:携程池,对象池

  // 对象池:复用对象减少GC压力
  pool := pool.NewObjectPool[bytes.Buffer](
      func() *bytes.Buffer { return &bytes.Buffer{} },
      func(b *bytes.Buffer) { b.Reset() }, // 归还时重置状态
  )
  buf := pool.Get()   // 获取对象
  buf.WriteString("hello")
  pool.Put(buf)       // 归还对象
  
  // 字符串池:用数字ID代替长字符串,适合做Map的Key
  sp := pool.NewStringPool()
  id := sp.Use("long-long-key-string")  // 分配ID,引用计数+1
  sp.UnUse("long-long-key-string")      // 释放引用,归零时自动清理

• storage
  map等存储工具,swissMap,gls等

  // 泛型Map:默认使用高性能Swiss Map实现
  m := storage.NewMap[string, int]() // 等价于 storage.NewMap(storage.MapTypeSwiss[string, int](16))
  m.Put("hello", 1)
  v, ok := m.Get("hello")  // 1, true
  m.Iter(func(k string, v int) bool {
      println(k, v)
      return false
  })
  m.Delete("hello")
  
  // 并发安全Map
  cm := storage.NewMap(storage.MapTypeSwissConcurrent[string, int]())
  
  // Goroutine Local Storage:类似Java ThreadLocal
  storage.KnowHowToUseGls() // 使用前必须声明已知用法
  var traceId = storage.NewGlsItem[string]() // 全局定义key
  func() {
      traceId.Set("abc-123")            // 在当前goroutine存储
      val, _ := traceId.Get()           // "abc-123"
      println(val)
      traceId.Delete(true)              // 使用完毕必须清理,参数true表示自动清理无其他key的goroutine
  }()

  更多例子见: map_test.go gls_test.go

• logger 日志工具

• helper 一些工具,如: 字符串处理,时间日期处理,cron任务,延时任务 等

• di 高性能依赖注入容器,支持完整的生命周期管理、配置注入和钩子系统

• script 嵌入式脚本语言引擎,支持动态脚本执行、变量绑定、外部函数调用和完整控制流

  // 单行脚本执行
  result, err := script.Eval("10 + 20")
  fmt.Println(result.Int()) // 30
  
  // 带变量绑定执行
  result, _ = script.EvalWithBindings(`
      x :=>int getBindValue("x")
      y :=>int getBindValue("y")
      x + y
  `, map[string]any{"x": 10, "y": 20})
  
  // 编译一次,多次执行
  parser := script.NewParser()
  engine := script.NewEngine()
  ctx := script.NewContext()
  ctx.BindFunc("double", func(x int) int { return x * 2 })
  compiled, _ := parser.Compile(`
      #fn double(int)=>int
      double(21)
  `)
  result, _ = engine.Run(ctx, compiled) // 42

  更多例子见: README.md