搜索到
5
篇与
All
的结果
-
Go语言精进之路-白明 | 变长参数函数的妙用 {mtitle title="目录"/}{lamp/}实现功能选项模式在日常Go编程中，我们经常会实现一些带有设置选项的创建型函数。对于一些复杂的Go包中的创建型函数，它要提供的可设置选项有时多达数十种，甚至后续还会增加。那么在选项增长的同时，依旧保持对外接口的稳定性，就成了关键。例：实现一个NewFinishedHouse函数，其中选项有：装修风格是否是中央空调地面材料墙面材料还有可能会增加的选项。版本1实现：使用结构体封装配置选项type FinishedHouse struct { style string isCentral bool floor string wall string } type Option struct { Style string IsCentral bool Floor string Wall string } func NewFinishedHouse(option *Option) *FinishedHouse { var ( style = "fashion" isCentral = true floor = "normal" wall = "standard" ) if option != nil { style = option.Style isCentral = option.IsCentral floor = option.Floor wall = option.Wall } return &FinishedHouse{ style: style, isCentral: isCentral, floor: floor, wall: wall, } }采用这种方式的好处是，当选项增加时，只需增加结构体option的字段，原本的函数签名是不变的。版本2实现：使用功能选项模式Go语言之父Rob Pike早在2014年就在其博文“自引用函数与选项设计”[2]中论述了一种被后人称为“功能选项”（functional option）的模式，这种模式应该是目前进行功能选项设计的最佳实践。type FinishedHouse struct { style string isCentral bool floor string wall string } type Option func(*FinishedHouse) func NewFinishedHouse(options ...Option) *FinishedHouse { h := &FinishedHouse{ style: "fashion", isCentral: true, floor: "normal", wall: "standard", } for _, option := range options { option(h) } return h } func WithStyle(style string) Option { return func(f *FinishedHouse) { f.style = style } } func WithIsCentral(isCentral bool) Option { return func(f *FinishedHouse) { f.isCentral = isCentral } } func WithFloor(floor string) Option { return func(f *FinishedHouse) { f.floor = floor } } func WithWall(wall string) Option { return func(f *FinishedHouse) { f.wall = wall } } func main() { fmt.Printf("%+v", NewFinishedHouse()) // 默认选项 fmt.Printf("%+v", NewFinishedHouse( WithStyle("classic"), WithIsCentral(false), )) }我们看到在该方案中，FinishedHouse的配置选项不是通过存储在结构体中的配置参数传入的，而是通过对FinishedHouse值本身进行操作的函数调用（利用函数的“一等公民”特质）实现的，并且通过使用变长参数函数，我们可以随意扩展传入的配置选项的个数。
-
-
go-canal 订阅和消费 binlog Binlog二进制的日志文件，记录着数据库中已经执行的 Sql 语句。docker-compose部署mysqlversion: '3' services: mysql5.7: container_name: mysql5.7 image: mysql:5.7 ports: - "3307:3306" command: --server_id=1513 --default-authentication-plugin=mysql_native_password --log-bin=mysql-bin --binlog-ignore-db=mysql restart: always environment: MYSQL_ROOT_PASSWORD: 123456 TZ: Asia/Shanghai volumes: - ../../data/mysql5.7:/var/lib/mysqldocker-compose up -d # 后台运行 docker exec -it mysql5.7 mysql -u root -p 123456 # 输入密码确保 binlog 开启，并且 binlog 日志格式 为 rowshow variables like 'log_bin'; // 查看 binlog show variables like 'binlog_format'; // 日志格式Tips: 外部工具无法连接请配置mysql>GRANT ALL PRIVILEGES ON *.* TO 'root'@'%' IDENTIFIED BY '123456' WITH GRANT OPTION; mysql>FLUSH PRIVILEGES; // 其中123456，可以修改为你的密码常用Binlog的sql指令show master logs; show master status; flush logs; --刷新，创建一个新的binlog文件 reset master; --清空日志文件 // 查询 mysql 的配置 mysql --help | grep 'Default options' -A 1 // 默认存储 binlog 的文件位置 > /var/lib/mysqlBinlog字段Event_typeQuery Event记录删除表创建表修改表Xid Eventcommit 提交成功的 idTable_map Event记录下一个操作对映的数据库和表名Rotate Event记录生成一张新的binlog日志表Write_rows Event # 插入Update_rows Event # 更新Delete_rows Event # 删除Event_type官方文档Go-Canal通过 Canal 订阅和消费 mysql 的 binlog。go get github.com/go-mysql-org/go-mysql@v1.4.0canal包中的接口和用法type EventHandler interface { OnRotate(roateEvent *replication.RotateEvent) error OnTableChanged(schema string, table string) error OnDDL(nextPos mysql.Position, queryEvent *replication.QueryEvent) error OnRow(e *RowsEvent) error OnXID(nextPos mysql.Position) error OnGTID(gtid mysql.GTIDSet) error OnPosSynced(pos mysql.Position, set mysql.GTIDSet, force bool) error String() string }event 类型为 Write_rows, Update_rows, Delete_rowstype BinlogSync struct { canal.DummyEventHandler } //OnRow 获取 event_type 为 write_rows, update_rows, delete_rows 的数据 func (h *BinlogSync) OnRow(ev *canal.RowsEvent) error { rowData := make(map[string]interface{}) rowList := make([]interface{}, len(ev.Rows)) fmt.Println("原始数据：", ev.Rows) fmt.Printf("sql的操作行为：%s\t", ev.Action) for idx, _ := range ev.Table.PKColumns { fmt.Printf("主键为：%s\n", ev.Table.Columns[ev.Table.PKColumns[idx]].Name) } for idxRow, _ := range ev.Rows { for columnIndex, currColumn := range ev.Table.Columns { // 字段名和对应的值 row := fmt.Sprintf("%v:%v", currColumn.Name, ev.Rows[idxRow][columnIndex]) fmt.Println(row) rowData[currColumn.Name] = ev.Rows[idxRow][columnIndex] rowList[idxRow] = rowData } } rowJson, err := json.Marshal(rowList) if err != nil { return fmt.Errorf("序列化错误：%s", err) } fmt.Printf("序列化为json格式：%s\n\n", string(rowJson)) return nil }event 类型为 Rotate// OnRotate 获取 binlog 下个日志文件名字和位置 func (h *BinlogSync) OnRotate(r *replication.RotateEvent) error { fmt.Printf("下一个日志为 %s 位置为 %d \n", string(r.NextLogName), r.Position) return nil }event 类型为 Query// OnTableChanged 在 OnDDL 之前执行 func (h *BinlogSync) OnTableChanged(schema string, table string) error { result := fmt.Sprintf("修改了数据库%s中表%s的结构", schema, table) fmt.Println(result) return nil } // OnDDL query 事件中的一些信息，如执行的 sql 语句 func (h *BinlogSync) OnDDL(nextPos mysql.Position, queryEvent *replication.QueryEvent) error { fmt.Println(string(queryEvent.Query)) return nil }Event 类型为 Xid// OnXID 打印事件 Xid 的结束为止 func (h *BinlogSync) OnXID(m mysql.Position) error { fmt.Println("XID", m.Pos) return nil }执行func main() { cfg := canal.NewDefaultConfig() cfg.Addr = "127.0.0.1:3307" cfg.User = "root" cfg.Password = "123456" // 数据库名 cfg.Dump.TableDB = "mrsnake" cfg.ServerID = 1513 // 表名 cfg.Dump.Tables = []string{"bin_log_test"} cfg.Dump.ExecutionPath = "" c, err := canal.NewCanal(cfg) if err != nil { log.Fatal(err) } // Register a handler to handler Events c.SetEventHandler(&BinlogSync{}) err = c.Run() if err != nil { log.Fatal(err) }GTID 的方式执行# ... 其他不变 startupGTID = "09e12c4e-6a25-21ec-bea1-04242ac180002" set, _ := mysql.ParseGTIDSet("mysql", startupGTID) err = c.StartFromGTID(set) if err != nil { log.Fatal(err) }
-
测试用 {dotted startColor="#ff6c6c" endColor="#1989fa"/}test{dotted startColor="#ff6c6c" endColor="#1989fa"/}test {abtn icon="" color="#ff6800" href="https://mrsnake.top" radius="" content="mrsnake"/} {card-list}{card-list-item} 列表一内容{/card-list-item}{card-list-item} 列表二内容{/card-list-item}{/card-list}{tabs}{tabs-pane label="标签一"} 标签一内容{/tabs-pane}{tabs-pane label="标签二"} 标签二内容{/tabs-pane}{/tabs}reflect包type t struct { name string } reflect.Typeof(t) // main.t reflect.Kind(t) // struct1.Typeof指变量所属的类型，Kind指变量所属的类别。const (Invalid Kind = iota,Bool,Int,Int8,Int16,Int32,Int64,Uint,Uint8,Uint16,Uint32,Uint64,Uintptr,Float32,Float64,Complex64,Complex128,Array,Chan,Func,Interface,Map,Ptr,Slice,String,Struct,UnsafePointer)2.修改接口实际变量的值Elem()获取指向原变量的指针reflect.ValueOf(a).Elem().SetInt(38)时间转换todayZero, _ := time.ParseInLocation("2006-01-02", "2021-11-26 15:22:22" time.Local)
-
