From fd0f621b9b67d869e089c47f62176cf428586165 Mon Sep 17 00:00:00 2001
From: bin.shen <bluelazysb@hotmail.com>
Date: Tue, 22 Nov 2016 09:18:21 +0800
Subject: [PATCH] initial commit
---
rabbitmq_client.js | 16 ++++++++++++++++
.idea/jsLibraryMappings.xml | 6 ++++++
sharding.js | 31 +++++++++++++++++++++++++++++++
3 files changed, 53 insertions(+), 0 deletions(-)
diff --git a/.idea/jsLibraryMappings.xml b/.idea/jsLibraryMappings.xml
new file mode 100644
index 0000000..0040210
--- /dev/null
+++ b/.idea/jsLibraryMappings.xml
@@ -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>
\ No newline at end of file
diff --git a/rabbitmq_client.js b/rabbitmq_client.js
new file mode 100644
index 0000000..40faee9
--- /dev/null
+++ b/rabbitmq_client.js
@@ -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});
+ });
+ });
+});
\ No newline at end of file
diff --git a/sharding.js b/sharding.js
new file mode 100644
index 0000000..ffba383
--- /dev/null
+++ b/sharding.js
@@ -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);
+// });
+// });
\ No newline at end of file
--
Gitblit v1.8.0