|
|
@@ -173,6 +173,8 @@ func (r *Client) SetQuoteWebSocket(ws *websocket.Conn) (err error) {
|
|
|
// 注意: 阻塞式, 直到websocket关闭才退出
|
|
|
func (r *Client) readClientWsQuoteMessage() {
|
|
|
for {
|
|
|
+ fmt.Println("readClientWsQuoteMessage start")
|
|
|
+
|
|
|
// 40秒心跳超时
|
|
|
r.wsQuoteConn.SetReadDeadline(time.Now().Add(40 * time.Second))
|
|
|
|
|
|
@@ -277,6 +279,8 @@ func (r *Client) SetTradeWebSocket(ws *websocket.Conn) (err error) {
|
|
|
// 注意: 阻塞式, 直到websocket关闭才退出
|
|
|
func (r *Client) readClientWsTradeMessage() {
|
|
|
for {
|
|
|
+ fmt.Println("readClientWsTradeMessage start")
|
|
|
+
|
|
|
// 40秒心跳超时
|
|
|
r.wsTradeConn.SetReadDeadline(time.Now().Add(40 * time.Second))
|
|
|
|
