feat: using eventbus for traffic statistics

Gopkg.toml

@@ -24,11 +24,6 @@
 #   go-tests = true
 #   unused-packages = true
 
-
-[[constraint]]
-  branch = "master"
-  name = "github.com/aead/chacha20"
-
 [[constraint]]
   branch = "master"
   name = "golang.org/x/crypto"
@@ -48,3 +43,7 @@
 [[constraint]]
   name = "github.com/AlecAivazis/survey"
   version = "1.8.0"
+
+[[constraint]]
+  branch = "master"
+  name = "github.com/asaskevich/EventBus"

cmd/test/test.go

@@ -4,8 +4,11 @@ import (
 	"fmt"
 )
 
-func main() {
-	s := "a,c,b,"
-	fmt.Printf(s[:len(s)-1])
+type Test struct {
+	Name string
+}
 
+func main() {
+	a := Test{}
+	fmt.Print(a.(type))
 }

comm/eventbus/eventbus.go

@@ -0,0 +1,17 @@
+package eventbus
+
+import (
+	evbus "github.com/asaskevich/EventBus"
+	"github.com/rc452860/vnet/utils"
+)
+
+var eventBus evbus.Bus
+
+func GetEventBus() evbus.Bus {
+	utils.Lock("eventbus:eventBus")
+	defer utils.UnLock("eventbus:eventBus")
+	if eventBus != nil {
+		eventBus = evbus.New()
+	}
+	return eventBus
+}

conn/conn_decorate.go

@@ -7,6 +7,7 @@ import (
 	"net"
 	"time"
 
+	"github.com/rc452860/vnet/log"
 	"github.com/rc452860/vnet/pool"
 	"github.com/rc452860/vnet/utils"
 	"golang.org/x/time/rate"
@@ -26,7 +27,7 @@ func DialTcp(addr string) (IConn, error) {
 	}
 	err = con.(*net.TCPConn).SetKeepAlivePeriod(30 * time.Second)
 	if err != nil {
-		logging.Error("set tcp keepalive error: %v", err)
+		log.Error("set tcp keepalive error: %v", err)
 	}
 	return icon, nil
 }

db/db.go

@@ -196,9 +196,11 @@ func DbStarted(ctx context.Context) {
 }
 
 type DBTraffic struct {
-	Port int
-	Up   uint64
-	Down uint64
+	Port         int
+	Up           uint64
+	Down         uint64
+	ConnectCount int
+	Connects     map[string]bool
 }
 
 var trafficTable = make(map[int]*DBTraffic)

doc/开发须知.md

@@ -2,4 +2,7 @@ golang 语言学习网址: http://docscn.studygolang.com/
 golang 标准库: https://studygolang.com/pkgdoc
 
 ## 依赖管理
-dep
+dep ensure
+
+
+## EventBus