Compare commits
2 Commits
622cd80380
...
6c6995d2dd
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
6c6995d2dd | ||
|
|
8ae1b59a55 |
|
|
@ -37,3 +37,6 @@ config.local.yaml
|
||||||
|
|
||||||
# 需求文件
|
# 需求文件
|
||||||
todo.txt
|
todo.txt
|
||||||
|
|
||||||
|
# 测试文件
|
||||||
|
test/
|
||||||
|
|
@ -118,14 +118,22 @@ func (c *WSClient) closeConn() {
|
||||||
c.isConnected = false
|
c.isConnected = false
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *WSClient) connect() any {
|
func (c *WSClient) connect() error {
|
||||||
c.mu.Lock()
|
|
||||||
defer c.mu.Unlock()
|
|
||||||
|
|
||||||
conn, _, err := websocket.DefaultDialer.Dial(c.config.ServerURL, nil)
|
conn, _, err := websocket.DefaultDialer.Dial(c.config.ServerURL, nil)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
c.mu.Lock()
|
||||||
|
defer c.mu.Unlock()
|
||||||
|
|
||||||
|
select {
|
||||||
|
case <-c.stopChan:
|
||||||
|
conn.Close()
|
||||||
|
return nil
|
||||||
|
default:
|
||||||
|
}
|
||||||
|
|
||||||
c.conn = conn
|
c.conn = conn
|
||||||
c.isConnected = true
|
c.isConnected = true
|
||||||
log.Printf("[网络] 成功连接到服务器: %s", c.config.ServerURL)
|
log.Printf("[网络] 成功连接到服务器: %s", c.config.ServerURL)
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue
Block a user