Flash 简介

Flash 是一款轻量级的 Go 语言库，它利用事件管理机制，实现了对 PostgreSQL 数据库变化的实时监控。开发者可以通过 Flash 轻松地监听数据库中特定表的变化，并在变化发生时执行自定义的回调函数。

核心功能

Flash 提供了丰富的功能来满足各种实时数据处理需求，其核心功能包括：

• 实时监听： Flash 允许开发者在程序运行时启动和停止对数据库变化的监听，提供了高度的灵活性。
• 事件支持： Flash 支持常见的 PostgreSQL 数据库事件，包括插入、更新、删除和清空表操作。
• 驱动接口： Flash 提供了驱动接口，开发者可以轻松地创建新的驱动程序以支持其他数据库系统。
• 并行回调： Flash 利用 goroutine 实现了并行回调执行，确保了高效的数据处理能力。
• 字段级监听： 开发者可以选择监听特定字段的变化，而无需监听整行的变化，提高了数据处理的效率。
• WAL 复制： Flash 支持使用 WAL（Write-Ahead Logging）复制来监听数据库变化，确保了数据的完整性和一致性。

快速上手

使用 Flash 非常简单，以下是一个基本的示例：

package main

import (
 "fmt"
 "github.com/quix-labs/flash/pkg/listeners"
 "os"
 "os/signal"

 "github.com/quix-labs/flash/pkg/client"
 "github.com/quix-labs/flash/pkg/types"
)

func main() {
 // 配置监听器，监听 public.posts 表
 postsListenerConfig := &types.ListenerConfig{Table: "public.posts"}
 postsListener := listeners.NewListener(postsListenerConfig)

 // 设置事件回调函数
 postsListener.On(types.OperationAll, func(event types.Event) {
  switch typedEvent := event.(type) {
  case *types.InsertEvent:
   fmt.Printf("insert - new: %+v\n", typedEvent.New)
  case *types.UpdateEvent:
   fmt.Printf("update - old: %+v - new: %+v\n", typedEvent.Old, typedEvent.New)
  case *types.DeleteEvent:
   fmt.Printf("delete - old: %+v \n", typedEvent.Old)
  case *types.TruncateEvent:
   fmt.Printf("truncate \n")
  }
 })

 // 创建客户端并连接数据库
 clientConfig := &types.ClientConfig{DatabaseCnx: "postgresql://user:password@host:port/database"}
 flashClient, _ := client.NewClient(clientConfig)

 // 将监听器添加到客户端
 flashClient.Attach(postsListener)

 // 启动监听
 go flashClient.Start()
 defer flashClient.Close()

 // 监听程序中断信号
 interrupt := make(chan os.Signal, 1)
 signal.Notify(interrupt, os.Interrupt)
 <-interrupt

 fmt.Println("Program terminated.")
}

高级功能

除了基本功能外，Flash 还提供了一些高级功能，例如：

• 可配置主键： 开发者可以自定义主键，当主键值发生变化时，Flash 会触发删除事件和插入事件，方便开发者追踪数据的变化。
• 自定义条件： 开发者可以设置自定义条件，只有满足条件的数据才会触发事件，提高了数据处理的精准度。
• 部分字段监听： 开发者可以选择监听表中特定字段的变化，减少不必要的数据传输和处理。