如何杀死Redis上由Node打开的闲置客户端？(How to kill idle clients opened by Node on Redis?)

 这是使用投影的Spring代码。 您可能需要根据从Spring上下文获取MongoOperations对象的方式替换此代码“getMongoConnection（）”。 
 
 使用投影的聚合方法： -  
 
public Boolean aggregateMyTypeCollectionUsingProject() {

        MongoOperations mongoOperations = getMongoConnection();

        ProjectionOperation  project = Aggregation.project().and("props.city").as("city").and("props.age").as("person.age").andExpression("name")
                .as("person.name");
        Aggregation aggregate = Aggregation.newAggregation(project);

        System.out.println(aggregate.toString());
        AggregationResults<DBObject> results = mongoOperations.aggregate(aggregate, MyType.class, DBObject.class);

        System.out.println("Result ============>" + results.getMappedResults());
        return true;

    }
 
 我的getMongoConnection（）方法： -  
 
@SuppressWarnings("resource")
public MongoOperations getMongoConnection() {

    return (MongoOperations) new AnnotationConfigApplicationContext(SpringMongoConfig.class)
            .getBean("mongoTemplate");
}
 
 查询： - 
 
{ "aggregate" : "__collection__" , "pipeline" : [ { "$project" : { "city" : "$props.city" , "person.age" : "$props.age" , "person.name" : "$name"}}]}
 
 输出： - 
 
{
    "_id": {
        "$oid": "57b32d31ced49443e4b79f0d"
    },
    "city": "Moscow",
    "person": {
        "age": "26",
        "name": "Dmitry"
    }
}

Here is the Spring code using projection. You may need to replace this code "getMongoConnection()" based on how you get MongoOperations object from Spring context.
 
Aggregate method using projection:-
 
public Boolean aggregateMyTypeCollectionUsingProject() {

        MongoOperations mongoOperations = getMongoConnection();

        ProjectionOperation  project = Aggregation.project().and("props.city").as("city").and("props.age").as("person.age").andExpression("name")
                .as("person.name");
        Aggregation aggregate = Aggregation.newAggregation(project);

        System.out.println(aggregate.toString());
        AggregationResults<DBObject> results = mongoOperations.aggregate(aggregate, MyType.class, DBObject.class);

        System.out.println("Result ============>" + results.getMappedResults());
        return true;

    }
 
My getMongoConnection() method:-
 
@SuppressWarnings("resource")
public MongoOperations getMongoConnection() {

    return (MongoOperations) new AnnotationConfigApplicationContext(SpringMongoConfig.class)
            .getBean("mongoTemplate");
}
 
Query:-
 
{ "aggregate" : "__collection__" , "pipeline" : [ { "$project" : { "city" : "$props.city" , "person.age" : "$props.age" , "person.name" : "$name"}}]}
 
Output:-
 
{
    "_id": {
        "$oid": "57b32d31ced49443e4b79f0d"
    },
    "city": "Moscow",
    "person": {
        "age": "26",
        "name": "Dmitry"
    }
}