~jinersong/ruleprocess.git

			@@ -1,25 +1,38 @@
			package main

			import (
			"basic.com/dbapi.git"
			"basic.com/pubsub/protomsg.git"
			"basic.com/valib/deliver.git"
			"bufio"
			"bytes"
			"flag"
			"fmt"
			"github.com/golang/protobuf/proto"
			"gocv.io/x/gocv"
			"image"
			"image/color"
			"os"
			"ruleprocess/cache"
			"ruleprocess/insertdata"
			"ruleprocess/ruleserver"
			"ruleprocess/util"
			"sync"
			)

			var dbIp = flag.String("dbIp","127.0.0.1","dbserver ip")
			var dbPort = flag.Int("dbPort",8001,"default dbPort=8001")
			var surveyPort = flag.Int("surveyPort",40007,"survey port") //心跳
			var pubPort = flag.Int("pubPort",50007,"pubsub port") //数据更新
			var initchan = make(chan bool)
			func main() {
			flag.Parse()
			wg := sync.WaitGroup{}
			wg.Add(1)

			dbapi.Init(dbIp,dbPort)
			go cache.Init(initchan,dbIp,surveyPort,*pubPort)
			fmt.Println("cache init completed!!!",<- initchan)//dbserver初始化完毕

			go ruleserver.TimeTicker()
			nReciever("ipc:///tmp/sdk-2-rules-process.ipc", deliver.PushPull, 1)
			wg.Wait()