Canal 中文
Canal supports redis 2.x to 5.x and forward compatible replication tools with hybrid (rdb + aof) protocol
- Redis data synchronization across computer rooms
- Heterogeneous data migration; such as Redis to mysql, MQ, ES, etc.
Simulate the redis slave, then go to dump the rdb and aof of the redis master (add the architecture design diagram later)
- Support redis 2.x to 5.x data synchronization
- Support full synchronization and incremental synchronization (continued resume)
- Support failover
- Faster
- 2k + redis instance data synchronization
go get github.com/yametech/canalpackage main
import (
"github.com/yametech/canal"
"log"
"os"
"time"
)
type printer struct{}
func (p *printer) Command(cmd *canal.Command) error {
log.Printf("[PRINTER] cmd=%v\n", cmd)
return nil
}
func main() {
log.SetOutput(os.Stdout)
cfg, err := canal.NewConfig(
"127.0.0.1:6379",
canal.DialKeepAlive(time.Hour*16800),
canal.DialWithLocalPort(6379), // use specified local port
)
if err != nil {
panic(err)
}
repl, err := canal.NewCanal(cfg)
if err != nil {
panic(err)
}
defer repl.Close()
if err := repl.Run(&printer{}); err != nil {
panic(err)
}
}// starting from the location of an instance example
package main
import (
"github.com/yametech/canal"
"log"
"os"
"time"
)
type printer struct{}
func (p *printer) Command(cmd *canal.Command) error {
log.Printf("[PRINTER] cmd=%v\n", cmd)
return nil
}
func main() {
log.SetOutput(os.Stdout)
cfg, err := canal.NewConfig(
"127.0.0.1:8888",
canal.DialKeepAlive(time.Minute*5),
)
if err != nil {
panic(err)
}
repl, err := canal.FromOffsetCanal(cfg, "0cc79e52c7cdcaa58535bb2ce23f46ee1343246c", 111)
if err != nil {
panic(err)
}
defer repl.Close()
if err := repl.Run(&printer{}); err != nil {
panic(err)
}
}//
type printer struct{}
func (p *printer) Command(cmd *canal.Command) error {
log.Printf("[PRINTER] cmd=%s\n", cmd.String())
return nil
}
func main() {
log.SetOutput(os.Stdout)
cfg, err := canal.NewConfig(
"127.0.0.1:6379",
canal.DialKeepAlive(time.Minute*5),
// canal.DialPassword(""),
)
if err != nil {
panic(err)
}
cfg.ReplMaster()
repl, err := canal.NewCanal(cfg)
if err != nil {
panic(err)
}
defer repl.Close()
if err := repl.Run(&printer{}); err != nil {
panic(err)
}
}
- Support c / s structure, grpc cross platform use
- redis 6.x
- Support etcd, zk, consul and other storage position
- Support cluster
- Automatic maintenance of redis topology structure
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent