initial commit

bin.shen

2016-11-22 fd0f621b9b67d869e089c47f62176cf428586165

initial commit

 .idea/jsLibraryMappings.xml

New file
@@ -0,0 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
  <component name="JavaScriptLibraryMappings">
    <file url="file://$PROJECT_DIR$" libraries="{moral_server/node_modules}" />
  </component>
</project>

 rabbitmq_client.js

New file
@@ -0,0 +1,16 @@

var amqp = require('amqplib/callback_api');

amqp.connect('amqp://guest:guest@121.40.92.176', function(err, conn) {
    conn.createChannel(function(err, ch) {
        var ex = 'open_id';
        ch.assertExchange(ex, 'fanout', {durable: false});
        ch.assertQueue('', {exclusive: true}, function(err, q) {
            console.log(" [*] Waiting for messages in %s. To exit press CTRL+C", q.queue);
            ch.bindQueue(q.queue, ex, '');
            ch.consume(q.queue, function(msg) {
                console.log(" [x] %s", msg.content.toString());
            }, {noAck: true});
        });
    });
});

 sharding.js

New file
@@ -0,0 +1,31 @@
var mongoClient = require('mongodb').MongoClient;

var url = "mongodb://192.168.1.103:10005,192.168.1.104:10005,192.168.1.106:10005/mydb?replicaSet=test12";
//var url = "mongodb://192.168.1.103:10005/mydb";
mongoClient.connect(url, function(err, db) {
    db.collection("users").find({ }).count(function(err, doc){
        console.log(doc);
        db.close();
    });
});

// url = "mongodb://192.168.1.103:10001/mydb";
// mongoClient.connect(url, function(err, db) {
//     db.collection("users").find({ }).count(function(err, doc){
//         console.log("192.168.1.103: " + doc);
//     });
// });
//
// url = "mongodb://192.168.1.104:10002/mydb";
// mongoClient.connect(url, function(err, db) {
//     db.collection("users").find({ }).count(function(err, doc){
//         console.log("192.168.1.104: " + doc);
//     });
// });
//
// url = "mongodb://192.168.1.106:10003/mydb";
// mongoClient.connect(url, function(err, db) {
//     db.collection("users").find({ }).count(function(err, doc){
//         console.log("192.168.1.106: " + doc);
//     });
// });