go 快速入門2 ： 搭建簡單RPC服務器部署，子服務器通過心跳保持長連接。

將client代碼部署在各個服務器，通過心跳與monitor保持聯系，
monitor統一任務下放，簡單的例子，還沒有具體實現。

//agent
package main

import (
    "fmt"
    "net/rpc/jsonrpc"
    "log"
    "time"
    "net/rpc"
    "strconv"
    "domain"
)

var Clo chan bool

func main() {
    Clo = make(chan bool)
    client, err := jsonrpc.Dial("tcp", "127.0.0.1:8088")
    if err != nil {
        log.Fatal("dialhttp: ", err)
    }
    defer client.Close()
    go Handler(client)
    select {
    case <- Clo:
        fmt.Println("關閉連接")
    }
}

func Handler(client *rpc.Client) {
    go heartBeat(client)
}

func GetTask(client *rpc.Client) {
    var reply *domain.DeployTaskJob
    err := client.Call("MyRPC.DeployJob", "agent1", &reply)
    if err != nil {
        log.Fatal("call DeployJob: ", err)
    }
    fmt.Println("getTask success")
    fmt.Println(*reply)
}

func heartBeat(client *rpc.Client) {
    i :=0
    for {
        time.Sleep(5 * time.Second)
        var reply *domain.ReplyMessage
        fmt.Println("send HeartBeat"+strconv.Itoa(i))
        m := domain.HeartMessage{"agent1", "heart"}
        err := client.Call("MyRPC.HeartBeat", m, &reply)
        fmt.Println(*reply)
        if err != nil {
            log.Fatal("call heartBeat: ", err)
        }
        if reply.Ack{
            fmt.Println("heartBeat normal")
        }
        if reply.TaskStatus{
            fmt.Println("need to get task")
        }
        i++
        go GetTask(client);
    }
}

 

//SERVER
package main

import (
"fmt"
"net"
"net/rpc"
"net/rpc/jsonrpc"
"os"
    "domain"
)


type MyRPC int

func (r *MyRPC) HeartBeat(M domain.HeartMessage, reply *domain.ReplyMessage) error {
    fmt.Println(M)
    reply.Ack = true

    //此處遍歷任務隊列
    reply.TaskStatus = true
    return nil
}

func (r *MyRPC) DeployJob(name string, deployTaskJob *domain.DeployTaskJob) error {
    fmt.Println(name)
    //此處根據agent name取出對應的任務
    deployTaskJob.TaskName = "epoch"
    deployTaskJob.ShCommand = "ls -a"
    deployTaskJob.TaskRemotePath = "/opt/test"
    return nil
}

func main() {
    r := new(MyRPC)
    rpc.Register(r)

    tcpAddr, err := net.ResolveTCPAddr("tcp", "127.0.0.1:8088")
    checkError(err)

    listener, err := net.ListenTCP("tcp", tcpAddr)
    checkError(err)

    for {
        conn, err := listener.Accept()
        if err != nil {
            continue
        }
        jsonrpc.ServeConn(conn)
        fmt.Println("開始監聽")
    }

}

func checkError(err error) {
    if err != nil {
        fmt.Println("Fatal error ", err.Error())
        os.Exit(1)
    }
}