stop bigcache init

panlei

2019-08-30 77a05fa27d55ea7e39aee47f71cb5f74308e5e0e

 ruleserver/readyDataForRule.go

@@ -1,23 +1,21 @@
package ruleserver

import (
   bigCache "basic.com/pubsub/cache.git"
   "basic.com/pubsub/cache.git/esutil"
   "basic.com/pubsub/protomsg.git"
   "encoding/json"
   "errors"
   "fmt"
   "github.com/go-yaml/yaml"
   "github.com/golang/protobuf/proto"
   "io/ioutil"
   "math"
   "nanomsg.org/go-mangos"
   "nanomsg.org/go-mangos/protocol/req"
   "nanomsg.org/go-mangos/transport/tcp"
   "net"
   "os"
   "ruleprocess/cache"
   "ruleprocess/logger"
   "github.com/golang/protobuf/proto"
   "ruleprocess/structure"
   "strconv"
   "time"
@@ -52,7 +50,7 @@
      logger.Error("查询本机信息失败！")
   }
   logger.Debug("本机信息和server信息：", localConfig, serverIp, serverPort)
   bigCache.Init(dbTablePersons, serverIp, serverPort, localConfig.ServerId)
   //bigCache.Init(dbTablePersons, serverIp, serverPort, localConfig.ServerId)
   sock, err = req.NewSocket();
   if err != nil {
      logger.Error("创建请求socket失败: %s", err.Error())
@@ -337,11 +335,11 @@
   //bytes := []byte("ndfasojdfaidsos")
   if err = sock.Send(bytes); err != nil {
      logger.Error("推送socket发送数据失败: %s", err.Error())
      os.Exit(1)
      //os.Exit(1)
   }
   if msg, err = sock.Recv(); err != nil {
      logger.Error("接收响应失败: %s", err.Error())
      os.Exit(1)
      //os.Exit(1)
   }
   logger.Debug("数据推送成功！收到响应,数据长度为：",len(msg))
   return msg