Explorar el Código

redis连接失败时,服务直接退出

Sand hace 8 años
padre
commit
9f8cd47cff

+ 6 - 4
src/server/models/client/app.client.js

@ -99,10 +99,12 @@ class AppClient extends RedisModel {
                ModelUtil.logError("Get user app status failed", err);
                return;
            }
            if(!userStatus){
                log.warn("User's app endpoint is not online, user id: " + targetId);
            if (!userStatus) {
                log.warn("User's app status is not found, user id: " + targetId + ", MAYBE user never login yet?");
                return;
            }
            let tipMessage = CONTENT_TYPES.typeToDescription(parseInt(message.content_type), "您有一条新消息") || message.content;
            let customData = {
                session_id: '' || message.session_id,
@ -110,11 +112,11 @@ class AppClient extends RedisModel {
                topic_id: '' || message.topic_id,
                from: '' || message.sender_id,
                data: message.content,
                business_type:message.business_type||1
                business_type: message.business_type || 1
            };
            if (userStatus.platform == PLATFORMS.iOS) {
                pusher.pushToSingleViaAPN(tipMessage, customData,message.contentType, userStatus.token, function (err, res) {
                pusher.pushToSingleViaAPN(tipMessage, customData, message.contentType, userStatus.token, function (err, res) {
                    if (err) {
                        ModelUtil.logError("Send notification via APN failed", err);
                    } else {

+ 7 - 2
src/server/repository/redis/redis.client.js

@ -27,9 +27,14 @@ class RedisClient {
            config.redisConfig
        );
        this._connection.on('ready', function (res) {
            log.info('Redis is ready.');
        this._connection.on('connect', function (res) {
            log.info('Redis is connected.');
        });
        this._connection.on('error', function (res) {
            log.error("Redis connect failed.");
            process.exit(2);
        })
    }
    get connection() {

+ 1 - 1
src/server/util/wlyy.sdk.js

@ -30,7 +30,7 @@ class WlyySDK {
        };
        let req = http.request(options, function (res) {
            res.setEncoding('utf8');
            res.setEncoding('utf-8');
            res.on('data', function (chunk) {
                log.info('家庭医生平台->请求成功:', chunk);