1

关闭查询后很快关闭池时出现此异常：

Uncaught Error: Bad state: Cannot write to socket, it is closed
Stack Trace: 
#0      BufferedSocket.writeBufferPart (package:sqljocky/src/buffered_socket.dart:114:7)
#1      BufferedSocket.writeBuffer (package:sqljocky/src/buffered_socket.dart:108:27)
#2      _Connection._sendBufferPart (package:sqljocky/src/connection.dart:261:31)
#3      _Connection._sendBuffer (package:sqljocky/src/connection.dart:249:29)
#4      _Connection.processHandler (package:sqljocky/src/connection.dart:289:16)
#5      ConnectionPool._closeQuery.<anonymous closure> (package:sqljocky/src/connection_pool.dart:220:29)
#6      _rootRunUnary (dart:async/zone.dart:730)
#7      _RootZone.runUnary (dart:async/zone.dart:864)
#8      _Future._propagateToListeners.handleValueCallback (dart:async/future_impl.dart:488)
#9      _Future._propagateToListeners (dart:async/future_impl.dart:571)
#10     _Future._completeWithValue (dart:async/future_impl.dart:331)
#11     _Future._asyncComplete.<anonymous closure> (dart:async/future_impl.dart:393)
#12     _asyncRunCallbackLoop (dart:async/schedule_microtask.dart:23)
#13     _asyncRunCallback (dart:async/schedule_microtask.dart:32)
#14     _RawReceivePortImpl._handleMessage (dart:isolate-patch/isolate_patch.dart:128)


Unhandled exception:
Bad state: Cannot write to socket, it is closed
#0      _rootHandleUncaughtError.<anonymous closure>.<anonymous closure> (dart:async/zone.dart:713)
#1      _asyncRunCallbackLoop (dart:async/schedule_microtask.dart:23)
#2      _asyncRunCallback (dart:async/schedule_microtask.dart:32)
#3      _asyncRunCallback (dart:async/schedule_microtask.dart:36)
#4      _RawReceivePortImpl._handleMessage (dart:isolate-patch/isolate_patch.dart:128)

问题似乎是查询关闭在内部触发了 Future ，因此 close() 函数在关闭实际完成之前返回：

void _closeQuery(Query q, bool retain) {
  _log.finest("Closing query: ${q.sql}");
  for (var cnx in _pool) {
    var preparedQuery = cnx.removePreparedQueryFromCache(q.sql);
    if (preparedQuery != null) {
      _waitUntilReady(cnx).then((_) {
        _log.finest("Connection ready - closing query: ${q.sql}");
        var handler = new _CloseStatementHandler(preparedQuery.statementHandlerId);
        cnx.autoRelease = !retain;
        cnx.processHandler(handler, noResponse: true);
      });
    }
  }
}

池关闭立即发生，它立即关闭套接字。这意味着查询关闭（由于 Future 而延迟到池关闭之后）失败，无法通过套接字发送它需要的任何信息。我已经在https://github.com/jamesots/sqljocky/issues/44打开了一张 sqljocky 的票，但我没有收到任何回复，如果需要一段时间才能得到回复，我需要一个解决方法。

这段代码允许我 100% 地复制问题：

Future _putMethod(RestRequest request) {
  return new Future.sync(() {
  mysql.ConnectionPool pool = getConnectionPool();
    return pool.prepare("SELECT * FROM files").then((mysql.Query query) {
      return query.execute().then((result) {
        // Do something?
      }).then((_) {
        this._log.info("Closing");
        query.close();
      });
    }).then((_) {
      pool.close();
    });
  });
}
4

1 回答 1

0

这更像是一个问题而不是一个答案，但我不能以一种可用的方式将此代码放在评论中。

您应该确保返回每次异步调用返回的 Future。我不知道我添加评论的行// added return是否是异步调用。

如果这有任何改变，请您尝试并提供反馈。

Future _putMethod(RestRequest request) {
  return new Future.sync(() {
  mysql.ConnectionPool pool = getConnectionPool();
    return pool.prepare("SELECT * FROM files").then((mysql.Query query) {
      return query.execute().then((result) {
        // Do something? // also ensure that a Future of an async invocation is returned
      }).then((_) {
        this._log.info("Closing");
        return query.close(); // added return
      });
    }).then((_) {
      return pool.close(); // added return
    });
  });
}
于 2014-07-14T07:26:49.380 回答