diff --git a/cluster/cluster.go b/cluster/cluster.go index b5bf119..5c42fbe 100644 --- a/cluster/cluster.go +++ b/cluster/cluster.go @@ -100,7 +100,7 @@ func (cls *Cluster) serviceDiscoverySetNodeInfo (nodeInfo *NodeInfo){ log.Error("Bad duplicate Service Cfg.") continue } - + mapDuplicate[serviceName] = nil cls.mapServiceNode[serviceName] = append(cls.mapServiceNode[serviceName],nodeInfo.NodeId) } diff --git a/go.mod b/go.mod index 855c6a4..70dd224 100644 --- a/go.mod +++ b/go.mod @@ -2,4 +2,12 @@ module github.com/duanhf2012/origin go 1.15 -require gopkg.in/mgo.v2 v2.0.0-20190816093944-a6b53ec6cb22 +require ( + github.com/go-sql-driver/mysql v1.5.0 + github.com/golang/protobuf v1.4.3 + github.com/gomodule/redigo v1.8.3 + github.com/gorilla/websocket v1.4.2 + github.com/json-iterator/go v1.1.10 + google.golang.org/protobuf v1.25.0 + gopkg.in/mgo.v2 v2.0.0-20190816093944-a6b53ec6cb22 +) diff --git a/sysservice/tcpservice/tcpservice.go b/sysservice/tcpservice/tcpservice.go index d6c5644..cef9947 100644 --- a/sysservice/tcpservice/tcpservice.go +++ b/sysservice/tcpservice/tcpservice.go @@ -45,7 +45,6 @@ var seedLocker sync.Mutex type TcpPack struct { Type TcpPackType //0表示连接 1表示断开 2表示数据 - //MsgProcessor processor.IProcessor ClientId uint64 Data interface{} }