间歇性错误“此套接字已被另一方终止”

Intermittent error "This socket has been ended by the other party"

本文关键字：另一方 终止 套接字 错误      更新时间：2023-09-26

我正在连接到我的neo4j在docker容器上运行，当我试图尝试另一个连接/查询时，我得到一个错误。错误提示"此套接字已被另一方终止"。这是我的Dockerfile与打开的端口:

EXPOSE 7474 7473 7687

这是我的驱动程序工具:

var neo4j = require("neo4j-driver").v1,
    config = require("../../config");
(function(module){ 
    module.exports = function(){
        config.neo4j.server = 'localhost';
        return neo4j.driver("bolt://" + config.neo4j.server, neo4j.auth.basic(config.neo4j.user, config.neo4j.password));
    }
}(module));

我对neo4j的查询方式:

(function(module){
    var driver = require('../../../utils/neo4j-driver')(),
        Q = require('q'),
        logger = require('../../../utils/logger'),
        BaseNeo4jModel = require('../../../utils/neo4j-model');
    function userDBAuth(user){
        var deferred = Q.defer();
        var session = driver.session();
        session
            //.run( "MATCH (a:Person) RETURN a.name AS name, a.uuid as uuid" )
            .run("MATCH (user:User {email:{email}})"
                    + "RETURN user",
                    { email: user.email})
            .then(function (result) {
                logger.debug('fetching results...');
                if(result.records.length > 0){
                    var records = [];
                    result.records.forEach(function(record){
                        records.push(new BaseNeo4jModel(record));
                    });
                    done();
                    deferred.resolve(records);
                } else {
                    deferred.reject({sucess: false, message: 'User not Found'});
                }
            }).catch( function(err) {
                logger.error(err);
                done();
                deferred.reject(err.fields[0]);
            });
            return deferred.promise;
        function done(){
            session.close();
            driver.close();
        }
    }
    module.exports = userDBAuth;
}(module));

这是我的堆栈跟踪:

{"name":"auth-services","hostname":"MacBook-Pro-de-Vinicius.local","pid":16292,"level":50,"err":{"message":"This socket has been ended by the other party","name":"Error","stack":"Error: This socket has been ended by the other party
at TLSSocket.writeAfterFIN [as write] (net.js:286:12)
at NodeChannel.write (/Users/viniciussouza/Sites/WeddSocial/backend/weddsocial-auth/node_modules/neo4j-driver/lib/v1/internal/ch-node.js:285:20)
at Chunker.flush (/Users/viniciussouza/Sites/WeddSocial/backend/weddsocial-auth/node_modules/neo4j-driver/lib/v1/internal/chunking.js:114:18)
at Connection.sync (/Users/viniciussouza/Sites/WeddSocial/backend/weddsocial-auth/node_modules/neo4j-driver/lib/v1/internal/connector.js:487:21)
at Session.run (/Users/viniciussouza/Sites/WeddSocial/backend/weddsocial-auth/node_modules/neo4j-driver/lib/v1/session.js:89:20)
at userDBAuth (/Users/viniciussouza/Sites/WeddSocial/backend/weddsocial-auth/app/api/auth/services/userDBAuth.js:13:7)
at Object._auth [as auth] (/Users/viniciussouza/Sites/WeddSocial/backend/weddsocial-auth/app/api/auth/services/auth.js:9:3)
at Server.auth (/Users/viniciussouza/Sites/WeddSocial/backend/weddsocial-auth/app/api/auth/resources/auth.js:7:12)
at next (/Users/viniciussouza/Sites/WeddSocial/backend/weddsocial-auth/node_modules/restify/lib/server.js:906:30)
at f (/Users/viniciussouza/Sites/WeddSocial/backend/weddsocial-auth/node_modules/once/once.js:25:25)","code":"EPIPE"},"msg":"This socket has been ended by the other party","time":"2016-09-27T11:12:33.163Z","v":0}

我绝望了，请帮帮我!

只是一个建议-但看起来您的成功路径并不总是调用done()方法，因此会话并不总是关闭并返回到池。

我建议你修改如下:

            if(result.records.length > 0){
                var records = [];
                result.records.forEach(function(record){
                    records.push(new BaseNeo4jModel(record));
                });
                done();
                deferred.resolve(records);
            } else {
                deferred.reject({sucess: false, message: 'User not Found'});
            }

在else块中添加done()调用:

            if(result.records.length > 0){
                var records = [];
                result.records.forEach(function(record){
                    records.push(new BaseNeo4jModel(record));
                });
                done();
                deferred.resolve(records);
            } else {
                done();
                deferred.reject({sucess: false, message: 'User not Found'});
            }

我们得到了同样的错误，并跟踪到我们的代码，我们有时在事务中的所有查询完成之前提交事务。

看一下你的代码，我建议这样做:

(function (module) {
    var driver = require('../../../utils/neo4j-driver')(),
        Q = require('q'),
        logger = require('../../../utils/logger'),
        BaseNeo4jModel = require('../../../utils/neo4j-model');
    function userDBAuth(user) {
        var session = driver.session();
        return session
            .run("MATCH (user:User {email:{email}}) RETURN user", {email: user.email})
            .then(function (result) {
                logger.debug('fetching results...');
                if (result.records.length === 0) {
                    return Q.reject({success: false, message: 'User not Found'}); // will be caught by the .catch() below
                }
                var records = result.records.map(function(record) {
                        return new BaseNeo4jModel(record); // assume this is synchronous and doesn't return a promise
                    });
                done();
                return records;
            })
            .catch(function (err) {
                logger.error(err);
                done();
                Q.reject(err.fields[0]); // return a rejected promise that can be caught by the caller of userDBAuth
            });
        function done() {
            session.close();
            driver.close();
        }
    }
    module.exports = userDBAuth;
}(module));

不确定这将解决你的问题，因为你做的并不完全是我们所做的，只是一个基于我们发现的建议。

相关文章：