MySQL 数据实时推给三方业务？试试用 SeaTunnel 搞定 HTTP 接入

sh bin/install-plugin.sh

[mysqld]server-id = 1          # 集群内唯一编号log-bin = mysql-bin    # 开启二进制日志binlog-format = ROW    # 必须设为ROW模式

package mainimport (    "fmt"    "io"    "log"    "net/http")// 处理所有HTTP请求，打印接收到的数据func handler(w http.ResponseWriter, r *http.Request) {    defer r.Body.Close() // 记得关闭请求体    body, err := io.ReadAll(r.Body)    if err != nil {        msg := fmt.Sprintf("读取请求体失败: %v", err)        http.Error(w, msg, http.StatusInternalServerError)        fmt.Println(msg)        return    }    if len(body) > 0 {        fmt.Printf("请求内容: %s\n", string(body))        fmt.Printf("数据大小: %d 字节\n", len(body))    } else {        fmt.Println("请求体为空")    }    // 给客户端一个成功回复    w.WriteHeader(http.StatusOK)    fmt.Fprintf(w, "数据接收成功! 大小: %d 字节。", len(body))}func main() {    http.HandleFunc("/", handler) // 所有请求都交给handler处理    fmt.Println("HTTP服务启动，端口 9090...")    fmt.Println("你可以用curl测试: curl -X POST -d '{\"test\":123}' http://localhost:9090/")    if err := http.ListenAndServe(":9090", nil); err != nil {        log.Fatal("启动服务失败: ", err)    }}

go run server.go

CREATE TABLE `post` (  `id` int(11) NOT NULL,  `content` varchar(50) DEFAULT NULL,  `author` varchar(50) DEFAULT NULL,  PRIMARY KEY (`id`)) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;INSERT INTO `post` VALUES (1, 'Mysql入门', '张三');INSERT INTO `post` VALUES (2, 'Http解析', '李四');

env {  parallelism = 1  job.mode = "STREAMING"      # 流式任务模式  checkpoint.interval = 10000  # 10秒做一次检查点}source {  MySQL-CDC {    username = "root"    password = "root"    table-names = ["your_database.post"] # 改成你的数据库和表名    url = "jdbc:mysql://你的MySQL地址:3306/your_database" # 修改为你的连接信息    schema-changes.enabled = true # 允许表结构变更  }}sink {  Http {    url = "http://你的服务地址:9090/" # 改成你的HTTP服务地址    headers {      Accept="application/json",      Content-Type="application/json;charset=utf-8"    }  }}

bin/seatunnel.sh --config job/mysqlcdc_http.conf -m local

E:\>go run server.goStarting HTTP server on port 9090...Send POST/PUT requests with body data to test.Example: curl -X POST -d '{"message":"test"}' http://localhost:9090/Request Body Content: {"id":1,"content":"Mysql入门","author":"张三"}Body Length: 50 bytesRequest Body Content: {"id":2,"content":"Http解析","author":"李四"}Body Length: 49 bytes

INSERT INTO `post` VALUES (3, 'SeaTunnel实时同步测试', '王五');

Request Body Content: {"id":3,"content":"SeaTunnel实时同步测试","author":"王五"}Body Length: 66 bytes