Compare commits

..

2 Commits

Author SHA1 Message Date
wuko233 6c6995d2dd fix: 修复网络连接时波动导致客户端死锁问题 2026-02-17 09:56:07 +08:00
wuko233 8ae1b59a55 chore: 更新.gitignore,添加测试文件夹test/ 2026-02-17 09:23:44 +08:00
2 changed files with 16 additions and 5 deletions

5
.gitignore vendored
View File

@ -36,4 +36,7 @@ config.local.yaml
.DS_Store .DS_Store
# 需求文件 # 需求文件
todo.txt todo.txt
# 测试文件
test/

View File

@ -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)