From aa3f73eef78b96c8f1a53336c5d6459098907a6b Mon Sep 17 00:00:00 2001 From: chenshijun <csj_sky@126.com> Date: 星期三, 04 九月 2019 13:45:19 +0800 Subject: [PATCH] 添加晓龙因业务而增加的更新 --- agent.go | 53 ++++++++++++++++++++------ db.go | 2 config.go | 7 +++ dbself.go | 2 agent_test.go | 2 db_test.go | 2 searcher.go | 2 7 files changed, 52 insertions(+), 18 deletions(-) diff --git a/agent.go b/agent.go index 6e8ffe7..1f84e47 100644 --- a/agent.go +++ b/agent.go @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package main +package syncdb import ( "context" @@ -117,14 +117,17 @@ switch ev := event.(type) { case serf.UserEvent: + var sqlUe SqlUserEvent fmt.Println(string(ev.Payload)) - var tmpstringslice []string - tmpstringslice = append(tmpstringslice, string(ev.Payload)) - fmt.Println(tmpstringslice) - results, err := ExecuteWriteSql(tmpstringslice) - - for _, result := range results { - fmt.Println(result, "results err: ", err) + err := json.Unmarshal(ev.Payload, &sqlUe) + if err !=nil { + fmt.Println("sqlUe unmarshal err:",err) + return + } + if sqlUe.Owner != a.conf.NodeName { + results, _ := ExecuteWriteSql(sqlUe.Sql) + //flag, _ := ExecuteSqlByGorm(sqlUe.Sql) + fmt.Println("userEvent exec ",sqlUe.Sql,",Result:",results) } case *serf.Query: @@ -185,6 +188,19 @@ //var res []*Rows //json.Unmarshal(bytesReturn, &res) } + case serf.MemberEvent: + if event.EventType() == serf.EventMemberLeave { + if ev.Members !=nil && len(ev.Members) ==1 { + leaveMember := ev.Members[0] + leaveSql := "delete from cluster_node where node_id='"+leaveMember.Name+"'" + fmt.Println("leaveSql:",leaveSql) + //ExecuteSqlByGorm([]string{ leaveSql }) + + fmt.Println("EventMemberLeave,current Members:",ev.Members) + } + return + } + default: fmt.Printf("Unknown event type: %s\n", ev.EventType().String()) @@ -405,10 +421,23 @@ }() } +type SqlUserEvent struct { + Owner string `json:"owner"` + Sql []string `json:"sql"` +} //SyncSql boardcast sql to cluster -func (a *Agent) SyncSql(sqlOp string) { +func (a *Agent) SyncSql(sqlOp []string) { // event : use to send command to operate db. - err := a.UserEvent("SyncSql", []byte(sqlOp), false) + var sqlUe = SqlUserEvent{ + Owner: a.conf.NodeName, + Sql: sqlOp, + } + ueB, err := json.Marshal(sqlUe) + if err !=nil { + fmt.Println("sqlUE marshal err:",err) + return + } + err = a.UserEvent("SyncSql", []byte(ueB), false) if err == nil || !strings.Contains(err.Error(), "cannot contain") { fmt.Println("err: ", err) } @@ -480,8 +509,8 @@ n, err := a.Agent.Join(nodes, true) if err != nil || n == 0 { - a.Stop() - fmt.Println("Stop node") + //a.Stop() + //fmt.Println("Stop node") return fmt.Errorf("Error Encrypt Key!") } diff --git a/agent_test.go b/agent_test.go index 98e78fe..fbabde6 100644 --- a/agent_test.go +++ b/agent_test.go @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package main +package syncdb import ( "context" diff --git a/config.go b/config.go index 722fc62..e0d02c8 100644 --- a/config.go +++ b/config.go @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package main +package syncdb import ( "fmt" @@ -118,6 +118,11 @@ if c.Mode == ModeCluster && c.RetryMaxAttempts <= 0 { c.RetryMaxAttempts = retryMaxAttempts } + + serfConf.QueryResponseSizeLimit = c.QueryResponseSizeLimit + serfConf.QuerySizeLimit = c.QuerySizeLimit + serfConf.UserEventSizeLimit = c.UserEventSizeLimit + return serfConf, nil } diff --git a/db.go b/db.go index 22c4961..cce6d76 100644 --- a/db.go +++ b/db.go @@ -1,6 +1,6 @@ // Package db exposes a lightweight abstraction over the SQLite code. // It performs some basic mapping of lower-level types to rqlite types. -package main +package syncdb import ( "database/sql/driver" diff --git a/db_test.go b/db_test.go index 420de25..42a7da3 100644 --- a/db_test.go +++ b/db_test.go @@ -1,4 +1,4 @@ -package main +package syncdb import ( "encoding/json" diff --git a/dbself.go b/dbself.go index 848eba7..70b7024 100644 --- a/dbself.go +++ b/dbself.go @@ -1,4 +1,4 @@ -package main +package syncdb import ( "errors" diff --git a/searcher.go b/searcher.go index 3757b3d..afd2daa 100644 --- a/searcher.go +++ b/searcher.go @@ -1,4 +1,4 @@ -package main +package syncdb import ( "encoding/json" -- Gitblit v1.8.0