<span style="font-size:18px;"> func main() {
    var wg sync.WaitGroup
    var index = 0
    // var temp = 0
    for _, empCode := range EmpCodes {//依次開啟每個賬號的執行緒
        index = index + 1
        if index > 1 {
        break
    }
    log.Printf("index:%v", index)
    wg.Add(1)</span>

<span style="font-size:18px;">
    go func(code string) {
       defer wg.Done()
       err := SimulateKeepOnline(code)//呼叫建立websocket連線的方法
       if err != nil {
           log.Printf("[%s] has error: %s", code, err.Error())
           return
       }
    }(empCode)
  }

  wg.Wait()//併發啟動執行緒

}

func SimulateKeepOnline(empCode string) error {
    log.Printf("[%s] Begin...", empCode)
    defer log.Printf("[%s] Exit...", empCode)
    ticket, err := ConnectorAuth(empCode)
    if err != nil {
      return err
    }
    // Extract the cookie for later use
    log.Printf("[%s] Establishing websocket connection...", empCode)

    // Establish websocket connection
    var wsHeader = http.Header(make(map[string][]string))
    cookie := http.Cookie{
        Name:  "WS_TICKET",
        Value: ticket,
    }
    wsHeader.Add("Cookie", cookie.String())
    //伺服器地址
    wsConfig, err := NewConfig("ws://ws.xxx.cn/employee/ws", "http://ws.xxx.cn")
    if err != nil {
        return err
    }
    wsConfig.Header = wsHeader
    wsConn, err := DialConfig(wsConfig)
    if err != nil {
        return err
    }
    log.Printf("[%s] IsClientConn: %v", empCode, wsConn.IsClientConn())
    log.Printf("[%s] IsServerConn: %v", empCode, wsConn.IsServerConn())
    log.Printf("[%s] LocalAddr: %+v", empCode, wsConn.LocalAddr())
    log.Printf("[%s] RemoteAddr: %+v", empCode, wsConn.RemoteAddr())
    log.Printf("[%s] Receiving upstream messages...", empCode)
    for {
        var message string
        //接受伺服器傳送的響應ACK
        if err := Message.Receive(wsConn, &message); err != nil {
            return err
            continue
        }
        log.Printf("[%s] received: %s", empCode, message)
    }
}
</span>