update

broker/broker.go

@@ -34,6 +34,8 @@ type Broker struct {
 
 	cluster *cluster.Cluster
 
+	gid uint64
+
 	sync.RWMutex
 }
 
@@ -47,6 +49,9 @@ func New(path string) *Broker {
 
 		wg:      &sync.WaitGroup{},
 		clients: make(map[uint64]*client),
+
+		// init gid
+		gid: config.Conf.Broker.ID * 1e9,
 	}
 	// init base config
 	config.Init(path)
@@ -93,8 +98,6 @@ func (b *Broker) Shutdown() {
 	b.wg.Wait()
 }
 
-var uid uint64
-
 func (b *Broker) onRequest(w http.ResponseWriter, r *http.Request) {
 	if conn, ok := websocket.TryUpgrade(w, r); ok {
 		c := newClient(conn, b)

broker/client.go

@@ -35,7 +35,7 @@ type client struct {
 }
 
 func newClient(conn net.Conn, b *Broker) *client {
-	id := atomic.AddUint64(&uid, 1)
+	id := atomic.AddUint64(&b.gid, 1)
 	c := &client{
 		id:      id,
 		conn:    conn,

flap.conf

@@ -5,8 +5,9 @@ common:
   loglevel: debug
 
 broker:
+  id: 1
   listen: ':9091'
-
+  
 
 storage:
   provider: fdb

pkg/config/config.go

@@ -15,6 +15,7 @@ type Config struct {
 		LogLevel string
 	}
 	Broker struct {
+		ID     uint64
 		Listen string
 	}
 	Storage struct {